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

["谢波 (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-21370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283953#comment-17283953 ] 

谢波 commented on FLINK-21370:
----------------------------

[~jark] Can you assign this problem to me?

> 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: 谢波
>            Priority: Major
>
> 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)