Hello
1.7.2是比较老的版本了, 可以考虑下升级新的版本,新的版本都支持你所需的功能的。
1.10.0 && 1.10.1 文档[1],对应的两个参数:
'connector.write.flush.max-rows' = '5000', -- optional, flush max size
(includes all append, upsert and delete records),
--
over this
请问timeout值是多少?在哪里可设置?
在 2020-06-18 17:43:31,"Benchao Li" 写道:
>我理解现在就是你想要的效果。
>batch-size和timeout两个条件是达到一个就会flush的。
>
>nicygan 于2020年6月18日周四 下午5:05写道:
>
>> dear all:
>> 我想用JDBCAppendTableSink向Mysql写数据,可以设置批量大小,不能设置间隔时间。
>>
>>
>> JDBCAppendTableSink sink =
我理解现在就是你想要的效果。
batch-size和timeout两个条件是达到一个就会flush的。
nicygan 于2020年6月18日周四 下午5:05写道:
> dear all:
> 我想用JDBCAppendTableSink向Mysql写数据,可以设置批量大小,不能设置间隔时间。
>
>
> JDBCAppendTableSink sink = JDBCAppendTableSink.builder().setBatchSize(1)
> .setDrivername("com.mysql.jdbc.Driver")
>
dear all:
我想用JDBCAppendTableSink向Mysql写数据,可以设置批量大小,不能设置间隔时间。
JDBCAppendTableSink sink = JDBCAppendTableSink.builder().setBatchSize(1)
.setDrivername("com.mysql.jdbc.Driver")
.setDBUrl("jdbc:mysql://localhost:3306/flink")
.setUsername("root")