代码之家 › 专栏 › 技术社区 › Alejandro Alcalde

修复“releaseJob()的不正确使用,但jobId”Flink的createTmpFiles()调用数不匹配

apache-flink scala

1

Alejandro Alcalde · 技术社区 · 8 年前

当我在日志中运行flink应用程序时,我看到以下警告:

improper use of releaseJob() without a matching number of createTmpFiles() calls for jobId

FileCache.java . 但看不到在我的代码中我引起这个警告的地方。你知道我该去哪里吗?

1 回复 | 直到 8 年前

1

2

Chesnay Schepler 8 年前

这不是代码的问题,而是Flink的内部错误。你能提供给我们你的应用程序(或最低版本)复制的问题吗?

不用担心,日志消息很简单,不需要。看到了吗 https://issues.apache.org/jira/browse/FLINK-10283