clear query| facets| time Search criteria: .   Results from 1 to 8 from 8 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Adding a part suffix setter to the BucketingSink - Flink - [mail # dev]
...Sorry, I meant "I don't see a way of doing this apart from setting a part file *suffix* with the required file extension. "On 2018/03/29 14:55:43, [EMAIL PROTECTED]  wrote: > Current...
   Author: lrao@... , 2018-03-29, 14:59
[expand - 1 more] - Compressing files with the Bucketing Sink - Flink - [mail # dev]
...Thanks a lot for the suggestion Till!I ended up using your suggestion of extending StreamWriterBase and wrapping the FSDataOutputStream with GZIPOutputStream.On 2018/03/28 09:44:26, Till Roh...
   Author: lrao@... , 2018-03-29, 14:50
[expand - 1 more] - Correct way to reference Hadoop dependencies in Flink 1.4.0 - Flink - [mail # dev]
...Hi,I am running this on a Hadoop-free cluster (i.e. no YARN etc.). I have the following dependencies packaged in my user application JAR:aws-java-sdk 1.7.4flink-hadoop-fs 1.4.0flink-shaded-h...
   Author: lrao@... , 2018-03-15, 01:26
[expand - 1 more] - Using the BucketingSink with Flink 1.4.0 - Flink - [mail # dev]
...Thank you for your responses Stephan and Piotrek!It's great to know that the hadoop-free Bucketing Sink might be available as early as 1.5.x!In the meantime, I have been trying workarounds b...
   Author: lrao@... , 2018-03-10, 01:03