当我在日志中运行flink应用程序时,我看到以下警告:
improper use of releaseJob() without a matching number of createTmpFiles() calls for jobId
我搜索了flink的源代码,在filecache.java中找到了这一行。但看不到在我的代码中我引起这个警告的地方。你知道我该去哪里吗?
当我在日志中运行flink应用程序时,我看到以下警告:
improper use of releaseJob() without a matching number of createTmpFiles() calls for jobId
我搜索了flink的源代码,在filecache.java中找到了这一行。但看不到在我的代码中我引起这个警告的地方。你知道我该去哪里吗?
1条答案
按热度按时间9fkzdhlc1#
这不是代码的问题,而是flink的内部错误。你能提供给我们你的应用程序(或最低版本)复制的问题吗?
不用担心,日志消息很简单,不需要。看到了吗https://issues.apache.org/jira/browse/flink-10283