Hi Jürgen, You can set the timeout in the configuration by this key "akka.ask.timeout", and the current default value is 10 s. Hope it can help you.
cheers,zhijiang ------------------------------------------------------------------发件人：Jürgen Thomann <juergen.thom...@innogames.com>发送时间：2017年4月12日(星期三) 19:04收件人：user <user@flink.apache.org>主 题：Changing timeout for cancel command Hi, We currently get the following exception if we cancel a job which writes to Hadoop: ERROR org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink - Error while trying to hflushOrSync! java.io.InterruptedIOException: Interrupted while waiting for data to be acknowledged by pipeline This causes problem if we cancel a job with creating a savepoint and resubmitting the job because the file is sometimes at the end smaller than the file size specified in the valid-length file. Is there a way to increase the time out during cancel to give the flush a bit more time? We currently lose events if this happens. Best, Jürgen
