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

求大佬解答一下,我现在有个flink cdc任务该怎么处理呢?

求大佬解答一下,我现在有个flink cdc任务,会计算不用的结果列,根据不同属性的列,我分了多个sink table,但是都是写入同一个mysql物理表中,ddl我也定义了主键,应该是开启了upsert的语义的,但是mysql结果表中还是会出现,结果被某些sink 算子直接覆盖了,并没有只是修改对应的列的情况,这种现象需要怎么处理呢?

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

Flink zk 里这么多失败任务,不删除吗?这个会占空间吗

Flink zk 里这么多失败任务,不删除吗?这个会占空间吗

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

Flink这个报错是 任务太多了吗?

Flink这个报错是 任务太多了吗? org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$NumberQuotaExceedException: KeeperErrorCode = Nodes number exceeds quota limit for /flink2/application_16709....

问答 2023-03-13 来自:开发者社区

当mysql源数据过大,要把数据迁移走,便迁移表数据时,又不想影响flink-cdc任务,要怎么办?

当mysql源数据过大,要把数据迁移走,便迁移表数据时,又不想影响flink-cdc任务,要怎么办?因为delete的事件也反应在cdc任务中了,这样会导致之前的统计数据也一并被清楚,这种情况该怎么处理?

问答 2023-03-13 来自:开发者社区

问下flink sql 创建的任务 flink重启后表丢失这个生产是怎么弄的啊?

问下flink sql 创建的任务 flink重启后表丢失这个生产是怎么弄的啊?还有任务执行信息的保存这些flink集群重启保存怎么设置的啊?

问答 2023-03-13 来自:开发者社区

关于Flink CDC,两个任务监控同一个mysql表,serverid改了,为啥还会报错重启?

关于Flink CDC,两个任务监控同一个mysql表,serverid改了,为啥还会报错重启?

问答 2023-03-13 来自:开发者社区

Flink CDC任务突然都终止了,为什么?

Flink CDC任务突然都终止了,为什么?

问答 2023-03-13 来自:开发者社区

定时周期性的启动flink任务都是怎么做的啊?

定时周期性的启动flink任务都是怎么做的啊?

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

flink-on-k8s的application模式怎么保存点重启大佬们有经验的吗 ,任务stop

flink-on-k8s的application模式怎么保存点重启大佬们有经验的吗 ,任务stop后pod都被直接清掉了

问答 2023-03-08 来自:开发者社区

集群上跑的flink任务,如果因为作业复杂导致流程长时间停不下来还有什么强制停止这个任务的办法吗?

standalone集群上跑的flink任务,如果因为作业复杂,数据积压种种原因,导致流程长时间停不下来,除了关集群,还有什么强制停止这个任务的办法吗

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

产品推荐

阿里云实时计算Flink

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

+关注