snuyanzin commented on code in PR #29697:
URL: https://github.com/apache/flink/pull/29697#discussion_r4436566431
##########
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/JoinITCase.scala:
##########
@@ -697,6 +697,74 @@ class JoinITCase(miniBatch: MiniBatchMode, state:
StateBackendMode, enableAsyncS
assertThat(sink.getRetractResults.sorted).isEqualTo(expected.sorted)
}
+ /**
+ * user_regions is unique on its join columns (user_id, region), but orders
is joined on user_id
+ * only, so an order matches the user's row of every region and its key is
not unique in the
+ * output. Deleting one region must keep the order's row for the other
region.
+ */
+ @TestTemplate
+ def testMultiJoinKeyNotUniqueWhenJoinedOnFewerColumns(): Unit = {
Review Comment:
can we avoid this old fashion approach and use semantic or store/restore
tests instead?
--
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]
