Re: Flink 1.6 Support

2018-10-31 Thread Jins George
planning to release both versions: > > https://issues.apache.org/jira/browse/BEAM-5419 > > Thanks, > Max > > On 31.10.18 06:28, Jins George wrote: >> Thank you Thomas.  Idea of providing different build targets  for >> runners is great, as it enables users to pick from a l

Re: Flink 1.6 Support

2018-10-30 Thread Jins George
Thank you Thomas. Idea of providing different build targets for runners is great, as it enables users to pick from a list of runner versions. Thanks Jins George On 10/30/18 12:36 PM, Thomas Weise wrote: There has not been any decision to move to 1.6.x for the next release yet. There has

Re: Travis-CI Build failures

2017-04-05 Thread Jins George
lowup with you further if necessary. Thanks! On Wed, Apr 5, 2017 at 9:47 AM Jins George wrote: Hello Team, I am a new contributor and working on a ticket BEAM-1812. After making code changes and pushing to my forked repo, I noticed that the Travis-CI build fails with a reason 2017-04-05T00:36:0

Travis-CI Build failures

2017-04-04 Thread Jins George
Can I proceed with the PR ignoring this build failure ? Thanks, Jins George

Re: Kafka Offset handling for Restart/failure scenarios.

2017-03-24 Thread Jins George
Currently /org.apache.beam.runners.flink.FlinkPipelineOptions/ does not have a way to configure externalized checkpoints. Is that something in the road map for FlinkRunner? Thanks, Jins George On 03/23/2017 10:27 AM, Aljoscha Krettek wrote: For this you would use externalised checkpoints

Re: Kafka Offset handling for Restart/failure scenarios.

2017-03-22 Thread Jins George
configured with HDFS. Thanks, Jins George On 03/22/2017 03:23 AM, Aljoscha Krettek wrote: As I mentioned before, when running a Flink Job and simply cancelling it all state about that job is discarded (with some exceptions, such as externalised checkpoints). If you want the state of a Job to