问答 2023-09-28 来自:开发者社区

Flink跑流任务的时候遇到一些问题,如图,有大佬指个路么?

Flink跑流任务的时候遇到一些问题,如图,有大佬指个路么?测试过的,b不影响,b的值传上来就不会变,c是传上来之后经过一些列计算才会更新,我试过这个方法,没有奏效,最后不得不把c放case when后面,以我有限的理论知识来说,我只是用视图来确定is_valid的值,不会影响c的更新结果才对,不知道为啥影响了

问答 2023-09-28 来自:开发者社区

如何用flink sql客户端用yarn application模式提交任务呢?

如何用flink sql客户端用yarn application模式提交任务呢?

问答 2023-09-27 来自:开发者社区

请问如何用flink sql客户端用yarn application模式提交任务呢?

请问如何用flink sql客户端用yarn application模式提交任务呢?

问答 2023-09-27 来自:开发者社区

flink任务报错的这个报错是什么意思呢?

flink任务报错:Cannot register Closeable, registry is already closed ,这个报错是什么意思呢?

问答 2023-09-27 来自:开发者社区

请教下Flink CDC多张表同步 一般做多个任务 还是做一个任务?

请教下Flink CDC多张表同步 一般做多个任务 还是做一个任务?

问答 2023-09-26 来自:开发者社区

DataWorks运维中心的实时计算任务的未运行状态是什么情况下产生的?

DataWorks运维中心的实时计算任务的未运行状态是什么情况下产生的?

问答 2023-09-20 来自:开发者社区

Flink CDC任务手动cancele后为啥checkpoin的metadata文件也自动删除了?

Flink CDC中我想测试checkpoin,任务手动cancele后为啥checkpoin的metadata文件也自动删除了?

问答 2023-09-20 来自:开发者社区

Flink CDC为啥我任务消费kafka数据到这就停止了?

Flink CDC为啥我任务消费kafka数据到这就停止了?kafka数据有积压

问答 2023-09-20 来自:开发者社区

Flink CDC任务能正常提交到yarn 这个0.0.0.0:8030能用什么参数修正呀?

Flink CDC任务能正常提交到yarn 但是任务会使用0.0.0.0:8030去找主节点 导致如果任务没有分配到rm节点上就回报错 能正常提交任务说明我配置文件也没问题 老铁们 这个0.0.0.0:8030能用什么参数修正呀?

问答 2023-09-20 来自:开发者社区

提交到flink集群任务正常运行 ck完成不了 有遇到过吗?

提交到flink集群任务正常运行 提交到yarn上is not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running.. ck完成不了 有老铁遇到过吗?

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

产品推荐

阿里云实时计算Flink

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

+关注