Fix issue: apache/pulsar#23555.

- remove useless variable
apache · Nov 12, 2024 · e66779e · e66779e
1 parent 8ce04bb
commit e66779e
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarBolt.java b/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarBolt.java
@@ -128,8 +128,6 @@ public void execute(Tuple input) {
                     }
                     collector.ack(input);
                 } else {
-                    final long messageSizeToBeSent = ((TypedMessageBuilderImpl<byte[]>) msgBuilder).getContent()
-                            .remaining();
                     msgBuilder.sendAsync().handle((msgId, ex) -> {
                         synchronized (collector) {
                             if (ex != null) {