[jira] [Created] (FLINK-21370) flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent

[Shang Yuanchun (Jira)]

谢波 created FLINK-21370:
--------------------------

             Summary: flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent
                 Key: FLINK-21370
                 URL: https://issues.apache.org/jira/browse/FLINK-21370
             Project: Flink
          Issue Type: Bug
          Components: Connectors / JDBC
    Affects Versions: 1.12.1
            Reporter: 谢波


When i test jdbc sink with kafka src, the data is not sink to db, and then i find out JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent.

JDBCExecutionOptions

public static final int DEFAULT_MAX_RETRY_TIMES = 3;
private static final int DEFAULT_INTERVAL_MILLIS = 0;
public static final int DEFAULT_SIZE = 5000;

 

JDBCDynamicTableFactory

 


// write config options
private static final ConfigOption<Integer> SINK_BUFFER_FLUSH_MAX_ROWS =
 ConfigOptions.key("sink.buffer-flush.max-rows")
 .intType()
 .defaultValue(100)
 .withDescription(
 "the flush max size (includes all append, upsert and delete records), over this number"
 + " of records, will flush data. The default value is 100.");


private static final ConfigOption<Duration> SINK_BUFFER_FLUSH_INTERVAL =
 ConfigOptions.key("sink.buffer-flush.interval")
 .durationType()
 .defaultValue(Duration.ofSeconds(1))
 .withDescription(
 "the flush interval mills, over this time, asynchronous threads will flush data. The "
 + "default value is 1s.");


private static final ConfigOption<Integer> SINK_MAX_RETRIES =
 ConfigOptions.key("sink.max-retries")
 .intType()
 .defaultValue(3)
 .withDescription("the max retry times if writing records to database failed.");



--
This message was sent by Atlassian Jira
(v8.3.4#803005)