[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Question about JVM exit caused by timeout exception with the asynchronous IO of flink 1.4.2


You can increase a timeout, that’s one way to tackle it. 

In Flink 1.6.0 there will be possibility to override default Flink’s behaviour regarding handling timeouts:
https://issues.apache.org/jira/browse/FLINK-7789 to handle them, instead of out right failing.

Also if you can not wait for the new release, you always could copy AsyncWaitOperator with AsyncFunction into your code base and apply the changes from the above mentioned ticket (https://github.com/apache/flink/pull/6091/files)


On 6 Jun 2018, at 10:39, 陈卓 <zhuochen6@xxxxxxxxxxxx> wrote:

The asynchronous IO of flink 1.4.2 will throw timeout exception when the timeout setting is one second and the invoke time setting is greater than twenty seconds. Unfortunately the timeout exception cannot be captured, which leads to abnormal exit of the process. So my question is how to deal with this situation to keep the jvm executing.
the exception info:
code as follows
zhuo chen