Re: flink1.7.2-JDBCAppendTableSink,如何按间隔时间写入数据

2020-06-18 文章 Leonard Xu
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

Re:Re: flink1.7.2-JDBCAppendTableSink,如何按间隔时间写入数据

2020-06-18 文章 nicygan
请问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 =

Re: flink1.7.2-JDBCAppendTableSink,如何按间隔时间写入数据

2020-06-18 文章 Benchao Li
我理解现在就是你想要的效果。 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") >

flink1.7.2-JDBCAppendTableSink,如何按间隔时间写入数据

2020-06-18 文章 nicygan
dear all: 我想用JDBCAppendTableSink向Mysql写数据,可以设置批量大小,不能设置间隔时间。 JDBCAppendTableSink sink = JDBCAppendTableSink.builder().setBatchSize(1) .setDrivername("com.mysql.jdbc.Driver") .setDBUrl("jdbc:mysql://localhost:3306/flink") .setUsername("root")