Tartarus0zm commented on code in PR #2448:
URL: https://github.com/apache/auron/pull/2448#discussion_r3733069765
##########
auron-flink-extension/auron-flink-planner/src/test/java/org/apache/auron/flink/table/runtime/AuronFlinkCalcITCase.java:
##########
@@ -221,6 +222,19 @@ public void testFilterOrComparison() {
assertThat(rows).isEqualTo(Arrays.asList(Row.of(1), Row.of(2)));
}
+ /** UNIX_TIMESTAMP over the per-row {@code ts} string converts to the
native ext function and
+ * yields the epoch seconds. The session timezone is set to Asia/Shanghai
to make the result
+ * deterministic and to exercise timezone propagation into the native
plan. */
+ @Test
+ public void testUnixTimestamp() {
+
tableEnvironment.getConfig().setLocalTimeZone(ZoneId.of("Asia/Shanghai"));
Review Comment:
The config `table.local-time-zone` supports multiple formats, such as
`GMT-08:00`, I'd suggest adding more test cases for this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
