snuyanzin commented on code in PR #27764:
URL: https://github.com/apache/flink/pull/27764#discussion_r2966257851
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java:
##########
@@ -313,16 +321,19 @@ public Iterator<RowData> iterator() {
private static final class InputSideHasNoUniqueKey implements
MultiJoinStateView {
private final MapState<RowData, Integer> recordState;
private RowDataSerializer joinKeySerializer; // Null if joinKeyType is
null
+ private RowDataSerializer stateKeySerializer; // Null if joinKeyType
is null
private int joinKeyFieldCount; // 0 if joinKeyType is null
private final int recordFieldCount;
@Nullable private final RowType joinKeyType; // Store to check for null
+ private final boolean prohibitReuseRowData;
private InputSideHasNoUniqueKey(
RuntimeContext ctx,
final String stateName,
@Nullable final RowType joinKeyType, // Can be null
final RowType recordType,
- final StateTtlConfig ttlConfig) {
+ final StateTtlConfig ttlConfig,
+ boolean prohibitReuseRowData) {
Review Comment:
```suggestion
final boolean prohibitReuseRowData) {
```
?
--
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]
