问答 2022-07-12 来自:开发者社区

flink cdc在一个job任务同步多表到starrocks,怎么配置?

flink cdc在一个job任务同步多表到starrocks,怎么配置?

问答 2022-07-12 来自:开发者社区

flink ui 界面怎么提交任务呢??

flink ui 界面怎么提交任务呢??

问答 2022-07-10 来自:开发者社区

请教下,大家的Flinksql任务生产上都是怎么部署的啊? 是通过Flink SQL client

请教下,大家的Flinksql任务生产上都是怎么部署的啊? 是通过Flink SQL client 还是 写FlinkSQL代码打jar包部署到yarn上啊?

问答 2022-07-10 来自:开发者社区

请教下,flink cdc 任务 Operator Chains合并之后只有一个节点,该如何查看任务

请教下,flink cdc 任务 Operator Chains合并之后只有一个节点,该如何查看任务实时流量呢?

问答 2022-07-10 来自:开发者社区

flink任务,在做初始化的时候,出现OOM,请问,该如何解决呢?

flink任务,在做初始化的时候,出现OOM,请问,该如何解决呢?

问答 2022-07-10 来自:开发者社区

大佬们,一个正常运行的使用yarn的flink任务,已开启checkpoint,然后再集群遇到不可预

大佬们,一个正常运行的使用yarn的flink任务,已开启checkpoint,然后再集群遇到不可预知的故障后,例如集群服务器断电,接着来电集群恢复正常后,如何获取该任务最新可用的checkpoint用于重启任务呢。主要是不知道在hdfs上保存的checkpoint目录下不知道哪个checkpoint是该任务的最新checkpoint。

问答 2022-07-08 来自:开发者社区

大佬们 我有一个疑问 就是 关于flink-cdc任务执行过程中任务失败导致数据丢失的问题 如果任务

大佬们 我有一个疑问 就是 关于flink-cdc任务执行过程中任务失败导致数据丢失的问题 如果任务失败重启 那重启这段时间的数据是不是就丢失了 如果说checkpoint可以让失败任务保证数据不丢失 那如果目标sink表根据主键upsert数据 flinkcdc实际上已经insert一部分数据进到目标表了 但是任务失败重启会从检查点的位置恢复数据 这样不会造成主键冲突写不进去数据么

问答 2022-07-08 来自:开发者社区

怎么控制flink 流任务的开始时间呢

怎么控制flink 流任务的开始时间呢

问答 2022-07-08 来自:开发者社区

问一个flink相关的问题哈,从checkpoint恢复任务,怎么让它自动找到上次失败的checkp

问一个flink相关的问题哈,从checkpoint恢复任务,怎么让它自动找到上次失败的checkpoint啊?每次还得手动找到再传进去,感觉好费事

问答 2022-07-07 来自:开发者社区

大佬们 我flink yarn-per-job模式任务中间失败了自动重启了 重启这段时间的数据丢失了

大佬们 我flink yarn-per-job模式任务中间失败了自动重启了 重启这段时间的数据丢失了怎么办 这种问题如何排查任务失败原因

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注