回复：回复：Changing timeout for cancel command

2017-04-14 Thread Zhijiang(wangzhijiang999)
for ack in hdfs.  cheers,zhijiang--发件人：Jürgen Thomann <juergen.thom...@innogames.com>发送时间：2017年4月13日(星期四) 15:32收件人：user <user@flink.apache.org>主　题：Re: 回复：Changing timeout for cancel command Hi zhijiang,

Re: 回复：Changing timeout for cancel command

2017-04-13 Thread Jürgen Thomann
en 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

回复：Changing timeout for cancel command

2017-04-12 Thread Zhijiang(wangzhijiang999)
ames.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 

Changing timeout for cancel command

2017-04-12 Thread Jürgen Thomann
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