set closure cleaner

Author: yanxi0227

core/src/main/java/com/dtstack/flink/sql/Main.java

@@ -321,6 +321,7 @@ private static StreamExecutionEnvironment getStreamExeEnv(Properties confPropert
                 StreamExecutionEnvironment.getExecutionEnvironment() :
                 new MyLocalStreamEnvironment();
 
+        env.getConfig().disableClosureCleaner();
         env.setParallelism(FlinkUtil.getEnvParallelism(confProperties));
         Configuration globalJobParameters = new Configuration();
         Method method = Configuration.class.getDeclaredMethod("setValueInternal", String.class, Object.class);