Flink watermark设置

Scala：

        .map(x=> JSON.parseObject(x))
        .assignTimestampsAndWatermarks(
          WatermarkStrategy.forBoundedOutOfOrderness[JSONObject](Duration.ofSeconds(3))
            .withTimestampAssigner(new SerializableTimestampAssigner[JSONObject] {
              override def extractTimestamp(element: JSONObject, recordTimestamp: Long): Long = element.getLong("ts")
            })
        )

2021-12-29
2021-09-11
2021-09-23
2022-12-23
2022-12-23
2021-05-09
2021-07-26