Au-Miner commented on code in PR #28671:
URL: https://github.com/apache/flink/pull/28671#discussion_r3540998120
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/bundle/InputSideHasUniqueKeyBundle.java:
##########
@@ -33,8 +34,23 @@
/** For the case that input has uniqueKey which is not contained by joinKey. */
public class InputSideHasUniqueKeyBundle extends BufferBundle<Map<RowData,
List<RowData>>> {
Review Comment:
Now supports
`testInnerJoinWithNoUniqueKeyInsertThenUpdateAfterFoldKeepsUpdateAfter` and
`testInnerJoinWithNoUniqueKeyUpdateBeforeThenUpdateAfterKeepsUpdateAfter` for
detecting that noUniqueKey does not incorrectly convert to +I
--
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]
