ストームトライデントは初めてです。これが私の問題です：
私は Kafka キューからメッセージを消費し、の実装を使用CombinerAggregatorして集計を行い、Cassandra でデータを永続化しています。
これをローカルで実行すると、数値が正しく入力されていることがわかります。しかし、実稼働環境では、ほとんどの場合、これらの集計が 0 になっています。これは間違っています。これらのケースにも値が必要です。また、場合によっては、ゼロ以外の数字が表示されますが、これは正しいものです。
numOfWorkersトポロジーを 4 と2に設定しましparallelismHintた。何がうまくいかないか分かりますか? または、この問題をデバッグする方法を提案してください。