FLINK SQL：row.getFieldsAs 返回 LocalDateTime 而不是时间戳？

Question

Flink：1.13.2

我有一个 StreamTableEnvironment tableEnv 从 KafkaSource 读取流数据。 从这个 tableEnv 中，我过滤数据并将其转换回 DataStream。

DataStream<Row> myStreamData = env.fromSource(source, WatermarkStrategy.noWatermarks(),"mySource");

tableEnv.createTemporaryView("myTable", myStreamData);
Table mytable = tableEnv.sqlQuery("select source_timestamp, id from mytable");
DataStream<Row> filteredDatastream = tableEnv.toChangelogStream(myTable);

source_timestamp 的类型是 java.sql.Timestamp，id 是 String。

后来，我从 filteredDatastream 访问数据，并遇到 row.getFieldsAs(source_timestamp) 返回 LocalDateTime 而不是时间戳的问题。

System.out.println(filteredDatastream.getTransformation().getOutputType());
/* 
Out: (
  `source_timestamp` TIMESTAMP(9), // Is a TIMESTAMP 
  `trip_id` STRING
)
*/

filteredDatastream.map(
        row -> {
            System.out.println(row.getFieldAs("source_timestamp").getClass());
            /*
            Out: class java.time.LocalDateTime // (not java.sql.Timestamp)
            */
            return row;
        }
);

如何让 row.getFieldAs("source_timestamp") 成为 java.sql.Timestamp 而不是 java.time.LocalDateTime 而无需之后投射？知道 java.sql.Timestamp 似乎是由 flink 处理的 数据类型提取。