flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [860:870]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
						else if (Timestamp.class.equals(colType)) {
							value = "'" + DateUtil.timeStamp2String((Timestamp)value, timeZone, reserveMs) + "'";
						} else if (Date.class.equals(colType)) {
							value = "'" + DateUtil.date2String((java.sql.Date)value, timeZone) + "'";
						} else if (Time.class.equals(colType)) {
							value = "'" + DateUtil.time2String((Time)value, timeZone) + "'";
						} else if (BigDecimal.class.equals(colType)) {
							value = Double.parseDouble("" + value);
						}
						else{
						    throw new IllegalArgumentException("invalid parm");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [940:950]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
					else if (Timestamp.class.equals(colType)) {
						value = "'" + DateUtil.timeStamp2String((Timestamp)value, timeZone, reserveMs) + "'";
					} else if (Date.class.equals(colType)) {
						value = "'" + DateUtil.date2String((java.sql.Date)value, timeZone) + "'";
					} else if (Time.class.equals(colType)) {
						value = "'" + DateUtil.time2String((Time)value, timeZone) + "'";
					} else if (BigDecimal.class.equals(colType)) {
						value = Double.parseDouble("" + value);
					}
					else{
						throw new IllegalArgumentException("invalid parm");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -