in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java [501:523]
public static void validateSink(ReadableConfig config, TableSchema tableSchema) {
int fieldNum = tableSchema.getFieldCount();
if (fieldNum <= 0) {
throw new RuntimeException("invalid fieldNum, get " + fieldNum);
}
validateRequiredConfigOptions(config);
validateStringConfigOption(config, ADBSSHOST);
validateIntegerConfigOption(config, ADBSSPORT);
validateIntegerConfigOption(config, RETRY_WAIT_TIME);
validateIntegerConfigOption(config, BATCH_SIZE);
validateIntegerConfigOption(config, BATCH_WRITE_TIMEOUT_MS);
validateIntegerConfigOption(config, MAX_RETRY_TIMES);
validateIntegerConfigOption(config, CONNECTION_MAX_ACTIVE);
validateStringEnumConfigOption(config, CONFLICT_MODE, ConflictMode.stringList());
validateIntegerEnumConfigOption(config, USE_COPY, ZeroOrOneEnum.integerList());
validateStringConfigOption(config, TARGET_SCHEMA);
validateStringEnumConfigOption(config, EXCEPTION_MODE, ExceptionMode.stringList());
validateIntegerEnumConfigOption(config, RESERVEMS, ZeroOrOneEnum.integerList());
validateIntegerEnumConfigOption(config, CASE_SENSITIVE, ZeroOrOneEnum.integerList());
validateIntegerEnumConfigOption(config, WRITE_MODE, WriteMode.integerList());
validateStringConfigOption(config, DELIMITER);
validateIntegerEnumConfigOption(config, VERBOSE, ZeroOrOneEnum.integerList());
}