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

Flink 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?

Flink application on k8s 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?

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

flink on yarn的应用模式,我提交一个程序最少都要占用4G内存吗?

flink on yarn的应用模式,我提交一个程序最少都要占用4G内存吗?task manager占至少2G,job manager占2G。

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

Flink CDC目前 ds 是不是不支持 session模式?

Flink CDC目前 ds 是不是不支持 session模式?dolphinscheduler Flink Session on Yarn

文章 2023-12-16 来自:开发者社区

在Flink的Standalone模式下,您可以使用`start-cluster.sh`命令启动Flink集群

在Flink的Standalone模式下,您可以使用start-cluster.sh命令启动Flink集群。此命令将启动JobManager和TaskManager。如果您在同一台机器上运行多个TaskManager或JobManager,只需多次运行此脚本即可。 例如,对于JobManager,您可以执行: ./bin/st...

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

在flink1.17Application模式中跑批,有没有办法同步获取任务执行结果后再退出客户端?

在flink1.17Application模式中 客户端执行 flink run-application -t yarn-application 跑批,有没有办法同步获取任务执行结果后再退出客户端 ?

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

使用 Flink CDC 连接到 Oracle ADG 备库(只读模式)时,是什么原因啊?

使用 Flink CDC 连接到 Oracle ADG 备库(只读模式)时,有时能读到数据,有时读不到。但程序都会自动结束,不是监听状态,是什么原因啊?之前出这个严重警告,oracle.simplefan.FanManager: attempt to configure ONS in FanManager failed with oracle.ons.NoServersAvailable: Su....

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

Flink CDC测试使用initial模式,使用savepoint停掉,不会做全量同步?

Flink CDC测试使用initial模式,使用savepoint停掉,删除一个表后,再使用savepoint启动,然后再使用savepoint停掉,加上表,再使用savepoint启动,最终加进去的这个表只会做增量同步,不会做全量同步?

文章 2023-12-06 来自:开发者社区

Flink(二)【Flink 部署模式】

前言        今天是Flink学习的第二天,我的心情异常的复杂哈哈哈(苦笑),学习上还是比较顺利的,感情上我并不擅长,所以心情波动大在所难免。害,至少还有学习让我不被各种糟糕琐碎的日常生活里的人和事所影响。       不管是学习还是生活,保持积极的心态很重要,不要好高骛远,不要想着遥远的目标不敢去努力。今天摘录《解忧杂....

Flink(二)【Flink 部署模式】
文章 2023-12-04 来自:开发者社区

Flink SQL中使用DEBUG模式来输出详细的日志信息,

这种情况可能是由于以下原因导致的: 检查Flink SQL中的Kafka数据源配置是否正确,包括Kafka的地址、端口、Topic名称等。检查Flink SQL中的Doris数据目标配置是否正确,包括Doris的地址、端口、用户名、密码、数据库名、表名等。检查Flink SQL中的数据写入逻辑是否正确,包括SELECT语句和INSERT I...

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

Flink standalone模式扩展taskmanager,知道嘛?

Flink standalone模式扩展taskmanager,使用 start-cluster.sh 同一台机器taskmanager或者jobmanager会启动多个,有大神知道嘛?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注