Hi,
When using a BoundedOutOfOrdernessTimestampExtractor, the trigger is not
firing. However, the trigger fires when using custom timestamp extractor
with similar watermark.
Sample code below:
1.Assigner as anonymous class which works fine
AssignerWithPeriodicWatermarks<Tuple2<Rule, T>> assigner = new
AssignerWithPeriodicWatermarks<Tuple2<Rule, T>>() {
@Override
public long extractTimestamp(Tuple2<Rule, T> element, long
previousElementTimestamp) {
return System.currentTimeMillis();
}
@Override
public final Watermark getCurrentWatermark() {
// this guarantees that the watermark never goes backwards.
return new Watermark(System.currentTimeMillis()-100);
}
};
2.BoundedOutOfOrdernessTimestampExtractor assigner which doesn't work
AssignerWithPeriodicWatermarks<Tuple2<Rule, T>> assigner = new
BoundedOutOfOrdernessTimestampExtractor<Tuple2<Rule,
T>>(Time.milliseconds(100)) {
@Override
public long extractTimestamp(Tuple2<Rule, T> element) {
return System.currentTimeMillis();
}
};
Do you see any difference in the approaches?
- Jayant
