问答 2024-06-16 来自:开发者社区

请问Flink任务提交后出现这个异常要怎么处理呀 ?

请问Flink任务提交后出现这个异常要怎么处理呀 ?然后执行一会又抛这个异常?

问答 2024-06-16 来自:开发者社区

在Flink CDC中如何把cdc 任务提交到指定的session 集群呢?

在Flink CDC中如何把cdc 任务提交到指定的session 集群呢?

问答 2024-06-16 来自:开发者社区

在Flink CDC中请问任务提交后出现这个异常要怎么处理呀 ?

在Flink CDC中请问任务提交后出现这个异常要怎么处理呀 ?请参考图片:

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据

问题一:这种场景阿里云flink引擎有计划吗? flink 去 lookup join 一张实时写入的维表,在join不到情况下,加入缓存,然后delay retry。这种场景阿里云flink引擎有计划吗? 参考答案: 阿里云Flink引擎确实提供了一些功能来支持维表join操作的优化,但关于特定场景下“实时写入的维表在join不到时加入缓存并延迟重试...

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之在同一个tm里面,任务超过20个后就显示连接池满,连不上数据库了,该怎么处理

问题一:在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,这个问题如何修改配置解决? 在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,连不上数据库了,这个问题如何修改配置解决? 参考答案: source选项里设置这个参数 ...

实时计算 Flink版产品使用问题之在同一个tm里面,任务超过20个后就显示连接池满,连不上数据库了,该怎么处理
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之任务经常exception退出, 如何监控任务状态

问题一:有 Flink CDC的性能优化方面的介绍吗? 有 Flink CDC的性能优化方面的介绍吗? 参考答案: https://github.com/apache/flink-cdc/wiki/Flink-CDC-Blog-(ZH) 看下这些博客。 关于本问题的更多回答可点击进行查看: https://d...

实时计算 Flink版产品使用问题之任务经常exception退出, 如何监控任务状态
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之在进行数据同步时,修改了YAML文件以增加新的同步表并取消了之前的同步任务,如何从之前的检查点继续执行

问题一:flink cdc 3.0 使用pipeline方式同步数据,中断任务后怎么继续之前的任务断点? flink cdc 3.0 使用pipeline同步数据时,如果改动yaml文件已增加新的同步表,取消了之前的同步任务,修改后的任务怎么继续之前的检查点。现在是每次重新提交任务都会重新处理一遍之前同步过程。 参考答案: 在使用 Flink CDC ...

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之全量快照初始化时,如果任务异常自动从ck restore后,会从上次binlog断点续传吗

问题一:Flink CDC 里flink application 模式提交能声明环境变量不? Flink CDC 里flink application 模式提交能声明环境变量不? 参考答案: 当使用 ./bin/flink run-application 命令提交 Flink 应用程序时,可以在命令行中添加 -Dkey=value 格式的 JVM 系统...

实时计算 Flink版产品使用问题之全量快照初始化时,如果任务异常自动从ck restore后,会从上次binlog断点续传吗
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之遇到配置问题导致任务无法正常运行,该怎么办

问题一:在使用 Flink CDC 同步时,如何解决这个问题呢? 在使用 Flink CDC 同步 MySQL 数据到 Doris 的 unique key 表时,我能够同步更新操作,但删除操作却没有被同步。我不确定是不是我的代码配置有问题。以下是我的 source 端和 sink 端的配置。我使用的是版本2.0.1,目前在 unique key 和 duplicate 模型的表中都无法...

实时计算 Flink版产品使用问题之遇到配置问题导致任务无法正常运行,该怎么办
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之 从Kafka读取数据,并与两个仅在任务启动时读取一次的维度表进行内连接(inner join)时,如果没有匹配到的数据会被直接丢弃还是会被存储在内存中

问题一:Flink CDC 里这个配置参数有文档吗?哪里有全部的配置参数可以查到? Flink CDC 里这个配置参数有文档吗?哪里有全部的配置参数可以查到? https://github.com/apache/flink-cdc ...

实时计算 Flink版产品使用问题之 从Kafka读取数据,并与两个仅在任务启动时读取一次的维度表进行内连接(inner join)时,如果没有匹配到的数据会被直接丢弃还是会被存储在内存中

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

产品推荐

阿里云实时计算Flink

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

+关注