问答 2023-08-22 来自:开发者社区

如何通过 flink api 方式,将jar任务提交到Yarn上以Application运行?

有没有谁知道如何通过 flink api 方式,将jar任务提交到 Yarn 上以Application运行?就是用本地Java代码替代"flink run-application ..."命令。

问答 2023-08-22 来自:开发者社区

Flink为什么我的这个任务,遇到异常数据自动重启时,不会从上一次的CheckPoint进行重启呢?

Flink为什么我的这个任务,遇到异常数据(手动造了一条)自动重启时,不会从上一次的CheckPoint进行重启呢?而是从latest-offset进行重启呢?手动造了一条异常数据 让它自动重启的。

问答 2023-08-22 来自:开发者社区

flink任务从intel x86机器迁移到arm机器, 报错怎么解决?

flink任务从intel x86机器迁移到arm机器, 从checkpoint启动 state rockdb报错 怎么解决?Snappy not supported or corrupted Snappy compressed block contents,

问答 2023-08-22 来自:开发者社区

请问,Flink CDC怎么停止启动的任务?

请问,Flink CDC怎么停止启动的任务?

问答 2023-08-22 来自:开发者社区

Flink CDC你们如果中间任务失败了?如何恢复?通过检查点恢复还是怎么搞?如果binlog索引被

问题1:Flink CDC你们如果中间任务失败了?如何恢复?通过检查点恢复还是怎么搞?如果binlog索引被清理了你是怎么解决的?问题2:你们代码有加什么设置吗?比如server id?

问答 2023-08-22 来自:开发者社区

Flink CDC自动任务什么意思? 大佬请教一个有关flink cdc实时同步MySQL的问题,当

Flink CDC自动任务什么意思?大佬请教一个有关flink cdc实时同步MySQL的问题,当我全量同步过来,切接上了增量数据,当运行的过程中报异常提示找不到了binlog的位置该如何解决这个问题?通过检查点重启任务也是报这个binlog 位置已被清除如何解决?

问答 2023-08-22 来自:开发者社区

Flink CDC有没有大佬遇到过oracle cdc监控数据表,运行几天后任务就内存溢出的问题?

Flink CDC有没有大佬遇到过oracle cdc监控数据表,运行几天后任务就内存溢出的问题?在测试环境测试发现即使没有数据进行变更,观测其进程内存变化也是一直在创建对象,然后就会频繁gc,运行个2天左右就会挂掉。

问答 2023-08-22 来自:开发者社区

flink Kubernetes Session提交任务所产生的任务pod为什么没办法解析主机域名?

flink Kubernetes Session提交任务所产生的任务pod没办法解析主机域名 ,怎么解决?

问答 2023-08-22 来自:开发者社区

我这个flink任务,查看jobmanager日志,接口报错,是什么问题呢?

我这个flink任务,查看jobmanager日志,接口报错,是什么问题呢?能帮忙看下吗,taskmanager的任务也看不到。

问答 2023-08-21 来自:开发者社区

有没有谁知道如何通过 flink api 方式,将jar任务提交到 Yarn 上以Applicati

有没有谁知道如何通过 flink api 方式,将jar任务提交到 Yarn 上以Application运行?就是用本地Java代码替代"flink run-application ..."命令。

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

产品推荐

阿里云实时计算Flink

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

+关注