2

使用本地集群重新运行 Trident 拓扑时出现此错误:

Current batch (1) is behind state's batch

以前的事务 ID 和一个计数器值一起存储在 Cassandra 中,但似乎事务 ID 在开始时总是设置为 1,因此简单的验证步骤(当前事务 ID 大于以前的事务 ID)总是失败。

如何让 Trident 持久化当前的批次 ID?

谢谢!

4

0 回答 0