org.apache.giraph.yarn

Class TestYarnJob

java.lang.Object

org.apache.giraph.yarn.TestYarnJob

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class TestYarnJob
extends Object
implements org.apache.zookeeper.Watcher

Tests the Giraph on YARN workflow. Basically, the plan is to use a MiniYARNCluster to run a small test job through our GiraphYarnClient -> GiraphApplicationMaster -gt; GiraphYarnTask (2 no-ops) No "real" BSP code need be tested here, as it is not aware it is running on YARN once the job is in progress, so the existing MRv1 BSP tests are fine.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Constructor and Description
TestYarnJob()

Method Summary

Modifier and Type	Method and Description
void	process(org.apache.zookeeper.WatchedEvent zkEvent) Logging this stuff will help you debug integration test issues.
void	testPureYarnJob()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestYarnJob

public TestYarnJob()

Method Detail

testPureYarnJob

public void testPureYarnJob()

process

public void process(org.apache.zookeeper.WatchedEvent zkEvent)

Logging this stuff will help you debug integration test issues.

Specified by:

process in interface org.apache.zookeeper.Watcher

Parameters:

zkEvent - incoming event for our current test ZK's znode tree.