[FLINK-1436] fix missing checks in CliFrontendInfoTest

cfregly · Feb 13, 2015 · 2121185 · 2121185
1 parent 988602b
commit 2121185
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/flink-clients/src/test/java/org/apache/flink/client/CliFrontendInfoTest.java b/flink-clients/src/test/java/org/apache/flink/client/CliFrontendInfoTest.java
@@ -72,9 +72,10 @@ public void testErrorCases() {
 	@Test
 	public void testShowExecutionPlan() {
 		try {
-			String[] parameters = {"-e", CliFrontendTestUtils.getTestJarPath()};
+			String[] parameters = {CliFrontendTestUtils.getTestJarPath()};
 			InfoTestCliFrontend testFrontend = new InfoTestCliFrontend(-1);
-			testFrontend.info(parameters);
+			int retCode = testFrontend.info(parameters);
+			assertTrue(retCode == 0);
 		}
 		catch (Exception e) {
 			System.err.println(e.getMessage());
@@ -86,9 +87,10 @@ public void testShowExecutionPlan() {
 	@Test
 	public void testShowExecutionPlanWithParallelism() {
 		try {
-			String[] parameters = {"-e", "-p", "17", CliFrontendTestUtils.getTestJarPath()};
+			String[] parameters = {"-p", "17", CliFrontendTestUtils.getTestJarPath()};
 			InfoTestCliFrontend testFrontend = new InfoTestCliFrontend(17);
-			testFrontend.info(parameters);
+			int retCode = testFrontend.info(parameters);
+			assertTrue(retCode == 0);
 		}
 		catch (Exception e) {
 			System.err.println(e.getMessage());