becketqin commented on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734530063
Hey @rmetzger , can you check if you are using the latest update of the PR? Some earlier commit I had for this PR had a problem of using `Integer.parseInt()` to parse a long value, which causes the `SplitEnumerator` to throw exception immediately. And it looks that the JM was not handling that correctly to fail the job. I have fired a ticket [FLINK-20382](https://issues.apache.org/jira/browse/FLINK-20382) for this. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
