bug fix: changed flink_host default from taskmanager to jobmanager
@@ -23,7 +23,7 @@ public enum FlinkConfig {
config.register(HOST, "pe-flink-samples", "Hostname for the pe mixed flink component");
config.register(PORT, 8090, "Port for the pe mixed flink component");
- config.register(FLINK_HOST, "taskmanager", "Host for the flink cluster");
+ config.register(FLINK_HOST, "jobmanager", "Host for the flink cluster");
config.register(FLINK_PORT, 6123, "Port for the flink cluster");
config.register(ELASTIC_HOST, "elasticsearch", "Elastic search host address");
config.register(ELASTIC_PORT, 9200, "Elasitc search port");
@@ -55,7 +55,6 @@ public enum FlinkConfig {
}
-
public static final String iconBaseUrl = FlinkConfig.INSTANCE.getHost() + "/img";
public static final String getIconUrl(String pictureName) {
