SAMZA-871; Heart-beat mechanism between JobCoordinator and all running containers release-0.13.0-rc0
authorAbhishek Shivanna <ashivanna@linkedin.com>
Wed, 10 May 2017 23:58:14 +0000 (16:58 -0700)
committervjagadish1989 <jvenkatr@linkedin.com>
Wed, 10 May 2017 23:58:14 +0000 (16:58 -0700)
commitf6d0d65516aed4f37216dc44ab312cdf1e7b124a
tree33776e923f62a89fde64c5171e52951bf76708d1
parent46b1333c450abdfc616970b21f6a5582e05ff222
SAMZA-871; Heart-beat mechanism between JobCoordinator and all running containers

Author: Abhishek Shivanna <ashivanna@linkedin.com>

Reviewers: Navina Ramesh <navina@apache.org>, Jagadish V <jagadish@apache.org>

Closes #163 from abhishekshivanna/master
15 files changed:
docs/learn/documentation/versioned/container/metrics-table.html
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatClient.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatResponse.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java
samza-core/src/main/scala/org/apache/samza/config/ShellCommandConfig.scala
samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala
samza-core/src/main/scala/org/apache/samza/util/Util.scala
samza-core/src/test/java/org/apache/samza/container/TestContainerHeartbeatClient.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/container/TestContainerHeartbeatMonitor.java [new file with mode: 0644]
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnContainerRunner.java
samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java [new file with mode: 0644]
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala
samza-yarn/src/test/java/org/apache/samza/webapp/TestYarnContainerHeartbeatServlet.java [new file with mode: 0644]
samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaYarnAppMasterService.scala