Merge branch 'APEXCORE-649' of github.com:tushargosavi/apex-core
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/cfe9cefe Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/cfe9cefe Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/cfe9cefe Branch: refs/heads/master Commit: cfe9cefed1400f83dc95a17a1f1f8de921d552b1 Parents: 6cb3e35 d705ed4 Author: Pramod Immaneni <[email protected]> Authored: Fri Apr 21 14:51:47 2017 -0700 Committer: Pramod Immaneni <[email protected]> Committed: Fri Apr 21 14:51:47 2017 -0700 ---------------------------------------------------------------------- .../stram/StreamingAppMasterService.java | 2 + .../stram/StreamingContainerManager.java | 2 + .../plugin/AbstractApexPluginDispatcher.java | 216 +++++++++++++++++++ .../AbstractDAGExecutionPluginContext.java | 9 +- .../engine/plugin/ApexPluginDispatcher.java | 8 + .../apex/engine/plugin/ApexPluginManager.java | 191 ---------------- .../plugin/DefaultApexPluginDispatcher.java | 4 +- .../apache/apex/engine/plugin/DebugPlugin.java | 29 +-- .../apache/apex/engine/plugin/PluginTests.java | 25 +-- 9 files changed, 242 insertions(+), 244 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/cfe9cefe/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ----------------------------------------------------------------------
