You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/06/22 10:12:16 UTC
flink git commit: [FLINK-4076] BoltWrapper calls super.dispose()
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 <ma...@gmail.com>
Authored: Thu Jun 16 17:17:41 2016 +0800
Committer: zentol <ch...@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();
}