AI 助理
备案控制台

游客jtk3jx2vjvfli_个人页

游客jtk3jx2vjvfli
个人头像照片
文章
0
问答
7
视频
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力：

暂时未有相关通用技术能力~

云产品技术能力：

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息

2021年12月

正在加载, 请稍后...
暂无更多信息
  • 回答了问题 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
  • 回答了问题 2021-12-03

    直接用AvroDeserializationSchema总是运行失败？

    你往kafka中写入avro格式的数据时用kafak的Serializer，写入的格式是当成confluent schemat registry的avro格式吧 confluent schemat registry 在处理avro数据时会多写一个MAGIC_BYTE，一般avro是没有的，消费时用ConfluentRegistryAvroDeserializationSchema 试试。*来自志愿者整理的FLINK邮件归档
    踩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
  • 回答了问题 2021-12-03

    Session Window使用event time延迟特别高是怎么回事呢？

    个人理解可以从以下几个角度分析下 1.你说的30s和1s的延迟分别都是怎样对比出来的，参照物是否一致 2.如果上述参照物都是事件数据的原始时间戳的话，可以按照Congxian说的方法查看下 3.如果不是原始时间戳，并且MaxOutOfOrderness = 100ms的情况下，可以先查看是否是根源问题，查看是否是Flink消费作业时，上游事件时间戳是否已经有比较大的延迟*来自志愿者整理的FLINK邮件归档
    踩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
  • 回答了问题 2021-12-03

    Flink 中该如何实现“Group By聚合操作”这个需求？

    非常抱歉当前确实支持不了，不过这个问题将在 FLIP-95 提供的新 TableSink 接口后解决，有望在 1.11 中解决。*来自志愿者整理的FLINK邮件归档
    踩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
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息