When I run my flink application in the Logs I am seeing this warning:
improper use of releaseJob() without a matching number of createTmpFiles() calls for jobId
I've search in flink's source code and found that line in FileCache.java. But can not see where in my code I am causing this warning to raise. Any ideas where I should look at?
This is not an issue with your code but a Flink-internal bug. Can you provide us your application (or a minimal version) that reproduces the problem?
Nothing to worry about, the log message is simple unnecessary. See https://issues.apache.org/jira/browse/FLINK-10283