VictorvandenHoven commented on code in PR #14426: URL: https://github.com/apache/kafka/pull/14426#discussion_r1399179893
########## streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java: ########## @@ -60,24 +61,21 @@ class KStreamKStreamJoin<K, V1, V2, VOut> implements ProcessorSupplier<K, V1, K, private final TimeTrackerSupplier sharedTimeTrackerSupplier; - KStreamKStreamJoin(final boolean isLeftSide, - final String otherWindowName, - final JoinWindowsInternal windows, - final ValueJoinerWithKey<? super K, ? super V1, ? super V2, ? extends VOut> joiner, - final boolean outer, - final Optional<String> outerJoinWindowName, - final TimeTrackerSupplier sharedTimeTrackerSupplier) { + KStreamKStreamJoin(final boolean isLeftSide, final String otherWindowName, final JoinWindowsInternal windows, + final ValueJoinerWithKey<? super K, ? super V1, ? super V2, ? extends VOut> joiner, final boolean outer, + final Optional<String> outerJoinWindowName, final TimeTrackerSupplier sharedTimeTrackerSupplier) { Review Comment: changes reverted ########## streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java: ########## @@ -94,7 +92,8 @@ public Processor<K, V1, K, VOut> get() { private class KStreamKStreamJoinProcessor extends ContextualProcessor<K, V1, K, VOut> { private WindowStore<K, V2> otherWindowStore; private Sensor droppedRecordsSensor; - private Optional<KeyValueStore<TimestampedKeyAndJoinSide<K>, LeftOrRightValue<V1, V2>>> outerJoinStore = Optional.empty(); + private Optional<KeyValueStore<TimestampedKeyAndJoinSide<K>, LeftOrRightValue<V1, V2>>> outerJoinStore = Optional + .empty(); Review Comment: changes reverted -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org