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)

Reply via email to