flink1.15 sink到cassandra 失败重试 怎么写

对于 flink1.15 sink 到 cassandra 失败重试的问题，可以通过以下代码实现：

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 会自动进行重试，直到达到最大重试次数或写入成功为止。

希望这个回答能够帮到你！

相关问题

flink1.15 sink到cassandra pojo方式 怎么写

您可以使用以下代码将 Flink 1.15 中的数据以 POJO 方式写入 Cassandra：

DataStream<MyPojo> stream = ...; // 输入数据流
CassandraSink.addSink(stream)
    .setHost("127.0.0.1")
    .setPort(9042)
    .setKeyspace("my_keyspace")
    .setTable("my_table")
    .build();

其中，`MyPojo` 是您定义的 POJO 类，`setHost` 和 `setPort` 分别设置 Cassandra 的主机名和端口号，`setKeyspace` 和 `setTable` 分别设置要写入的 keyspace 和 table 名称。

flink1.15 sink到cassandra 怎么写

您可以使用以下代码将 Flink 1.15 的数据流写入 Cassandra：

DataStream<YourDataType> dataStream = ... // your data stream
CassandraSink.addSink(dataStream)
    .setHost("your-cassandra-host")
    .setPort(9042)
    .setKeyspace("your-keyspace")
    .setTable("your-table")
    .build();

请确保您已经在项目中添加了以下依赖项：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-cassandra_2.11</artifactId>
    <version>1.15.0</version>
</dependency>
<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>cassandra-driver-core</artifactId>
    <version>3.11.0</version>
</dependency>

请注意，您需要将 `your-cassandra-host`、`your-keyspace` 和 `your-table` 替换为您自己的 Cassandra 主机、键空间和表名。