麻烦问一下Flinkwatermark信息丢失了。怎么办？

bid表rowtime字段选错了，没选原表中定义watermark那个字段 ，此回答整理自钉群“【①群】Apache Flink China社区”

这个问题可能是由于在创建视图时，FlinkSQL没有正确地处理Watermark信息。你可以尝试以下方法来解决这个问题：

1. 在创建视图时，确保将Watermark信息添加到视图中。你可以使用WATERMARK FOR子句来实现这一点。例如：

CREATE VIEW your_view_name AS
SELECT
  your_columns,
  WATERMARK FOR your_timestamp_column AS your_watermark_expression
FROM your_source_table;

1. 在执行window查询时，确保你的窗口函数是基于时间属性列的。例如，如果你的时间属性列是your_timestamp_column，那么你可以使用如下的窗口查询：

SELECT
  your_aggregate_function(your_column) OVER (
    PARTITION BY your_partition_column
    ORDER BY your_timestamp_column
    RANGE BETWEEN your_range_interval AND your_slide_interval
  )
FROM your_view_name;

1. 如果问题仍然存在，你可以尝试在创建视图时显式地添加Watermark信息，然后在窗口查询中使用这个视图。例如：

CREATE TABLE your_view_name (
  your_columns,
  WATERMARK FOR your_timestamp_column AS your_watermark_expression
) WITH (
  'connector' = '...', -- 使用与源表相同的连接器
  'format' = '...', -- 使用与源表相同的格式
  ...
);

INSERT INTO your_view_name
SELECT * FROM your_source_table;

SELECT
  your_aggregate_function(your_column) OVER (
    PARTITION BY your_partition_column
    ORDER BY your_timestamp_column
    RANGE BETWEEN your_range_interval AND your_slide_interval
  )
FROM your_view_name;

希望这些建议能帮助你解决问题。