Merge pull request #1701 from tapdata/fix-mergeNode-main

fix:merge node npe
tapdata · Jan 29, 2024 · 4f88f94 · 4f88f94
2 parents 2b4dc9f + 45c7c58
commit 4f88f94
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/.../src/main/java/io/tapdata/flow/engine/V2/node/hazelcast/processor/HazelcastMergeNode.java b/.../src/main/java/io/tapdata/flow/engine/V2/node/hazelcast/processor/HazelcastMergeNode.java
@@ -124,12 +124,6 @@ public class HazelcastMergeNode extends HazelcastProcessorBaseNode implements Me
 
 	public HazelcastMergeNode(DataProcessorContext dataProcessorContext) {
 		super(dataProcessorContext);
-		if (AppType.init().isCloud())
-			externalStorageDto = ExternalStorageUtil.getTargetNodeExternalStorage(
-					processorBaseContext.getNode(),
-					processorBaseContext.getEdges(),
-					clientMongoOperator,
-					processorBaseContext.getNodes());
 	}
 
 	private void selfCheckNode(Node node) {