From 8968cdd809a54ec82a206f04cf296ea15207cb7a Mon Sep 17 00:00:00 2001
From: Bill Bejeck <bbejeck@gmail.com>
Date: Tue, 10 Dec 2019 11:01:31 -0500
Subject: [PATCH] MINOR: Remove line with addAll since collection passed into
 constructor call. (#7807)

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Sophie Blee-Goldman <sophie@confluent.io>
---
 .../apache/kafka/streams/kstream/internals/AbstractStream.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java
index 736d68febf2..664e8c5a760 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java
@@ -87,7 +87,6 @@ public abstract class AbstractStream<K, V> {
 
     Set<String> ensureCopartitionWith(final Collection<? extends AbstractStream<K, ?>> otherStreams) {
         final Set<String> allSourceNodes = new HashSet<>(sourceNodes);
-        allSourceNodes.addAll(sourceNodes);
         for (final AbstractStream<K, ?> other: otherStreams) {
             allSourceNodes.addAll(other.sourceNodes);
         }