[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460
]
EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:28 AM:
-------------------------------------------------------------
Hi [~CrynetLogistics] ，When I use jdbc sink, I found that there are several
parameters. I don't know if it can help you. I will provide you with reference.
{code:java}
JdbcExecutionOptions
.builder()
.withBatchSize(4000)
.withBatchIntervalMs(200)
.withMaxRetries(3)
.build()
{code}
was (Author: zsigner):
Hi [~CrynetLogistics] ，When I use jdbc sink, I found that there are several
parameters. I don't know if it can help you. I will provide you with reference.
{code:java}
JdbcExecutionOptions.builder() .withBatchSize(4000) .withBatchIntervalMs(200)
.withMaxRetries(3) .build()
{code}
> Initialise Async Sink maximum number of in flight messages to low number for
> rate limiting strategy
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-28027
> URL: https://issues.apache.org/jira/browse/FLINK-28027
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Common, Connectors / Kinesis
> Affects Versions: 1.15.0
> Reporter: Zichen Liu
> Priority: Minor
> Fix For: 1.16.0
>
>
> *Background*
> In the AsyncSinkWriter, we implement a rate limiting strategy.
> The initial value for the maximum number of in flight messages is set
> extremely high ({{{}maxBatchSize * maxInFlightRequests{}}}).
> However, in accordance with the AIMD strategy, the TCP implementation for
> congestion control has found a small value to start with [is
> better]([https://en.wikipedia.org/wiki/TCP_congestion_control#Slow_start]).
> *Suggestion*
> A better default might be:
> * maxBatchSize
> * maxBatchSize / parallelism
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
