问答 2022-10-28 来自:开发者社区

flink版本1.14.2 kafka版本0.11.0.1 精确一次模式生产数据报错,有遇到过的吗?

flink版本1.14.2 kafka版本0.11.0.1 精确一次模式生产数据报错,有遇到过的吗?

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

Flink-1.13.6版本的 Flink sql以yarn session 模式运行,怎么禁用托管

Flink-1.13.6版本的 Flink sql以yarn session 模式运行,怎么禁用托管内存啊,尝试了flink-conf配置,也尝试了 sql-client提交时设置,但都不生效。哪位大佬知道怎么禁用托管内存啊

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

请问下群内各位大佬,flink1.13.6版本,standalone集群模式,使用基础的flink

请问下群内各位大佬,flink1.13.6版本,standalone集群模式,使用基础的flink run xxx.jar 提交应用程序到集群上运行,怎么让日志打到 应用程序config/log4j.properties配置文件中指定的日志文件中去?怎么试,好像应用程序日志都是打到${flink_home}/log/flink-root-client-host-xxx.log中去了

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

请问下大家,flink1.13.6版本,standalone集群模式,使用基础的flink run

请问下大家,flink1.13.6版本,standalone集群模式,使用基础的flink run xxx.jar 提交应用程序到集群上运行,怎么让日志打到 应用程序config/log4j.properties配置文件中指定的日志文件中去? 怎么试,好像应用程序日志都是打到${flink_home}/log/flink-root-client-host-xxx.log中去了。

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

flink1.12版本,yarn-application模式Flink web ui看不到日志

2021-06-04 17:38:15,417 INFO org.apache.flink.runtime.entrypoint. ClusterEntrypoint [] - -Dlog .file=/yarn/container-logs/application_1622784975053_0013/container_1622784975053_0013_01_000001/jobma...

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

flink1.12版本,使用yarn-application模式提交任务失败怎么办?

通过脚本提交flink作业,提交命令: /bin/flink run-application -t yarn-application -Dyarn.provided.lib.dirs="hdfs://xx/flink120/" hdfs://xx/flink-example.jar --sqlFilePath /xxx/kafka2print.sql flink使用的Lib及user jar已.....

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

请问 flink1.10版本 table api 可以在stream模式下,写入hive#Flink

请问 flink1.10版本 table api 可以在stream模式下,写入hive 吗?#Flink

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

产品推荐

阿里云实时计算Flink

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

+关注