问答 2023-04-12 来自:开发者社区

问一下大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试

问一下大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试连接旧的hdfs(我们换了hdfs,把任务的checkpoint相关文件迁移到新的hdfs了),这样的问题遇到过么?或者checkpoint会存储集群的hdfs地址么?

问答 2023-04-11 来自:开发者社区

有兄弟使用 flink on k8s 命令提交任务的时候,限制 cpu 内存 参数的没 比如在容

有兄弟使用 flink on k8s 命令提交任务的时候,限制 cpu 内存 参数的没 比如在容器中有 limits 和 requests 参数,命令提交任务的时候是什么参数?

问答 2023-04-11 来自:开发者社区

老哥们,我有个问题,就是flink任务设置了restart strategy,所以报错会自动重启,但

老哥们,我有个问题,就是flink任务设置了restart strategy,所以报错会自动重启,但是重启后我看taskManager中的日志刷新了,想看之前taskmanager日志中报错详情除了将任务停掉取yarn看历史日志,有没有不用停掉任务的方法?

问答 2023-04-11 来自:开发者社区

请教一下、flink on yarn模式下如何让提交的Application任务中加载的一些配置文

请教一下、flink on yarn模式下如何让提交的Application任务中加载的一些配置文件及jar包打到hdfs的/user/flink/.flink的目录下

问答 2023-04-11 来自:开发者社区

flink job自动重启,sink task一直处于canceling状态,导致整个任务不能重启。

flink job自动重启,sink task一直处于canceling状态,导致整个任务不能重启。有大佬知道为啥吗?

问答 2023-04-11 来自:开发者社区

Flink sqlgateway 偶发性执行任务报错Stream closed web界面显示任务

Flink sqlgateway 偶发性执行任务报错Stream closed web界面显示任务取消 请问下需要修改啥配置

问答 2023-04-10 来自:开发者社区

问一下群里的大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里

问一下群里的大佬们,我们最近flink任务从checkpoint(hdfs存储)恢复,发现恢复信息里还尝试连接旧的hdfs(我们换了hdfs,把任务的checkpoint相关文件迁移到新的hdfs了),这样的问题遇到过么?或者checkpoint会存储集群的hdfs地址么?

问答 2023-04-10 来自:开发者社区

大佬们,使用flink cdc 同步oracle的数据,如果归档日志被删除了,流任务重新拉起的话,还

大佬们,使用flink cdc 同步oracle的数据,如果归档日志被删除了,流任务重新拉起的话,还能读到oracle的数据吗?如果oracle的数据在一开始就没有开启归档日志,在开启归档日志之前的数据Flink cdc可以读取到吗?

问答 2023-04-10 来自:开发者社区

mysql cdc开启了增量并发同步,但flink中只有一个任务在同步数据,可能是什么原因?

mysql cdc开启了增量并发同步,但flink中只有一个任务在同步数据,可能是什么原因?

问答 2023-04-05 来自:开发者社区

请问flink任务使用flink run的形式从savepoint恢复, 但是启动成功了,在chec

请问flink任务使用flink run的形式从savepoint恢复, 但是启动成功了,在checkpoint的页面的restored还是显示0,任务是自己做了savepoint的,也是有地址的,直接从上次savepoint恢复的3月28日 11:01

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

产品推荐

阿里云实时计算Flink

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

+关注