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

Flink任务编排 可以跑 msyql同步到mysql的批处理任务吗?

Flink任务编排 可以跑 msyql同步到mysql的批处理任务吗?

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

flink cdc 最新版支持一个任务同步多个库吗?

flink cdc 最新版支持一个任务同步多个库吗?

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

要是flink进程挂掉了,之前的任务还能从savepoint恢复吗?

要是flink进程挂掉了,之前的任务还能从savepoint恢复吗

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

这种情况我正在运行的Flink任务能读到新加的200条数据吗?

我现在用 MC中的表作为维表,这个表本来有1000条数据,我启动任务后,正常运行,之后MC中的这个表数据增加了,变成了 1200条数据,这种情况我正在运行的Flink任务能读到新加的200条数据吗?

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

为什么我的有一个flink任务会经常自动创建kafka中的group?

为什么我的有一个flink任务会经常自动创建kafka中的group?

文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之部署到 Kubernetes 集群时,任务过一会儿自动被取消,该如何排查

问题一:实时计算 Flink版有没有clickhouse的连接器分享下呗? 实时计算 Flink版有没有clickhouse的连接器分享下呗? 参考答案: 如果您需要在Flink中连接ClickHouse数据库,您可以考虑以下几种方法: 1.自定义连接器: 您可以尝试自己开发一个连接ClickHouse的Flink连接器。Flink提供了创建自...

实时计算 Flink版产品使用问题之部署到 Kubernetes 集群时,任务过一会儿自动被取消,该如何排查
文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之如何查看和管理任务

问题一:在Flink CDC中3.1版本怎么配置hosts、connectionOptions呢? 在Flink CDC中3.1版本的mongodb connector,使用schema=mongdb+srv的方式,怎么配置hosts、connectionOptions呢? 参考答案: mongodb+srv://cluster0.xxxx.mongo...

实时计算 Flink版产品使用问题之如何查看和管理任务
文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之提交任务时如何设置TaskManager的数量

问题一:flink 1.19.0 版本 任务提交命令中设置TaskManager 个数的参数是哪个? flink 1.19.0 版本 任务提交命令中设置TaskManager 个数的参数是哪个? 参考答案: 在 Flink 1.19.0 版本中,提交任务时可以通过命令行参数来设置 TaskManager 的数量。你可以使用 -p 或 -D 参数来设置并...

文章 2024-08-18 来自:开发者社区

实时计算 Flink版操作报错合集之任务提交后出现 "cannot run program "/bin/bash": error=1, 不允许操作" ,是什么原因

问题一:问下 Flink经常报这个是什么意思,内存不足吗? 问下 Flink经常报 是什么意思,内存不足吗? 参考答案: Flink 任务之间的网络连接出现了问题,或者任务所在的节点之间无法...

实时计算 Flink版操作报错合集之任务提交后出现
文章 2024-08-18 来自:开发者社区

实时计算 Flink版操作报错合集之提交任务后,如何解决报错:UnavailableDispatcherOperationException

问题一:Flink提交任务到yarn 集群 报错?有遇到过类似的错误吗? Flink提交任务到yarn 集群 报错?有大佬遇到过类似的错误吗?Diagnostics from YARN: Application application_1715652296904_0003 failed 1 times (global limit =2; local limit is =1) due to...

实时计算 Flink版操作报错合集之提交任务后,如何解决报错:UnavailableDispatcherOperationException

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

产品推荐

阿里云实时计算Flink

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

+关注