Merge pull request #135 from tweise/APEX-56 Remove terminated operators from plan after window is committed.
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/a2f9d2e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/a2f9d2e3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/a2f9d2e3 Branch: refs/heads/devel-3 Commit: a2f9d2e30760c1a258c90891d6834ec1c4f9a606 Parents: ffedce9 064edf0 Author: gauravgopi123 <[email protected]> Authored: Fri Aug 21 14:22:57 2015 -0700 Committer: gauravgopi123 <[email protected]> Committed: Fri Aug 21 14:22:57 2015 -0700 ---------------------------------------------------------------------- .../common/util/AsyncFSStorageAgent.java | 1 + .../java/com/datatorrent/stram/StramClient.java | 1 - .../stram/StreamingContainerManager.java | 49 ++++++++---- .../stram/plan/physical/PhysicalPlan.java | 32 +++++--- .../com/datatorrent/stram/MockContainer.java | 2 +- .../com/datatorrent/stram/StreamCodecTest.java | 35 +-------- .../stram/StreamingContainerManagerTest.java | 83 +++++++++++++++++++- .../stram/engine/AtMostOnceTest.java | 2 +- .../stram/engine/ProcessingModeTests.java | 16 ++-- .../stram/engine/RecoverableInputOperator.java | 10 +-- 10 files changed, 152 insertions(+), 79 deletions(-) ----------------------------------------------------------------------
