You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2017/03/03 16:40:12 UTC

[2/2] apex-core git commit: Merge branch 'APEXCORE-563-event-log-update' of http://github.com/DT-Priyanka/incubator-apex-core into APEXCORE-563

Merge branch 'APEXCORE-563-event-log-update' of http://github.com/DT-Priyanka/incubator-apex-core into APEXCORE-563


Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/8ce340ef
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/8ce340ef
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/8ce340ef

Branch: refs/heads/master
Commit: 8ce340ef3e363d188a58ae496d51cec170a58947
Parents: 1e47856 764ca7b
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Fri Mar 3 08:33:27 2017 -0800
Committer: Vlad Rozov <v....@datatorrent.com>
Committed: Fri Mar 3 08:33:27 2017 -0800

----------------------------------------------------------------------
 .../datatorrent/stram/StramLocalCluster.java    |   5 +-
 .../stram/StreamingContainerParent.java         |   9 +-
 .../com/datatorrent/stram/api/StramEvent.java   |  58 ++++++++--
 .../StreamingContainerUmbilicalProtocol.java    |   5 +-
 .../stram/engine/StreamingContainer.java        |  14 ++-
 .../com/datatorrent/stram/util/LoggerUtil.java  |  77 +++++++++++++
 .../org/apache/apex/log/LogFileInformation.java |  45 ++++++++
 .../datatorrent/stram/StramRecoveryTest.java    |   6 +-
 .../stram/util/LogFileInformationTest.java      | 111 +++++++++++++++++++
 9 files changed, 308 insertions(+), 22 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-core/blob/8ce340ef/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/apex-core/blob/8ce340ef/engine/src/test/java/com/datatorrent/stram/StramRecoveryTest.java
----------------------------------------------------------------------