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

Flink任务假死;无限100%反压;但下游节点无压力是为什么?

如题,这个问题以前遇到过,后来发生频率低了,近期又多了几次,下面是具体的话题讨论,email不方便贴图。 语雀:https://www.yuque.com/sixhours-gid0m/ls9vqu/rramvh *来自志愿者整理的flink邮件归档

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

flink run -d -m yarn-cluster 提交任务到yarn集群不成功怎么办

不太明白“配置到哪一级”是什么含义。export 命令是将变量导出到目前的 shell session,在从 shell logout 之前都有效。如果运行了 export 命令之后再运行 flink run 应该就可行了。*来自志愿者整理的flink邮件归档

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

Flink Yarn Session模式,多任务不同Kerberos认证问题

在Flink Yarn Session中每次提交Job都更换principal。因为要做权限隔离,每个用户有自己的principal。 现在 Flink Session模式是不是无法满足多个principal共享一个Flink Session集群,只能走perjob。 或者每个持有独立principal的用户独享一个Session。*来自志愿者整理的flink邮件归档

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

Flink on yarn 如何指定固定几台yarn节点当做flink任务的运行节点

请问Flink on yarn 如何指定固定几台yarn节点当做flink任务的运行节点?*来自志愿者整理的flink邮件归档

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

flink 1.12提交用户任务方法问题

请问 flink 1.11 版本下 用于提交用户任务的方法   org.apache.flink.client.ClientUtils.submitJob(ClusterClient, JobGraph)方法在 flink 1.12版本下找不到了,  现在用哪个方法取代了呢?又该如何获取提交任务后的jobId呢?谢谢!  | publicstaticJobExecut...

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

./sql-client.sh embedded 这种方式提交的flink任务怎么设置state以及

./sql-client.sh embedded 这种方式提交的flink任务怎么设置state以及checkpoint? 如题 还是只能把sql放在java里边,通过tableEnvironment.sqlQuery执行?*来自志愿者整理的flink邮件归档

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

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已.....

问答 2021-10-27 来自:开发者社区

Flink任务报MySQLTransactionRollbackException异常

Flink任务报MySQLTransactionRollbackException异常

问答 2021-10-27 来自:开发者社区

Flink任务报InvalidProgramException异常

Flink任务报InvalidProgramException异常

问答 2021-10-27 来自:开发者社区

Flink任务报IllegalStateException异常

Flink任务报IllegalStateException异常

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

产品推荐

阿里云实时计算Flink

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

+关注