Re: KafkaIO reading from latest offset when pipeline fails on FlinkRunner

Hi Sushil, That is expected behavior. If you don't have any saved checkpoint, the pipeline would start from scratch. It does not have any connection to previous run. On Thu, Feb 1, 2018 at 1:29 AM, Sushil Ks wrote: > Hi, >Apologies for delay in my reply, > > @Raghu

Re: Slack invitation

Invitation sent. On Mon, Feb 5, 2018 at 1:43 PM Jose Ignacio Honrado Benítez < jihonra...@gmail.com> wrote: > Hello, > > I would like to get invited to the Apache Beam Slack. > > Thanks in advance! > > Cheers >

Slack invitation

Hello, I would like to get invited to the Apache Beam Slack. Thanks in advance! Cheers