我是风暴三叉戟的新手。这是我的问题：
我正在使用来自 Kafka 队列的消息并使用 的实现CombinerAggregator来进行聚合，以将数据保存在 Cassandra 中。
当我在本地运行这个东西时，我看到数字被正确填充。但是在生产环境中，我看到大多数时候这些聚合都是 0，这是错误的，我们也应该为这些情况设置值。在某些情况下，会出现正确的非零数字。
我已将numOfWorkers拓扑设置为 4 和parallelismHint2。您知道会出什么问题吗？或者建议一种方法来调试这个问题。