Hi Sathi,
which version of Flink are you using? Since Flink 1.2 the RollingSink is
deprecated. It is now recommend to use the BucketingSink. Maybe this
problem is resolved with the newer sink.
Cheers,
Till
On Thu, Mar 2, 2017 at 9:44 AM, Sathi Chowdhury <
sathi.chowdh...@elliemae.com> wrote:
I get the NPE from the below code
I am running this from my mac in a local flink cluster.
RollingSink s3Sink = new RollingSink("s3://sc-sink1/");
s3Sink.setBucketer(new DateTimeBucketer("-MM-dd--HHmm"));
s3Sink.setWriter(new StringWriter());
s3Sink.setBatchSize(200);
s3Sink.setPendingPrefix(
