开启水印后，Flink中的记录无法显示。

问题通常是由于水印设置不正确导致的。下面是

1. 确保数据源已经设置了正确的时间戳和水印

例如，对于Kafka消息数据源，需要设置TimestampAssigner和WatermarkStrategy：

SingleOutputStreamOperator<SomeEvent> stream = env.addSource(new FlinkKafkaConsumer<>("topic", new SomeEventSchema(), props)) .assignTimestampsAndWatermarks(WatermarkStrategy.<SomeEvent>forBoundedOutOfOrderness(Duration.ofSeconds(10)).withTimestampAssigner(new SomeEventTimestampAssigner()));

2. 检查流中的所有窗口操作（例如.keyBy().window().reduce()）是否使用了正确的时间戳和水印

例如：

SingleOutputStreamOperator<SomeAggregateResult> resultStream = stream.keyBy(SomeEvent::getKey) .window(TumblingEventTimeWindows.of(Time.seconds(10))) .reduce(new SomeReducer());

3. 使用WatermarkProcessorFunction函数手动处理水印

某些情况下，需要手动处理水印。这种情况可以使用WatermarkProcessorFunction函数来创建处理水印的流。

例如：

DataStream<SomeEvent> stream = ...;

DataStream<SomeEvent> watermarkedStream = stream.process(new WatermarkProcessorFunction<>(new SomeEventTimestampAssigner())); watermarkedStream.print();

其中，SomeEventTimestampAssigner是实现了TimestampAssigner接口的类。

通过以上方法，可以确保在Flink中开启水印后能够正确地显示记录。