diff --git a/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java b/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java index 8ac820ec2428591a0a8037620c9e446495f177a2..5311cb3e3ce949ace9069ee1b3ca38995b64cae4 100644 --- a/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java +++ b/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java @@ -292,6 +292,7 @@ public class BoltWrapper extends AbstractStreamOperator implements @Override public void dispose() { + super.dispose(); this.bolt.cleanup(); }