Skip to content

Commit

Permalink
[INLONG-apache#7056][Manager] FlinkConfiguration add setFlinkConfig,s…
Browse files Browse the repository at this point in the history
…et flink config from Map before getFlinkConfig,not only get default flink config from flink-sort-plugin.properties
  • Loading branch information
maiborli committed Aug 30, 2023
1 parent 6cea5a8 commit 7934b84
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public void getFlinkConfigTest() {
}

@Test
public void setFlinkConfig() {
public void setFlinkConfigTest() {
try {
Map<String, String> flinkConfigMap = new HashMap<>();
flinkConfigMap.put("address", "0.0.0.0");
Expand Down

0 comments on commit 7934b84

Please sign in to comment.