apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [04/10] incubator-apex-core git commit: Merge pull request #135 from tweise/APEX-56
Date Tue, 25 Aug 2015 23:23:56 GMT
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 <gaurav@datatorrent.com>
Authored: Fri Aug 21 14:22:57 2015 -0700
Committer: gauravgopi123 <gaurav@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(-)
----------------------------------------------------------------------



Mime
View raw message