Problem with passing arguments to Flink Web Submission Client

2015-12-20 Thread Filip Łęczycki
Hi all, I would like get the pretty printed execution plan of my job, in order to achieve that I uploaded my jar to Flink Web Submission Client and tried to run it. However when I provide arguments for my app I receive following error: An unexpected error occurred: Unrecognized option: -f org.apa

Re: Problem with passing arguments to Flink Web Submission Client

2015-12-20 Thread Matthias J. Sax
That is a bug. Can you open a JIRA for it? You can work around by not prefixing your flag with "-" -Matthias On 12/20/2015 12:59 PM, Filip Łęczycki wrote: > Hi all, > > I would like get the pretty printed execution plan of my job, in order > to achieve that I uploaded my jar to Flink Web Submis

Re: Problem with passing arguments to Flink Web Submission Client

2015-12-20 Thread Matthias J. Sax
The bug is actually in the CLI (it's not a WebClient related issue) if you run > bin/flink myJarFile.jar -f flink -i -m 1 it also returns > Unrecognized option: -f -Matthias On 12/20/2015 09:37 PM, Matthias J. Sax wrote: > That is a bug. Can you open a JIRA for it? > > You can work around

RE: Serialisation problem

2015-12-20 Thread Abdulrahman kaitoua
I still have the same problem even when i extended GValue with comparable. I think that the problem might be in the fact that Array[GValue] are not compatible and not the GValues but i do not know how to fix it in flink, may be some implicit ordering would work (and why the this field, Array[GVa