TextIO windowing

DirectRunner (local): 
[Before Write] Element=data window=[2020-05-09T13:39:00.000Z..2020-05-09T13:40:00.000Z), timestamp=2020-05-09T13:39:59.999Z, timing=ON_TIME, index =0, isFirst =true, isLast=true  pane=PaneInfo{isFirst=true, isLast=true, timing=ON_TIME, index=0, onTimeIndex=0}
[After  Write] Element=file window=[2020-05-09T13:39:00.000Z..2020-05-09T13:40:00.000Z), timestamp=2020-05-09T13:39:59.999Z, timing=EARLY,   index =0, isFirst =true, isLast=false pane=PaneInfo{isFirst=true, timing=EARLY, index=0}                               

FlinkRunner (cluster): 
[Before Write] Element=data window=[2020-05-09T15:13:00.000Z..2020-05-09T15:14:00.000Z), timestamp=2020-05-09T15:13:59.999Z, timing=ON_TIME, index =0, isFirst =true, isLast=true  pane=PaneInfo{isFirst=true, isLast=true, timing=ON_TIME, index=0, onTimeIndex=0}
[After  Write] Element=file window=[2020-05-09T15:13:00.000Z..2020-05-09T15:14:00.000Z), timestamp=2020-05-09T15:13:59.999Z, timing=UNKNOWN, index =0, isFirst =true, isLast=true  pane=PaneInfo.NO_FIRING

SparkRunner (cluster): 
[Before Write] Element=data window=[2020-05-09T15:34:00.000Z..2020-05-09T15:35:00.000Z), timestamp=2020-05-09T15:34:59.999Z, timing=ON_TIME, index =0, isFirst =true, isLast=true  pane=PaneInfo{isFirst=true, isLast=true, timing=ON_TIME, index=0, onTimeIndex=0}
[After  Write] Element=file window=[2020-05-09T15:34:00.000Z..2020-05-09T15:35:00.000Z), timestamp=2020-05-09T15:34:59.999Z, timing=UNKNOWN, index =0, isFirst =true, isLast=true  pane=PaneInfo.NO_FIRING