insert overwrite 问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

insert overwrite 问题

潘明文
您好,
    sql 出现以下错误,是什么原因造成的呀?


    Flink SQL> insert overwrite pmw select '1';
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: Stream Tables can only be emitted by AppendStreamTableSink, RetractStreamTableSink, or UpsertStreamTableSink.


还有个问题:
CREATE TABLE Orders(amount BIGINT) WITH ('connector.type' = 'filesystem','connector.path'='/opt/Orders','format.type' = 'csv','update-mode' = 'append')

出现下面错误
Flink SQL> insert overwrite  Orders select 1;    
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
java.lang.AssertionError: assertion failed: INSERT OVERWRITE requires OverwritableTableSink but actually got org.apache.flink.table.sinks.CsvTableSink