Hi 明文， 现在insert overwrite应该是只支持HiveTableSink。所以如果你不是HiveTableSink的话，可以直接用“insert into ..."就可以了。
潘明文 <[email protected]> 于2020年2月16日周日 上午8:38写道： > 您好， > 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. -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
