Flink sql中设置了时区为上海,但是时间还是少了8个小时怎么办?
tEnv.getConfig().setLocalTimeZone(ZoneId.of("Asia/Shanghai"));
sql的结构如下:
CREATE TABLE tmp_orders( order_number BIGINT, price DECIMAL(32,2), buyer ROW<first_name STRING, last_name STRING>, order_time TIMESTAMP(3)) WITH ( 'connector' = 'datagen', 'rows-per-second' = '1', 'number-of-rows' = '50' );
结果在查询的时候,发现时间少了8个小时,如下图:
需要怎么办?