问答 2021-12-08 来自:开发者社区

flink-1.12.1 k8s Session集群模式没有生成Stdout输出文件

我参考: https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/standalone/kubernetes.html 部署了一个session集群,运行任务。 在UI查看Stdout是空的,没有生成 .out 文件 请问是哪里配置的问题吗?*来自志愿者整理的flin...

问答 2021-12-08 来自:开发者社区

Flink1.12 批处理模式,分词统计时单词个数为1的单词不会被打印怎么处理?

代码: val env = StreamExecutionEnvironment.getExecutionEnvironment env.setRuntimeMode(RuntimeExecutionMode.BATCH) // 在DataStream API上以批处理方式执行 // 本地测试文件 val inputStream = env.readTextFile(getClass.get...

问答 2021-12-08 来自:开发者社区

on yarn模式,我是否需要在每台机器上都安装flink软件目录,还是只需要在提交机器上有flin

环境: flink1.9.1, on yarn hadoop2.6 flink只安装在了一台提交的机器上, lib目录下有文件: flink-dist_2.11-1.9.1.jar flink-json-1.9.0-sql-jar.jar flink-shaded-hadoop-2-uber-2.6.5-7.0.jar flink-sql-connector-kafka_2.11-1.9.0......

问答 2021-12-07 来自:开发者社区

flink-1.8.1 yarn per job模式使用

Hi 大家好: 在使用flink过程中,运行官网给的命令 https://ci.apache.org/projects/flink/flink-docs-stable/ops/deployment/yarn_setup.html#run-a-single-flink-job-on-yarn 报错如下: ➜ flink-1.8.1 ./bin/flink run -m yarn-cluster...

问答 2021-12-07 来自:开发者社区

Apache Flink中流处理的处理时间模式是什么呢?

Apache Flink中流处理的处理时间模式是什么呢?

问答 2021-12-07 来自:开发者社区

Apache Flink中流处理的事件时间模式是什么呢?

Apache Flink中流处理的事件时间模式是什么呢?

问答 2021-12-07 来自:开发者社区

Flink 不同模式的任务提交应该怎么弄?

Flink 不同模式的任务提交应该怎么弄?

问答 2021-12-07 来自:开发者社区

Flink on Yarn模式具体应该怎么安装?

Flink on Yarn模式具体应该怎么安装?

问答 2021-12-07 来自:开发者社区

Flink on Zeppelin 中Yarn Application 模式是什么?

Flink on Zeppelin 中Yarn Application 模式是什么?

问答 2021-12-07 来自:开发者社区

Flink on Zeppelin 中Yarn Interpreter 模式是什么?

Flink on Zeppelin 中Yarn Interpreter 模式是什么?

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

产品推荐

实时计算 Flink

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

+关注