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 Ta
Hi 明文，
第一个问题，请问你的 pmw 是什么表呢？ 需要检查下其 TableSink 没有实现 AppendStreamTableSink,
RetractStreamTableSink, or UpsertStreamTableSink 任意一个接口。
第二个问题，如果要支持 insert overwrite，需要对应的 TableSink 实现 OverwritableTableSink 接口。
目前 CsvTableSink 没有实现这个接口。
Best,
Jark
On Sun, 16 Feb 2020 at 09:27, Benchao Li wrote:
Hi 明文，
现在insert overwrite应该是只支持HiveTableSink。所以如果你不是HiveTableSink的话，可以直接用“insert
into ..."就可以了。
潘明文 于2020年2月16日周日 上午8:38写道：
> 您好，
> sql 出现以下错误，是什么原因造成的呀？
>
>
> Flink SQL> insert overwrite pmw select '1';
> [INFO] Submitting SQL update statement to the cluster...
> [ERROR] Could not exec
您好，
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, RetractSt
您好，
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, RetractSt
多谢回复。
请问外部hdfs 的配置项如何添加？ 把hdfs 集群的 core-site.xml / hdfs-site.xml 里内容 添加到
计算集群的core-site.xml/hdfs-site.xml 里吗？
Congxian Qiu 于2020年2月15日周六 下午7:31写道：
> Hi
>
> 只要 Flink 的 JM/TM 能访问到外部的 hdfs 就可以的。
>
> Best,
> Congxian
>
>
> tao wang 于2020年2月14日周五 下午10:28写道：
>
> >
> >
>
好的，感谢。我在user里附加了query SQL。
在 2020-02-15 16:14:56，"Jark Wu" 写道：
>Hi sunfulin,
>
>这个异常是说通过 query 推断不出 query 的 primary key，不是说 sink 没有 primary key。至于为什么 query
>推断不出 pk，可能要结合 query 看一下。
>我看到你在 user@ 里面也发邮件了，我已经在那下面回复了，我们要不在 user@ 邮件下面继续讨论吧。可以将你们的 SQL 补充一下，包括
>DDL。
>
>Best,
>Jark
>
>On Fri,
Hi
只要 Flink 的 JM/TM 能访问到外部的 hdfs 就可以的。
Best,
Congxian
tao wang 于2020年2月14日周五 下午10:28写道：
>
>
Hi sunfulin,
这个异常是说通过 query 推断不出 query 的 primary key，不是说 sink 没有 primary key。至于为什么 query
推断不出 pk，可能要结合 query 看一下。
我看到你在 user@ 里面也发邮件了，我已经在那下面回复了，我们要不在 user@ 邮件下面继续讨论吧。可以将你们的 SQL 补充一下，包括
DDL。
Best,
Jark
On Fri, 14 Feb 2020 at 23:03, sunfulin wrote:
> Hi，
> 我使用Flink 1.10，开启了Blink Planner，在尝试写入ES
