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.Exceptionpublic void testCallRestart()
throws java.lang.Exception
java.lang.Exceptionpublic void testCallKill()
throws java.lang.Exception
java.lang.Exceptionpublic 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.Exceptionpublic void testParseNewParallelismParam()
public void testParseNewParallelismParamEmpty()
public void testParseNewParallelismParamInvalid1()
public void testParseNewParallelismParamInvalid12()
public void testParallelismDelta()