使用本地集群重新运行 Trident 拓扑时出现此错误:
Current batch (1) is behind state's batch
以前的事务 ID 和一个计数器值一起存储在 Cassandra 中,但似乎事务 ID 在开始时总是设置为 1,因此简单的验证步骤(当前事务 ID 大于以前的事务 ID)总是失败。
如何让 Trident 持久化当前的批次 ID?
谢谢!
使用本地集群重新运行 Trident 拓扑时出现此错误:
Current batch (1) is behind state's batch
以前的事务 ID 和一个计数器值一起存储在 Cassandra 中,但似乎事务 ID 在开始时总是设置为 1,因此简单的验证步骤(当前事务 ID 大于以前的事务 ID)总是失败。
如何让 Trident 持久化当前的批次 ID?
谢谢!