From cc6947ff0508a050ecae1b27b2f284913b9ee883 Mon Sep 17 00:00:00 2001
From: lifengchao <lifengchao@geedgenetworks.com>
Date: Mon, 29 Jul 2024 17:42:02 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E6=97=B6=E8=AE=BE=E7=BD=AEse?=
 =?UTF-8?q?tParallelism=E4=BB=A3=E7=A0=81=E5=88=A0=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/zdjizhi/topology/ApplicationProtocolTopology.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java b/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java
index 951703c..26111e0 100644
--- a/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java
+++ b/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java
@@ -51,7 +51,6 @@ public class ApplicationProtocolTopology {
         }
 
         final StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
-        environment.setParallelism(1);
 
         ParameterTool tool = ParameterTool.fromPropertiesFile(args[0]);
         final Configuration config = tool.getConfiguration();