pnowojski commented on code in PR #26051:
URL: https://github.com/apache/flink/pull/26051#discussion_r1946730432
##########
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/DeduplicateTest.scala:
##########
@@ -139,14 +139,17 @@ class DeduplicateTest extends TableTestBase {
@Test
def testSimpleFirstRowOnRowtime(): Unit = {
+ // indirectly check output insert only via used SUM or SUM_RETRACT
aggregation function
Review Comment:
The output type of the actual resource is then slightly different, whole
explain instead of 3 individual resources for sql, ast and optimized exec plan,
but I guess that doesn't matter. (please check the fixup to the expected output)
--
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]
