[FLINK-4076] BoltWrapper calls super.dispose()

This closes #2111

[FLINK-4076] BoltWrapper calls super.dispose()
This closes #2111
e7dfa289 · MaBiao · zentol · 93c61c09 · e7dfa289
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java ...ain/java/org/apache/flink/storm/wrappers/BoltWrapper.java +1 -0

未找到文件。
--- 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<IN, OUT> extends AbstractStreamOperator<OUT> implements

 	@Override
 	public void dispose() {
+		super.dispose();
 		this.bolt.cleanup();
 	}