That seems incorrect. Please file a JIRA and provide an example + data that shows the error using the DirectRunner.
On Tue, Dec 12, 2017 at 2:51 AM, Sushil Ks <[email protected]> wrote: > Hi, > I am running a fixed window with GroupByKey on FlinkRunner and > have noticed that any exception and restart before the GroupByKey operation > the Kafka consumer is replaying the data from the particular offset, > however, post that any exception occurs and the pipeline restart the Kafka > is consuming from the latest offset. Is this expected? > > Regards, > Sushil Ks >
