Flink中在source流中自定义timestamp和watermark

To work with Event Time, streaming programs need to set the time characteristic accordingly.ide 首先配置成，Event Timethis final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvir

>>阅读原文<<