flink jdbcsink 连接数的问题

Mon, 29 May 2023 22:56:20 -0700 

各位老师，请教一下关于flink jdbcsink 连接数的问题；
我使用代码如下：在以下代码中，我查看了一下源码，并没有找到sink到MySQL时关于连接数的设定，请问这一块关于连接数的设定我应该怎么写呀；
谢谢各位老师的指导

|
outPutInfoStream.addSink(JdbcSink.sink(
"REPLACE  into InputInfo (breakCode, breakName, breakDuration, 
breakRule,breakPrimaryKey,breakStep,breakStepType,breakTime,breakSendTime,breakArgs)
 values (?,?,?,?,?,?,?,?,?,?)",
                (statement, InPutInfo) -> {
                    statement.setString(1,InPutInfo.getBreakCode());
                    statement.setString(2,InPutInfo.getBreakName());
                    statement.setLong(3,InPutInfo.getBreakDuration());
                    statement.setString(4,InPutInfo.getBreakRule());
                    statement.setString(5,InPutInfo.getBreakPrimaryKey());
                    statement.setString(6, InPutInfo.getBreakStep());
                    statement.setString(7, InPutInfo.getBreakStepType());
                    statement.setString(8,InPutInfo.getBreakTime());
                    statement.setString(9, DateUtil.format(new Date()));
                    statement.setString(10, 
String.valueOf(InPutInfo.getBreakArgs()));
                },
                JdbcExecutionOptions.builder()
                        .withBatchSize(10)
                        .withBatchIntervalMs(200)
                        .withMaxRetries(5)
                        .build(),
new JdbcConnectionOptions.JdbcConnectionOptionsBuilder()
                        
.withUrl("jdbc:mysql://111/iap?useSSL=false&useUnicode=false&failOverReadOnly=false&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&autoReconnectForPools=true&serverTimezone=Asia/Shanghai&autoReconnect=true")
                        .withDriverName("com.mysql.jdbc.Driver")
                        .withUsername("111")
                        .withPassword("111")
.build()
        )).name("sink-mysql");
|


| |
小昌同学
|
|
ccc0606fight...@163.com
|

回复