public class RuntimeManagerRunnerTest
extends java.lang.Object
Constructor and Description |
---|
RuntimeManagerRunnerTest() |
Modifier and Type | Method and Description |
---|---|
void |
setUp() |
void |
testCallKill() |
void |
testCallRestart() |
void |
testKillTopologyHandlerClientCantKill() |
void |
testKillTopologyHandlerFailCleanState() |
void |
testKillTopologyHandlerOk() |
void |
testParallelismDelta() |
void |
testParseNewParallelismParam() |
void |
testParseNewParallelismParamEmpty() |
void |
testParseNewParallelismParamInvalid1() |
void |
testParseNewParallelismParamInvalid12() |
void |
testRestartTopologyHandlerFailDeleteTMasterLoc() |
void |
testRestartTopologyHandlerFailRestartTopology() |
void |
testRestartTopologyHandlerSuccRestartTopology() |
void |
testUpdateTopologyHandler() |
void |
testUpdateTopologyHandlerWithSameParallelism() |
public void setUp() throws java.lang.Exception
java.lang.Exception
public void testCallRestart() throws java.lang.Exception
java.lang.Exception
public void testCallKill() throws java.lang.Exception
java.lang.Exception
public void testRestartTopologyHandlerFailRestartTopology()
public void testRestartTopologyHandlerSuccRestartTopology()
public void testRestartTopologyHandlerFailDeleteTMasterLoc()
public void testKillTopologyHandlerClientCantKill()
public void testKillTopologyHandlerFailCleanState()
public void testKillTopologyHandlerOk()
@PrepareForTest(value=Runtime.class) public void testUpdateTopologyHandler() throws java.lang.Exception
java.lang.Exception
@PrepareForTest(value=Runtime.class) public void testUpdateTopologyHandlerWithSameParallelism() throws java.lang.Exception
java.lang.Exception
public void testParseNewParallelismParam()
public void testParseNewParallelismParamEmpty()
public void testParseNewParallelismParamInvalid1()
public void testParseNewParallelismParamInvalid12()
public void testParallelismDelta()