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

Flink1.15.3 standalone 模式,其中一个任务发生重启,导致集群都挂了 又遇到嘛?

Flink1.15.3 standalone 模式,其中一个任务发生重启,导致集群都挂了 又遇到嘛?

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

Flink CDC中如果MySQL CDC任务中,MySQL的用户密码发生了变化,有什么解决办法么?

Flink CDC中如果MySQL CDC任务中,MySQL的用户密码发生了变化,有什么解决办法么?

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

机器学习PAI的pyalink提交任务到flink集群上的时候怎么定义job name?

机器学习PAI的pyalink提交任务到flink集群上的时候怎么定义job name?

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

Flink CDC中共用连接池是不是会导致不同任务中同一张表的cdc会有冲突?

Flink CDC中我通过更改源码那个连接池默认设置,改成200,现在不报这个错了,但是共用连接池是不是会导致不同任务中同一张表的cdc会有冲突?比如任务1有表a,任务2也有有表a,是由于共享连接池导致的吗?我把之前的任务都关掉重启,现在可以了,多任务启动没有问题了,难道只能通过源码更改那个连接池默认设置吗?或者我要在第一次创建表ddl的时候设置:connection.pool.size我改的是....

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

Flink CDC中为啥单表的sql 批任务,统计的数据都和写sql统计的数据不一致的呢?

Flink CDC中为啥单表的sql 批任务,统计的数据都和写sql统计的数据不一致的呢?是bug还是操作不对?

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

为什么我flink-1.15.3升cdc为2.3和2.4后,创建多个sql-client任务都失败?

"为什么我flink-1.15.3升级cdc为2.3和2.4之后,创建多个sql-client任务都会产生mysql连接超时失败问题?是这两个版本加了什么参数设置吗?换回2.2.1就不会,可以创建多个任务。而2.3和2.4只能创建1-2个任务。ddl没有设置,而且如果ddl设置也只是该任务的设置,看这个错是整个flink都使用了该设置,导致没办法共用连接池或者连接池不够。我把所有任务停了,重新一....

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

flink-cdc的任务中第二个任务是不是要等第一个结束后才能进行同步?

我同一个oracle都挂在一个flink-cdc的任务,那么假如第一个flink-cdc是千万级别的,一直在进行同步,那么我第二个任务flink-cdc,是不是要等第一个结束之后才能进行同步?我当前怎么实现两者分割?

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

FlinkCDC中flink 1.15.3 standalone 模式一个任务发生重启导致集群都挂?

Flink CDC中flink 1.15.3 standalone 模式,其中一个任务发生重启,导致集群都挂了 ,什么原因?

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

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

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

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

flink 1.15.3 standalone 模式,其中一个任务发生重启,导致集群都挂了 又遇到?

flink 1.15.3 standalone 模式,其中一个任务发生重启,导致集群都挂了 又遇到嘛?

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

产品推荐

阿里云实时计算Flink

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

+关注