snuyanzin commented on code in PR #4388:
URL: https://github.com/apache/calcite/pull/4388#discussion_r2114666513
##########
core/src/test/java/org/apache/calcite/test/SqlValidatorTest.java:
##########
@@ -8782,6 +8782,12 @@ void testGroupExpressionEquivalenceParams() {
sql("select stream * from orders left join products_temporal\n"
+ "for system_time as of CURRENT_TIMESTAMP\n"
+ "on orders.productid = products_temporal.productid").ok();
+
+ // verify left join of CTEs
Review Comment:
made it failing and overridable
>but is there even a definition of what it means to apply SYSTEM_TIME to the
result of a query?
in Flink result of query in streaming mode is changelog. Changelog has
timestamp, in this case we could jump at some position in the middle with
SYSTEM_TIME
--
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]
