fix“在jobid”flink没有匹配的createtmpfiles()调用数的情况下不正确地使用releasejob()

pwuypxnk 于 2021-06-21 发布在 Flink

关注(0)|答案(1)|浏览(190)

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

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

我搜索了flink的源代码，在filecache.java中找到了这一行。但看不到在我的代码中我引起这个警告的地方。你知道我该去哪里吗？

1条答案

这不是代码的问题，而是flink的内部错误。你能提供给我们你的应用程序（或最低版本）复制的问题吗？
不用担心，日志消息很简单，不需要。看到了吗https://issues.apache.org/jira/browse/flink-10283