in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/DateUtil.java [31:46]
private static FastDateFormat getDateFormat(String timeZone, String format) {
String key;
if (null != timeZone && !timeZone.isEmpty()) {
key = timeZone + format;
} else {
key = String.valueOf(format);
}
if (sdfCache.containsKey(key)) {
return (FastDateFormat) sdfCache.get(key);
} else {
FastDateFormat sdf = FastDateFormat.getInstance(format, TimeZone.getTimeZone(timeZone));
sdfCache.put(key, sdf);
return sdf;
}
}