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

Flink CDC2.4.0连接pgsql的source任务停止后再启动一直提示复制槽重复,有什么?

问题1:Flink CDC2.4.0连接pgsql的source任务停止后再启动一直提示复制槽重复,有什么配置能解决吗? 问题2:指定的是全局唯一的,如果source并行度大于1,第二个source创建连接的时候就提示复制槽已存在;如果source并行度为1,则下次重启的时候也会提示复制槽已存在

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

各位老师,Flink CDC中我这个TM的堆内存占用怎么调小呢?现在没有跑任务,也占用了55%,这有

各位老师,Flink CDC中我这个TM的堆内存占用怎么调小呢?现在没有跑任务,也占用了55%,这有点不合理?

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

Flink CDC这个异常在 taskmanger 节点 任务数上到 19-20 以上时 新任务就?

Flink CDC这个异常在 taskmanger 节点 任务数上到 19-20 以上时 新任务就会出现此问题 有哪位老铁遇到过没,运行大量任务时?org.apache.flink.util.flinkruntimeexception: org.apache.flink.util.FlinkRuntimeException: java.sql.SQLTransientConnectionExce....

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

请问大佬们 有没有遇到Flink CDC task 创建比较多之后,后面任务会出现异常。很多连接 ?

请问大佬们 有没有遇到Flink CDC task 创建比较多之后,后面任务会出现 SQLTransientConnectionException 异常。很多连接 mysql 的任务都会出现超时?

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

大佬,Flink CDC中我使用阿里云的实施计算Flink,采用CDAS语法同步任务,如果我想再当?

大佬,Flink CDC中我使用阿里云的实施计算Flink,采用CDAS语法同步任务,如果我想再当前正在运行的任务中,通过CDAS或者CTAS语法来新增加整库或表的 同步,如何增加allowNonRestoredState这个参数呢?我看官网上有说这个参数,但是没看到sql 怎么来添加?主要是新加库,我们数据量小,为了节约资源,所有同步都放在一个任务中。

问答 2023-06-29 来自:开发者社区

各位大佬 Flink CDC中pyflink可以远程执行任务的吗?

问题1:各位大佬 Flink CDC中pyflink可以远程执行任务的吗? 问题2:我想在我们的运维平台搞一个提交SQL的页面,然后远程提交给flinkserver ,pyflink可以远程提交的么,为什么不建议远程提交代码

问答 2023-06-29 来自:开发者社区

Flink CDC1.15,mysql5.7.23-log,运行一个月后报错任务停止。有状态重启也?

Flink CDC1.15,mysql5.7.23-log,运行一个月后报错任务停止。有状态重启也是报一样的错?

问答 2023-06-29 来自:开发者社区

Flink CDC这个读和写放在一个任务,怎么都没作用了啊?

问题1:Flink CDC这个读和写放在一个任务,怎么都没作用了啊?SourceFunction sourceFunction = OracleSource.builder() .hostname("localhost") .port(1521) .database("ORCL") // monitor XE database .schemaList("scott") // monitor in....

问答 2023-06-29 来自:开发者社区

各位大佬,请教个问题,flink cdc任务启动抽取pg的存量数据时,支持指定offset或者?

问题1:各位大佬,请教个问题,flink cdc任务启动抽取pg的存量数据时,支持指定offset或者timestamp去抽取吗? 问题2:flink cdc的最新版本(2.3)抽取存量数据时直接查询的表(snapshot)而不是读wal日志,所以没办法指定offset和timestamp是吧

问答 2023-06-29 来自:开发者社区

咨询一个Flink CDC问题,为现在有一个实时同步任务,如果为需要增加几个表进去同步。是不是要先?

咨询一个Flink CDC问题,为现在有一个实时同步任务,如果为需要增加几个表进去同步。是不是要先启动一个新任务,把这几个新增表 先全量同步过去,然后再老任务里面 加上这几个表之后,重savepoint 重启任务就行?

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

产品推荐

阿里云实时计算Flink

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

+关注