'Flink job is interrupted after 10 minutes

I have a flink job with a global window and custom process.
The Process is failed after ~10 minutes on the next error:

java.io.InterruptedIOException

This is my job:

SingleOutputStreamOperator<CustomEntry> result = stream
                .keyBy(r -> r.getId())
                .window(GlobalWindows.create())
                .trigger(new CustomTriggeringFunction())
                .process(new CustomProcessingFunction());

The CustomProcessingFunction is run for a long time (more then 10 minutes), but after 10 minutes, the process is stoped and failed on InterruptedIOException

Is it possible t increase the timeout of flink job?



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source