Skip to content

Commit 368c4c1

Browse files
committed
Ignore abandoned nodes in the test since we just need to replace the transforms.
1 parent 3e51cd8 commit 368c4c1

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaReadWithRedistributeOverrideTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,5 +128,6 @@ public void leaveCompositeTransform(Node node) {
128128
}
129129
};
130130
p.traverseTopologically(visitor);
131+
p.enableAbandonedNodeEnforcement(false);
131132
}
132133
}

0 commit comments

Comments
 (0)