From e7dfa28947f1582ab0b60ab9483b3fe06017f1ff Mon Sep 17 00:00:00 2001
From: MaBiao <mabiaocas@gmail.com>
Date: Thu, 16 Jun 2016 17:17:41 +0800
Subject: [PATCH] [FLINK-4076] BoltWrapper calls super.dispose()

This closes #2111
---
 .../main/java/org/apache/flink/storm/wrappers/BoltWrapper.java   | 1 +
 1 file changed, 1 insertion(+)

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 8ac820ec242..5311cb3e3ce 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<IN, OUT> extends AbstractStreamOperator<OUT> implements
 
 	@Override
 	public void dispose() {
+		super.dispose();
 		this.bolt.cleanup();
 	}
 
-- 
GitLab