We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b0f2cb9 commit af1e50aCopy full SHA for af1e50a
2 files changed
.gitignore
@@ -15,4 +15,4 @@ lib/
15
bin/nohup.out
16
.DS_Store
17
bin/sideSql.txt
18
-localTest
+localTest/
core/src/main/java/com/dtstack/flink/sql/exec/ExecuteProcessHelper.java
@@ -377,7 +377,7 @@ public static StreamTableEnvironment getStreamTableEnv(StreamExecutionEnvironmen
377
private static void timeZoneCheck(String timeZone) {
378
ArrayList<String> zones = Lists.newArrayList(TimeZone.getAvailableIDs());
379
if (!zones.contains(timeZone)){
380
- throw new IllegalArgumentException(" timezone is Incorrect!");
+ throw new IllegalArgumentException(String.format(" timezone of %s is Incorrect!", timeZone));
381
}
382
383
0 commit comments