java - org.apache.flink.util.FlinkException : Releasing shared slot parent

标签 java apache-flink

我有两份工作,jobA 和 jobB。当我取消jobA时,jobB同时失败。 jobB 抛出

org.apache.flink.util.FlinkException: Releasing shared slot parent

这是什么意思以及如何解决它?

Flink 版本 1.6.0

我有 setting a slot sharing group 的隔离槽对于我的工作:

someStream.filter(...).slotSharingGroup("name");

但是它不起作用。

最佳答案

升级到flink 1.9后该问题得到解决

关于java - org.apache.flink.util.FlinkException : Releasing shared slot parent,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54924020/

相关文章:

java - 如何在 Java 中检测多项式

java - 即使在 apache flink 中实现 AppendTableStream 接口(interface)后仍出现以下错误

java - 使用随机行顺序测试 csv 文件是否相等 (Junit)

Kotlin 类未识别为 Flink 有效 POJO

java - 重新排列列时,对 JTable 列的编辑将数据放置在错误的列中

java - 如何将 Java JMS 与 MQSeries 一起使用

java - 如何将字符串转换为 Java 字符串文字?

java - 是否有输出 javascript 代码的 Javacc 版本?

scala - Flink RocksDB 未在任务管理器中创建 sst 文件

kubernetes - 为什么 Flink 使用 Yarn?