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

flink-cdc.sh 中的 【--global-config】参数也是提供一个yaml吗?

flink-cdc.sh 中的 【--global-config】参数也是提供一个yaml吗,这里面可以那些参数可以给个参考吗?

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

Flink报错checkpointID-xxxalready exists in Config...

Flink报错checkpointID-xxxalready exists in ConfigMap job-***-jobmanager-leader

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

为啥flink的flink-config.yaml不用指定位置?

为啥flink的flink-config.yaml不用指定位置,我看taskmanager的日志中有写已经找到这个config了,但是不一定为啥不生效?

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

flink on yarn 环境,当任务程序包和配置文件目录config分离,应该怎么启动任务程序?

flink on yarn 环境,当任务程序包和配置文件目录config分离,并上传到HDFS时,应该怎么启动任务程序?

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

Please specify JAVA_HOME. Either in Flink config .

Please specify JAVA_HOME. Either in Flink config ./conf/flink-conf.yaml or as system-wide JAVA_HOME. 使用shell脚本执行 flink sql 报这个错误,有大佬知道是什么原因吗?JDK是1.8

问答 2022-07-23 来自:开发者社区

大佬们,flink往kafka写数据保证事务,TRANSACTIONAL_ID_CONFIG设置是怎

大佬们,flink往kafka写数据保证事务,TRANSACTIONAL_ID_CONFIG设置是怎么设置的,事务id写死?

问答 2022-02-15 来自:开发者社区

Question about the flink 1.6 memory config?

Now I am optimizing the flink 1.6 task memory configuration. I see the  source code, at first, the flink task config the cut-off memory, cut-off  memory = Math.max(600,containerized.heap-cut...

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

产品推荐

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等