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 <mabiao...@gmail.com> Authored: Thu Jun 16 17:17:41 2016 +0800 Committer: zentol <ches...@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(); }
