Re: Writing in flink clusters

2016-07-14 Thread Robert Metzger
I agree with Chesnay that we should report the file name. Can you create a [hotfix] PR for that? On Wed, Jul 13, 2016 at 3:46 PM, Chesnay Schepler wrote: > Hello, > > Is that the complete error message? I'm a bit surprised it does not > explicitly name any file name. If it really doesn't we shou

Re: Writing in flink clusters

2016-07-13 Thread Chesnay Schepler
Hello, Is that the complete error message? I'm a bit surprised it does not explicitly name any file name. If it really doesn't we should change that. Regards, Chesnay Schepler On 13.07.2016 15:35, Alexis Gendronneau wrote: Hi Roy, Have you looked on the nodes in charge of sink tasks ? You s

Re: Writing in flink clusters

2016-07-13 Thread Debaditya Roy
Thanks . Will check. :-) On Wed, Jul 13, 2016 at 3:35 PM, Alexis Gendronneau wrote: > Hi Roy, > > Have you looked on the nodes in charge of sink tasks ? You should be able > to find them on flink web interface by clicking on the sink taks. If you > get the OVERWRITE error, your output is certain

Re: Writing in flink clusters

2016-07-13 Thread Alexis Gendronneau
Hi Roy, Have you looked on the nodes in charge of sink tasks ? You should be able to find them on flink web interface by clicking on the sink taks. If you get the OVERWRITE error, your output is certainly somewhere. By the way, when using distributed mode it is easier to use an output like HDFS. T

Writing in flink clusters

2016-07-13 Thread Debaditya Roy
Hello users, I have written and executed a flink program in a cluster. The program was supposed to write to some text file as a sink, however I cannot find the text files in the target directory of the cluster nodes, but when I reexecute the program second time, it gives me the predictable error: