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

flink on yarn 集群跑cdc任务突然报这个错误,集群连不上了 这是什么问题呢?

flink on yarn 集群跑cdc任务突然报这个错误,集群连不上了 这是什么问题呢?请参考图片:

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

Flink cdc 任务启动后,发现PG数据库中的这个进程一直是lock状态,如何解决?

Flink cdc 任务启动后,数据同步不了,排查下来,发现PG数据库中的这个进程一直是lock状态,如何解决?请参考图片:

问答 2024-07-24 来自:开发者社区

麻烦问一下可以通过java 接口 动态的开启关闭运行在flink 的job任务吗?

麻烦问一下可以通过java 接口 动态的开启关闭运行在flink 的job任务吗?

问答 2024-07-24 来自:开发者社区

Flink通过接口提交任务,webui界面 Entry Class参数有值的话有知道怎么回事吗?

Flink通过接口提交任务,webui界面 Entry Class参数有值的话,指定类入口路径开启job失败。上面的job就可以正常开启,有大佬知道怎么回事吗?

文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理

问题一:我使用Flink CDC 3.0对mysql整库同步到starrock中,任务挂掉是为啥? 我使用Flink CDC 3.0对mysql整库同步到starrock中,现在任务已经创建好了,mysql的表和数据都同步到starrock中了,现在发现的问题是,我在源表加了新字段,接着flink的任务就挂掉了是为什么? ...

实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务

问题一:Flink CDC我使用cdc从oracle同步数据到doris,数据全部加载到内存后,报错怎么办? Flink CDC里我使用cdc从oracle同步数据到doris,这边将数据全部加载到内存后,报错如下:2024-01-09 15:11:00,825 WARN org.apache.flink.runtime.taskmanager.Task [] - Sink sink-d...

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之在使用RDS数据库作为源端,遇到只能同步21个任务,是什么导致的

问题一:有咩有碰到Flink CDC这个问题呀? 有咩有大老碰到Flink CDC这个问题呀?并没有file字段,也没有改变schema 参考答案: 这是一个待修复的问题,issue 上直接可以搜...

实时计算 Flink版操作报错合集之在使用RDS数据库作为源端,遇到只能同步21个任务,是什么导致的
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之从检查点重启任务,怎么在YAML配置文件中添加检查点的路径

问题一:使用flink native k8s的nodeport模式,能指定暴露的port吗? 使用flink native k8s的nodeport模式,能指定暴露的port吗? 参考答案: 在Flink中,通过使用NodePort模式暴露服务,可以指定要暴露的端口。NodePort模式允许你将Flink服务从集群内部访问扩展到集群外部,通过为每个节点...

实时计算 Flink版产品使用问题之从检查点重启任务,怎么在YAML配置文件中添加检查点的路径
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之任务无法实时同步MySQL到StarRocks中修改的数据,是什么原因

问题一:Flink CDC里mysql8 然后不是默认开始了binlog吗? Flink CDC里我用的mysql8 然后不是默认开始了binlog吗。然后我运行github上面的demo 并且设置了 startupOptions 但是控制台还是没有输出数据这是怎么回事? 参考答案: 是binlog生成日志的问题。 关于本问...

实时计算 Flink版产品使用问题之任务无法实时同步MySQL到StarRocks中修改的数据,是什么原因
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在场景中新加入了其他的CTAS语句后任务无法启动,该如何解决

问题一:Flink vvr上业务延迟时间和传输延迟时间是咋计算出来的? Flink vvr上业务延迟时间和传输延迟时间是咋计算出来的? 参考答案: hover到指标上有具体说明: ...

实时计算 Flink版产品使用问题之在场景中新加入了其他的CTAS语句后任务无法启动,该如何解决

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

产品推荐

阿里云实时计算Flink

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

+关注