Re: Upgrade to Flink 1.11 in EMR 5.31 Command line interface

2020-10-14 Thread Piotr Nowojski
I'm glad to hear that :) Best regards, Piotrek śr., 14 paź 2020 o 18:28 Vijayendra Yadav napisał(a): > Thank You Piotre. I moved *flink-s3-fs-hadoop* library to plugin. Now > it's good. > > > On Wed, Oct 14, 2020 at 6:23 AM Piotr Nowojski > wrote: > >> Hi, >> >> Are you sure you are loading

Re: Upgrade to Flink 1.11 in EMR 5.31 Command line interface

2020-10-14 Thread Vijayendra Yadav
Thank You Piotre. I moved *flink-s3-fs-hadoop* library to plugin. Now it's good. On Wed, Oct 14, 2020 at 6:23 AM Piotr Nowojski wrote: > Hi, > > Are you sure you are loading the filesystems correctly? Are you using the > plugin mechanism? [1] Since Flink 1.10 plugins can only be loaded in thi

Re: Upgrade to Flink 1.11 in EMR 5.31 Command line interface

2020-10-14 Thread Piotr Nowojski
Hi, Are you sure you are loading the filesystems correctly? Are you using the plugin mechanism? [1] Since Flink 1.10 plugins can only be loaded in this way [2], while there were some changes to plug some holes in Flink 1.11 [3]. Best, Piotrek [1] https://ci.apache.org/projects/flink/flink-docs-s

Upgrade to Flink 1.11 in EMR 5.31 Command line interface

2020-10-13 Thread Vijayendra Yadav
Hi Team, I have upgraded to Flink 1.11 (EMR 5.31) from Flink 1.10 (5.30.1). I am facing following Error while running *flink streaming *Job from command line. run command like:*/usr/lib/flink/bin/flink run* *What dependency I might be missing or conflicting ?*