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
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
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
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
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: