flink1.15 sink到cassandra 失败重试 怎么写
时间: 2023-05-19 09:04:15 浏览: 170
Flink windows安装包
对于 flink1.15 sink 到 cassandra 失败重试的问题,可以通过以下代码实现:
```java
DataStream<Row> stream = ...; // 获取数据流
CassandraSink.addSink(stream)
.setHost("localhost")
.setQuery("INSERT INTO my_table (id, name) VALUES (?, ?)")
.setRetryDelay(1000)
.setMaxRetryAttempts(3)
.build();
```
其中,`setRetryDelay` 设置重试间隔时间,`setMaxRetryAttempts` 设置最大重试次数。这样,当写入 cassandra 失败时,flink 会自动进行重试,直到达到最大重试次数或写入成功为止。
希望这个回答能够帮到你!
阅读全文