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

Flink CDC里flink on yarn,咋提交 CDC sql 任务呀?

Flink CDC里flink on yarn,咋提交 CDC sql 任务呀,必须得有 算子调用才能提交执行吗?

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

Flink CDC里并行度会任务会有什么影响?是-P这个参数吗?那-s呢?又是什么意思?

Flink CDC里并行度会任务会有什么影响?是-P这个参数吗?那-s呢?又是什么意思?视图有办法实时同步吗?

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

重启 flink cdc任务后,看着好像又重头开始了...如何解决呢?

重启 flink cdc任务后,看着好像又重头开始了...如何解决呢?

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

Flink CDC里提交两个任务读取sqlserver cdc怎么办?

Flink CDC里提交两个任务读取sqlserver cdc,java.lang.RuntimeException: One or more fetchers have encountered exception是要设置debezium 的servername吗?sqlserver 没有server id可配。报错2024-04-16 17:22:17java.lang.RuntimeExce....

问答 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里能提交实时计算任务嘛?

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

产品推荐

阿里云实时计算Flink

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

+关注