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

Flink CDC使用DataStream APi 的话 flink 上面可以看到执行任务吗?

问题1:Flink CDC使用DataStream APi 的话 flink 上面可以看到执行任务吗?问题2:需要哪里配置嘛 ,我项目启动了 但是在flink 上面没看到任务

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

老师 Flink CDC不想打jar包提交到flink集群 直接想在线提交任务 怎么个思路?

老师 Flink CDC不想打jar包提交到flink集群 直接想在线提交任务 怎么个思路?

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

Flink运行的过程中,不定时会报这个错误,导致CDC任务运行失败,是LogMiner引起的吗?

Flink运行的过程中,不定时会报这个错误,导致CDC任务运行失败,是LogMiner引起的吗?版本是2.2.1,同时监测数据库PGA不断增加,最后导致内存不足的情况出现

问答 2023-07-31 来自:开发者社区

flink任务基于checkpoint重启失败后,把chk目录删除了,这样的情况怎么避免呢?

flink任务基于checkpoint重启失败后,把chk目录删除了,这样的情况怎么避免呢?

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

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

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

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表,没更新?

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表。过了半天之后,更新源表中的记录,发现目标表没更新。这是flink SQL不支持吗,还是要做什么特殊设置,或者使用什么语法?就是更新了where条件对应的记录,另外,大表join,是如何做实时记录匹配的,应该是需要流内存拦截吧,不然怎么做到实时匹配呢?假如关联的两张表的记录一个在最开始就来了,另一个迟了很久才....

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

Flink CDC中这个是多表关联任务吗?为啥会不展开的,只有一个图,输出到什么库啊?

Flink CDC中这个是多表关联任务吗?为啥会不展开的,只有一个图,输出到什么库啊?

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

Flink CDC中数据库cdc任务启动后第二天数据库里新建的表 没有读到数据,怎么办?

Flink CDC中数据库有表按天分区,cdc任务启动后,第二天数据库里新建的表 没有读到数据,怎么解决?是正则写的有问题吗?^db.tableName\d{4}\d{2}_\d{2}$

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

Flink CDC中当前是启动任务全量数据可以同步,增量数据不同步怎么排查?

Flink CDC中,我是flink1.17.1+mysql cdc2.4.0+mysql5.7(source端),当前是启动任务全量数据可以同步,增量数据不同步,checkpoint开启了,也没见什么异常信息。怎么排查?我这边使用的Dinky,通过SQL的方式做的,如下是SQL配置部分

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

Flink CDC中ckp失败会导致任务OOM吗?

Flink CDC中ckp失败会导致任务OOM吗? 我已经调整过了 -checkpointDir hdfs:///flink/checkpoint/ -checkpointInterval 900000 -tolerableCheckpointFailureNumber 100 -checkpointTimeout 900000

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

产品推荐

阿里云实时计算Flink

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

+关注