[FLINK-10399] Rely on exception propgation to fail tests.

tongcheng-elong · Oct 9, 2018 · a363146 · a363146
1 parent 959eb7d
commit a363146
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java b/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java
@@ -47,9 +47,8 @@ protected void validate(ParameterTool parameter) {
  byte[] b = InstantiationUtil.serializeObject(parameter);
  final ParameterTool copy = InstantiationUtil.deserializeObject(b, getClass().getClassLoader());
  internalValidate(copy);
- } catch (Exception e) {
- e.printStackTrace();
- Assert.fail(e.getMessage());
+ } catch (IOException | ClassNotFoundException e) {
+ throw new RuntimeException(e);
  }
  }
 
@@ -82,8 +81,7 @@ private void internalValidate(ParameterTool parameter) {
  Assert.assertTrue(defaultProps.containsKey("input"));
 
  } catch (IOException e) {
- e.printStackTrace();
- Assert.fail(e.getMessage());
+ throw new RuntimeException(e);
  }
  }
 }