[STREAMPIPES-319] Modify Flink config
diff --git a/streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/Config.java b/streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/Config.java
index b440204..e807572 100644
--- a/streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/Config.java
+++ b/streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/Config.java
@@ -17,6 +17,7 @@
*/
package org.apache.streampipes.pe.flink.config;
+import org.apache.streampipes.svcdiscovery.SpServiceDiscovery;
import org.apache.streampipes.svcdiscovery.api.SpConfig;
import org.apache.streampipes.container.model.PeConfig;
@@ -30,7 +31,7 @@
private final static String SERVICE_CONTAINER_NAME = "pipeline-elements-all-flink";
Config() {
- config = SpConfig.getSpConfig(SERVICE_ID);
+ config = SpServiceDiscovery.getSpConfig(SERVICE_ID);
config.register(ConfigKeys.HOST, SERVICE_CONTAINER_NAME, "Data processor host");
config.register(ConfigKeys.PORT, 8090, "Data processor port");
config.register(ConfigKeys.SERVICE_NAME, SERVICE_NAME, "Data processor service name");
diff --git a/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/config/GeoFlinkConfig.java b/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/config/GeoFlinkConfig.java
index 0f704ca..498bfb1 100644
--- a/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/config/GeoFlinkConfig.java
+++ b/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/config/GeoFlinkConfig.java
@@ -18,6 +18,7 @@
package org.apache.streampipes.processor.geo.flink.config;
+import org.apache.streampipes.svcdiscovery.SpServiceDiscovery;
import org.apache.streampipes.svcdiscovery.api.SpConfig;
import org.apache.streampipes.container.model.PeConfig;
@@ -31,7 +32,7 @@
private final static String service_name = "Processors Geo Flink";
private final static String service_container_name = "processors-geo-flink";
GeoFlinkConfig() {
- config = SpConfig.getSpConfig(service_id);
+ config = SpServiceDiscovery.getSpConfig(service_id);
config.register(ConfigKeys.HOST, service_container_name, "Hostname for the geo flink component");
config.register(ConfigKeys.PORT, 8090, "Port for the geo flink component");
