问答 2024-04-22 来自:开发者社区

Flink CDC里mysql cdc 正则匹配需要抽取的表 抽取任务启动后 怎么实现这个目标?

Flink CDC里mysql cdc 正则匹配需要抽取的表 抽取任务启动后 有通过添加什么配置 新增的表也能捕获抽取到呢?我说的是任务不重启 能自动感知新增的表 进行抽取?

问答 2024-04-22 来自:开发者社区

如何保障flink cdc采集任务能在MySQL 多个备库中?

如何保障flink cdc采集任务能在MySQL 多个备库中?如果当前备库挂了,能随意切换到另一个备库的。

问答 2024-04-22 来自:开发者社区

Flink之前有很多历史任务,就是做数据打宽和打点的,这种任务默认是什么模式?

Flink之前有很多历史任务,就是做数据打宽和打点的,这些任务默认采用就是 app mode 提交的到yarn里面的,那现在转到 docker 里面的话,这种任务默认是什么模式?说白了,就是 java -jar 默认使用的啥模式?

问答 2024-04-22 来自:开发者社区

Flink背景:有这4tm2jm,zk做ha的standalone 集群,导致任务提交超时,怎么办?

Flink背景:有这4tm 2jm,zk做ha 的standalone 集群,执行seatunnel提交上来的batch作业。 问题:其中有两个tm在接到分发任务时报错,开了tm debug,看到leadship change,然后new leadship,但是address是null,导致任务提交超时?

问答 2024-04-22 来自:开发者社区

flink 任务任务中设置了数据状态 为 48 小时,并且设置了 状态过期时间,发现内存一直在缓慢增

flink 任务任务中设置了数据状态 为 48 小时,并且设置了 状态过期时间,发现内存一直在缓慢增,可能是什么远影

问答 2024-04-21 来自:开发者社区

dataworks里能提交实时计算任务嘛?

dataworks里能提交实时计算任务嘛?

文章 2024-04-19 来自:开发者社区

【Flink】怎么提交的实时任务,有多少Job Manager?

在 Flink 中提交实时任务时,通常只有一个 JobManager。JobManager 是 Flink 集群的主节点,负责接收、调度和管理作业的执行。一般情况下,每个 Flink 集群只有一个 JobManager,它是整个集群的控制中心。在某些情况下,可以通过配置高可用性(High Availability, HA)模式来启动多个 JobManager 实例,以提高集群的可靠性和容错性。接....

【Flink】怎么提交的实时任务,有多少Job Manager?
问答 2024-04-17 来自:开发者社区

Flink任务没有背压,也没有报错,请教下这种情况需要从哪里入手?

大佬们:Flink任务没有背压,也没有报错,大流量的时候上游Kafka积压很多,但是Flink消费组的消费速率并不会变大;如果重启Flink任务,刚开始的时候会很快消费掉,过一段时间以后,又恒定低速度消费了请教下这种情况需要从哪里入手?

问答 2024-04-15 来自:开发者社区

Flink CDC里我使用3.0的版本 flink1.18版本(官网示例使用版本)启动任务报错咋办?

Flink CDC里使用3.0的版本 flink1.18版本(官网示例使用版本)启动cdc3.0同步mysql 2 doris的任务报错,怎么解决?

问答 2024-04-15 来自:开发者社区

flink cdc读PG启动任务报这个错是什么原因啊?

flink cdc读PG启动任务报这个错是什么原因啊?org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of PostgresConnectorTask; check the logs for detailsorg.apache.kafka.connect.errors.Connect.....

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

产品推荐

阿里云实时计算Flink

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

+关注