|
您好,
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
|