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