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

之前使用云flink , 突然有一天周末重启任务, mysql 连不上了?

之前使用云flink , 突然有一天周末重启任务, mysql 连不上了 。 拉着运维和DBA 看了一天 。 他们都说没有做任何白名单的改动 。 请问这是什么原因呢?

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

在flink1.14版本以前,集群zk抖动问题导致no leader任务自动重启任务,提供的这个解决

在flink1.14版本以前,集群zk抖动问题导致no leader任务自动重启任务,提供的这个解决方案上生产好了么?

问答 2023-06-18 来自:开发者社区

Flink CDC重启不是自动从检查点恢复吗?但我不太明白,我看cdc官网有这个描述!

Flink CDC重启不是自动从检查点恢复吗?但我不太明白,我看cdc官网有这个描述

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

Flink CDC中flinksql 的mysqlconnector,jdbc包放lib目录重启还?

Flink CDC中flinksql 的mysqlconnector,jdbc包放lib目录重启还是加载不到,有人遇见过吗?

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

大佬们请教一个flink 重启生产者的问题,我通过检查点重启作业,但是sink的Kafka ?

大佬们请教一个flink 重启生产者的问题,我通过检查点重启作业,但是sink的Kafka topic换了,就一直报错说生产者尝试使用producer id,但是当前没有给其分配对应的transactional id,这个怎么解决?我通过网上了解到的 producer启动时Kafka会为其分配一个唯一的producer id,这个transactional id是我们自己手动指定的?

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

大佬们请教一个Flink CDC重启生产者的问题,我通过检查点重启作业,但是sink的Kafka ?

大佬们请教一个Flink CDC重启生产者的问题,我通过检查点重启作业,但是sink的Kafka topic换了,就一直报错说生产者尝试使用producer id,但是当前没有给其分配对应的transactional id,这个怎么解决?我通过网上了解到的 producer启动时Kafka会为其分配一个唯一的producer id,这个transactional id是我们自己手动指定的?

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

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原?

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原因?他这个tm日志一直再刷ProducerId,是是什么意思?

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

Flink中开发环境怎么设置从某一个checkpoint 重启呢?

Flink中开发环境怎么设置从某一个checkpoint 重启呢

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

大佬,我用的flink on k8s standalone 配置的高可用任务失败后自动重启没有从?

大佬,我用的flink on k8s standalone 配置的高可用任务失败后自动重启没有从checkpoint处启动呢,而是直接重新启动了呢?可以提供下思路嘛?

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

请教个问题,flink重启之后,重启前运行中的作业都没有了。有方法在重启后自动运行之前的作业吗?因为

请教个问题,flink重启之后,重启前运行中的作业都没有了。有方法在重启后自动运行之前的作业吗?因为机房会在放长假期间断电,得考虑这个问题。

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

产品推荐

阿里云实时计算Flink

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

+关注