【opt】add timezone check

Author: FlechazoW

core/src/main/java/com/dtstack/flink/sql/exec/ExecuteProcessHelper.java

@@ -71,11 +71,7 @@
 import java.net.URLClassLoader;
 import java.net.URLDecoder;
 import java.time.ZoneId;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Set;
+import java.util.*;
 
 /**
  *  任务执行时的流程方法
@@ -358,11 +354,19 @@ private static StreamTableEnvironment getStreamTableEnv(StreamExecutionEnvironme
 
         TableConfig tableConfig = new TableConfig();
 
+        timeZoneCheck(confProperties.getProperty(TIME_ZONE));
+
         tableConfig.setLocalTimeZone(ZoneId.of(confProperties.getProperty(TIME_ZONE)));
 
         StreamTableEnvironment tableEnv = StreamTableEnvironmentImpl.create(env, settings, tableConfig);
         StreamEnvConfigManager.streamTableEnvironmentStateTTLConfig(tableEnv, confProperties);
         return tableEnv;
     }
 
+    private static void timeZoneCheck(String timeZone) {
+        ArrayList<String> zones = Lists.newArrayList(TimeZone.getAvailableIDs());
+        if (!zones.contains(timeZone)){
+            throw new IllegalArgumentException(" timezone is Incorrect!");
+        }
+    }
 }