Refactor text mining config
package org.apache.streampipes.processors.textmining.flink.config;
+import org.apache.streampipes.svcdiscovery.SpServiceDiscovery;
import org.apache.streampipes.svcdiscovery.api.SpConfig;
import org.apache.streampipes.container.model.PeConfig;
@@ -33,7 +34,7 @@ public enum TextMiningFlinkConfig implements PeConfig {
TextMiningFlinkConfig() {
- config = SpConfig.getSpConfig(service_id);
+ config = SpServiceDiscovery.getSpConfig(service_id);
config.register(ConfigKeys.HOST, service_container_name, "Hostname for the pe mixed flink component");
config.register(ConfigKeys.PORT, 8090, "Port for the pe mixed flink component");
