????: ????????json schema??????????????????

2019-09-19 文章 ?? ??
??Types.LIST(Types.STRING)??flink-planner??blink-plannerTypes.OBJECT_ARRAY(Types.STRING)?? Type LEGACY(List) of table field 'ARRAY_FIELD' does not match with type List of the field 'ARRAY_FIELD' of the TableSource return type.

Re: How to implement grouping set in stream

2019-09-19 文章 Dian Fu
AFAIK, grouping sets has already been supported for streaming in blink planner. You could check FLINK-12192 for details. Regards, Dian > 在 2019年9月10日,下午6:51,刘建刚 写道: > > I want to implement grouping set in stream. I am new to flink sql. I > want to find a example to teach me how to self

Re: Flink BlobServerConnection NoSuchFileException

2019-09-19 文章 Dian Fu
我猜测原因是blob server目录里存的blob文件被删了,所以/tmp/blobStore-ca0f7afe-bd98-40cc-ae36-4ad96b1ef97e/incoming/temp-03506073目录为空,具体可以参考如下代码: https://github.com/apache/flink/blob/1a81982ba864d72fda3d161fc82ca1572333ba11/flink-runtime/src/main/java/org/apache/flink/runtime/blob/FileSystemBlobStore.java#L129

Flink BlobServerConnection NoSuchFileException

2019-09-19 文章 guo liu
hi, 我们在使用flink-stream时遇到了如下问题,有谁可以帮助一下吗?怎么避免该问题呢? flink版本:flink-1.8.1 standalone cluster node4是我们集群中的一个slave节点,我们的任务运行了差不多1个月才出现的这个问题。这个异常导致任务全部处于失败然后恢复失败的循环中,目前不知道什么原因造成的,查看了 /tmp/blobStore-ca0f7afe-bd98-40cc-ae36-4ad96b1ef97e/incoming/文件夹是空的。 谢谢。 2019-09-19 16:54:34,328 ERROR

在json schema中如何定义数组字段

2019-09-19 文章 苏 欣
我是用的是flink-1.9版本,现在想消费带数组字段的json数据,类似{“field1:” “aaa”, “field2”: [“bbb, “ccc”]} 这种数据格式。 注册schema的时候我使用了field("field2", Types.OBJECT_ARRAY(Types.STRING))这种方式。EnvironmentSetting指定为flink-planner和blink-planner都有问题。