HI ,
HiveTableSink正对HIVE 种创建的表可以是吗？ 但我用HIVE 创建表的(表是在HIVE 中创建的)，FLINK SQL
中直接使用HIVE 表
Flink SQL> INSERT INTO hive_test select '11';
[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.
Flink SQL> INSERT overwrite hive_test select '11';
[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.
在 2020-02-16 09:27:29，"Benchao Li" <[email protected]> 写道：
>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]
