FlinkSQL中如何正确配置时区？

-- 创建表时指定时区为UTC
CREATE TABLE events (
  event_id STRING,
  event_time TIMESTAMP(3),
  WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
) WITH (
  'connector' = 'kafka',
  'topics' = 'events_topic',
  'timezone' = 'UTC'  -- 显式设置时区
);

# flink-conf.yaml
execution.timezone: Asia/Shanghai

// Java代码中设置
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.getConfig().setLocalTimeZone(ZoneId.of("Asia/Shanghai"));