Исправить «неправильное использование releaseJob () без соответствующего количества вызовов createTmpFiles () для jobId» Flink - PullRequest
0 голосов
/ 02 сентября 2018

Когда я запускаю приложение flink в журналах, я вижу это предупреждение:

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

Я искал в исходном коде flink и нашел эту строку в FileCache.java . Но не вижу, где в моем коде я вызываю это предупреждение. Любые идеи, где я должен смотреть?

1 Ответ

0 голосов
/ 04 сентября 2018

Это не проблема с вашим кодом, а внутренняя ошибка Flink. Можете ли вы предоставить нам свое приложение (или минимальную версию), которое воспроизводит проблему?

Не о чем беспокоиться, сообщение в журнале просто не нужно. Смотри https://issues.apache.org/jira/browse/FLINK-10283

...