flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [FLINK-4076] BoltWrapper calls super.dispose()
Date Wed, 22 Jun 2016 10:12:16 GMT
Repository: flink
Updated Branches:
  refs/heads/master 93c61c097 -> e7dfa2894


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

This closes #2111


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7dfa289
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e7dfa289
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e7dfa289

Branch: refs/heads/master
Commit: e7dfa28947f1582ab0b60ab9483b3fe06017f1ff
Parents: 93c61c0
Author: MaBiao <mabiaocas@gmail.com>
Authored: Thu Jun 16 17:17:41 2016 +0800
Committer: zentol <chesnay@apache.org>
Committed: Wed Jun 22 12:10:54 2016 +0200

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


http://git-wip-us.apache.org/repos/asf/flink/blob/e7dfa289/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/BoltWrapper.java
----------------------------------------------------------------------
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 8ac820e..5311cb3 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();
 	}
 


Mime
View raw message