flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 潘明文 <panmin...@163.com>
Subject insert overwrite 问题
Date Sun, 16 Feb 2020 00:41:03 GMT
您好,
    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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message