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

当前版本的Flink Mysql CDC, 支持动态更改SQL任务吗?

当前版本的Flink Mysql CDC, 支持动态更改SQL任务吗,Mysql 数据组装写入ES时想要动态新增字段,重新提交flink 初始化数据的时间开销太大了,总共需要向写入ES数据2千万条数据

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

对于Flink CDC,库里有一些没有主键的表,也并没有添加这些表的任务,但产生了错,该怎么处理呢?

对于Flink CDC,库里有一些没有主键的表,也并没有添加这些表的任务,但产生了这样错,我该怎么处理呢?

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

对于Flink CDC,从丢失时刻的checkpoint重启任务,丢失的数据又获取到了。有排查方向吗

目前生产flink14+cdc2.3+mongo4,使用datastream api的方式进行整库订阅,出现数据丢失的情况。在日志中没有任何报错异常。但是我发现数据丢失后,从丢失时刻的checkpoint重启任务,丢失的数据又获取到了。也尝试调了poll.await.time.ms、heartbeat.interval.ms等参数,没有效果。请问有什么排查方向吗?

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

对于Flink CDC,mysql分库分表入iceberg的V2表,任务重启时为啥历史数据重复写入?

对于Flink CDC,mysql分库分表入iceberg的V2表,在任务重启时为啥历史数据会重复写入,并且时区有的正确有的-8小时,有大佬知道怎么解决吗

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

对于Flink CDC,这任务一直处于初始化状态,为什么?

对于Flink CDC,这任务一直处于初始化状态,为什么?

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

多个flink任务,sink-mysql同一个表,会不会锁表呢?

多个flink任务,sink-mysql同一个表,会不会锁表呢?

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

Flink CDC里, 任务那里为什么没有数据?

Flink CDC里, 任务那里为什么没有数据?

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

Flink CDC里,任务那里没有数据是为什么?

Flink CDC里,任务那里没有数据是为什么?

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

请问flink cdc 任务怎么做持久化啊?

请问flink cdc 任务怎么做持久化啊? 目前我重启flink后,之前在执行中的任务就丢了 state.backend: rocksdb

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

如何可以感知flink任务挂掉或者让他在集群查询起task?

如何可以感知flink任务挂掉或者让他在集群查询起task?

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

产品推荐

阿里云实时计算Flink

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

+关注