在您的情况下，最好使用提供的 TimeStampAssigners 看这里。
所以我推荐的是这样的：

DataStream<MyEvent> stream = ...

DataStream<MyEvent> withTimestampsAndWatermarks =
stream.assignTimestampsAndWatermarks(new AscendingTimestampExtractor<MyEvent>() {

    @Override
    public long extractAscendingTimestamp(MyEvent element) {
        return element.getCreationTime();
    }
});

同时也要记住设置正确 TimestampCharacteristic :

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);