游客jtk3jx2vjvfli
游客jtk3jx2vjvfli_个人页
游客jtk3jx2vjvfli
文章
0
问答
7
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
暂无更多信息
-
回答了问题
2021-12-03
flink-1.10.0 hive-1.2.1 No operators ？
我不是特别确定，但是看起来跟这两行代码有关系： List rowList = TableUtils.collectToList(table); System.out.println(rowList); 这两行代码应该是已经把你前面的SQL执行了。然后最后那个 tableEnv.execute('test'); 就没有可以执行的算子了。*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
直接用AvroDeserializationSchema总是运行失败？
你往kafka中写入avro格式的数据时用kafak的Serializer，写入的格式是当成confluent schemat registry的avro格式吧 confluent schemat registry 在处理avro数据时会多写一个MAGIC_BYTE，一般avro是没有的，消费时用ConfluentRegistryAvroDeserializationSchema 试试。*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
请问有全局状态组件吗？
任意并行度全局状态从物理上就是不可行的，你可以了解一下分布式计算系统怎么部署物理作业的。“全局状态”要么依赖外部存储要么依赖实现（部署）细节。 你这个需求能不能自定义 KeyBy 细节（KeySelector）来实现？相关文档见 https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/api_concepts.html#define-keys-using-key-selector-functions*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
Session Window使用event time延迟特别高是怎么回事呢？
个人理解可以从以下几个角度分析下 1.你说的30s和1s的延迟分别都是怎样对比出来的，参照物是否一致 2.如果上述参照物都是事件数据的原始时间戳的话，可以按照Congxian说的方法查看下 3.如果不是原始时间戳，并且MaxOutOfOrderness = 100ms的情况下，可以先查看是否是根源问题，查看是否是Flink消费作业时，上游事件时间戳是否已经有比较大的延迟*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
无法创建taskmanager flink web界面一致停留在created状态是什么情况？
org.apache.flink.configuration.IllegalConfigurationException: The Flink config file '/tmp/hadoop-bjhl/nm-local-dir/usercache/bjhl/appcache/application_1590820026922_0020/container_1590820026922_0020_01_000008/flink-conf.yaml' (/tmp/hadoop-bjhl/nm-local-dir/usercache/bjhl/appcache/application_1590820026922_0020/container_1590820026922_0020_01_000008) does not exist. 提示配置文件 flink-conf.yaml 不存在，检查一下配置文件是不是目录不对。*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
Flink 中该如何实现“Group By聚合操作”这个需求？
非常抱歉当前确实支持不了，不过这个问题将在 FLIP-95 提供的新 TableSink 接口后解决，有望在 1.11 中解决。*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-03
Flink 1.10.0 HiveModule 使用 explode 函数出错怎么办？
GenericUDTFExplode是一个UDTF。 Flink中使用UDTF的方式是标准SQL的方式： 'select x from db1.nested, lateral table(explode(a)) as T(x)' 你试下。 [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/functions/udfs.html#table-functions*来自志愿者整理的FLINK邮件归档赞0 踩0 评论0
滑动查看更多
暂无更多信息