Hi Colleagues,I am basically running the code in example WindowedWordCount.The only difference is that I dont TextIO but get records via KakkaIO.Everything else the same. I get the following exception.Appreciate your suggestions to fix it..Cheers
Caused by: java.lang.IllegalArgumentException: Cannot output with timestamp 2016-08-04T02:23:21.137Z. Output timestamps must be no earlier than the timestamp of the current input (2016-08-04T02:23:22.896Z) minus the allowed skew (0 milliseconds). See the DoFn#getAllowedTimestmapSkew() Javadoc for details on changing the allowed skew. at org.apache.beam.runners.flink.translation.wrappers.streaming.FlinkAbstractParDoWrapper.checkTimestamp(FlinkAbstractParDoWrapper.java:201)
