wormhole

wormhole copied to clipboard

Flow running状态，sink端接收不到数据

2

通过dataRepartitionRdd在driver端遍历可以获取到消息数据，但是mysql的sink端收不到数据。

alexcd90

重现步骤： 给一个Stream添加多个Flow（>50个），最后添加的几个中有可能出现此种问题 期望结果： 所有flow可以正常监控到，running，failed等状态显示正常 实际结果： 部分flow的状态一直为new，查看日志等都没有问题，yarn监控中任务正常运行 修复建议： 建议检查一下工作流监控相关的模块 其他信息： 无

JohnHenryEden

When Flink uses udf functions,udf functions field mapping split bug

Quinto0

Support Flink1.11 ?

2

Is wormhole support flink1.11 ?

zhiyuan192shine

数据如何写hive？

1

sink支持写hive吗？

xiaojiahuo

support data lake component as a source and sink will be useful

1

as the doc : https://iceberg.apache.org/spark-structured-streaming/ is wormhole have any plan to support data lake component

lordk911

flink 从指定checkpoint path 恢复任务

1

任务开启checkpoint 在hdfs上保存了checkpoint，任务失败后，重启任务没有从对应的路径加载checkpoint。什么时候在flow前端页面上提供配置从指定path中恢复checkpoint

inertance

Support spark3.0 ？

1

Is wormhole support spark3.0、flink1.11 ?

guochunhong

根据日志来看，spark已被shutdown，但是状态没有反映。 附：Stream日志 ``` 2020-07-15 10:41:44,762 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2020-07-15 10:41:49,484 INFO yarn.Client: Requesting a new application from cluster...

JohnHenryEden

SeeWei1985