Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5224#discussion_r159641680
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendAddressConfigurationTest.java
---
@@ -47,36 +49,29 @@ public static void init() {
}
@Test
- public void testValidConfig() {
- try {
- CliFrontend frontend = new
CliFrontend(CliFrontendTestUtils.getConfigDir());
- RunOptions options =
CliFrontendParser.parseRunCommand(new String[] {});
-
- ClusterClient clusterClient =
frontend.retrieveClient(options);
+ public void testValidConfig() throws Exception {
+ CliFrontend frontend = new CliFrontend(
+
GlobalConfiguration.loadConfiguration(CliFrontendTestUtils.getConfigDir()),
+ Collections.singletonList(new DefaultCLI()),
+ CliFrontendTestUtils.getConfigDir());
- checkJobManagerAddress(
- clusterClient.getFlinkConfiguration(),
-
CliFrontendTestUtils.TEST_JOB_MANAGER_ADDRESS,
-
CliFrontendTestUtils.TEST_JOB_MANAGER_PORT);
- }
- catch (Exception e) {
- e.printStackTrace();
- fail(e.getMessage());
- }
- }
-
- @Test(expected = IllegalConfigurationException.class)
- public void testInvalidConfigAndNoOption() throws Exception {
- CliFrontend frontend = new
CliFrontend(CliFrontendTestUtils.getInvalidConfigDir());
RunOptions options = CliFrontendParser.parseRunCommand(new
String[] {});
- frontend.retrieveClient(options);
+ ClusterClient clusterClient = frontend.retrieveClient(options);
+
+ checkJobManagerAddress(
+ clusterClient.getFlinkConfiguration(),
+ CliFrontendTestUtils.TEST_JOB_MANAGER_ADDRESS,
+ CliFrontendTestUtils.TEST_JOB_MANAGER_PORT);
}
@Test
public void testManualOptionsOverridesConfig() {
try {
- CliFrontend frontend = new
CliFrontend(CliFrontendTestUtils.getConfigDir());
+ CliFrontend frontend = new CliFrontend(
--- End diff --
nit: try-catch-exception block was removed in the test above but not here.
---
