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

flink在standalone模式下任务失败任务太多次,这个问题有解决方案么?

flink在standalone模式下任务失败任务太多次,会导致jobmanager的jvm heap内存不断增加,这个问题有解决方案么?

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

flink standalone模式调用job/stop接口任务停不了,显示重启中。知道怎么回事嘛?

flink standalone模式调用job/stop接口任务停不了,显示重启中。有大神知道怎么回事嘛?

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

有个问题想请教一下flink为什么任务启动一直accepted状态?yarn的,有什么排查方向吗?

有个问题想请教一下flink1.13版本上部署一个flink1.17为什么任务启动一直accepted状态?yarn的,有什么排查方向吗?资源什么的都是充足的

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

请教个问题,flink1.18跑在k8s,任务提交上去,几十秒自动cancel了,了解吗?

请教个问题,flink1.18跑在k8s,任务提交上去,几十秒自动cancel了,flink1.13版本没啥问题,有大佬了解吗?

文章 2023-11-18 来自:开发者社区

对于Flink任务的数据丢失问题,你可以从以下几个方面进行排查:

对于Flink任务的数据丢失问题,你可以从以下几个方面进行排查: Flink任务的checkpoint机制:检查Flink任务的checkpoint配置,确保其配置正确且能够正常触发。同时,检查任务是否在异常情况下成功完成了checkpoint。 Flink任务的state backend:检查Flink任务的s...

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

Flink CDC用DataStream开发任务么?

Flink CDC用DataStream开发任务么?Flink SQL模式和DataStream哪种效率高些?sink写的是自定义的吗?全量和增量的并行度是怎么判断修改的呢?我现在也在用flink做数据同步?

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

flink cdc 任务启动后加表读binlog报错有人碰到没?

flink cdc 任务启动后加表读binlog报错有人碰到没?2023-11-09 19:30:05,620 ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Error during binlog processing. Last offset stored = {transaction_id=nu.....

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

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启?

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启,这是正常日志?

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

Flink CDC用cdc版本2.4的话 任务起不来 一直ctreated状态?

Flink CDC是1.15的emr 阿里的半托管, 用cdc版本2.4的话 任务起不来 一直ctreated状态?

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

在Flink我这样创建的水印,但是任务运行的时候报错怎么处理?

在Flink我这样创建的水印,但是任务运行的时候报错怎么处理? timestamp是bigint型, 单位秒,我也这么改过, 但是问题还是存在,没有解决。

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注