You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:13:13 UTC
[42/50] incubator-apex-core git commit: Merge pull request #135 from
tweise/APEX-56
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/master
Commit: a2f9d2e30760c1a258c90891d6834ec1c4f9a606
Parents: ffedce9 064edf0
Author: gauravgopi123 <ga...@datatorrent.com>
Authored: Fri Aug 21 14:22:57 2015 -0700
Committer: gauravgopi123 <ga...@datatorrent.com>
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(-)
----------------------------------------------------------------------