Thanks very much for the pointers Vinay. That helps ☺
-Raja.
From: vinay patil <vinay18.pa...@gmail.com>
Date: Monday, August 7, 2017 at 1:56 AM
To: "user@flink.apache.org" <user@flink.apache.org>
Subject: Re: [EXTERNAL] Re: Help required - "BucketingSink" usa
;http:///user/SendEmail.jtp?type=node=14716=1>" <[hidden email]
> <http:///user/SendEmail.jtp?type=node=14716=2>>
> *Subject: *[EXTERNAL] Re: Help required - "BucketingSink" usage to write
> HDFS Files
>
>
>
> Hi Raja,
>
> Have you enabled check
/Test/part-0-1.pending
Regards,
Raja.
From: vinay patil <vinay18.pa...@gmail.com>
Date: Sunday, August 6, 2017 at 10:40 PM
To: "user@flink.apache.org" <user@flink.apache.org>
Subject: [EXTERNAL] Re: Help required - "BucketingSink" usage to write HDFS
Files
Hi Raja,
>
> Raja.
>
>
> --
> If you reply to this email, your message will be added to the discussion
> below:
> http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/Help-required-BucketingSink-usage-to-write-
> HDFS-Files-tp14714.
Hi,
I am working on a poc to write to hdfs files using BucketingSink class. Even
thought I am the data is being writing to hdfs files, but the files are lying
with “.pending” on hdfs.
Below is the code I am using. Can someone pls help me identify the issue and
help me fix this ?
