You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/11/29 12:22:10 UTC
[streampipes] branch dev updated: [hotfix] Fix exception logging for unavailable endpoints
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 73af6c9a2 [hotfix] Fix exception logging for unavailable endpoints
new 064f49152 Merge branch 'dev' of github.com:apache/streampipes into dev
73af6c9a2 is described below
commit 73af6c9a2e37b323867fbe4049745ce7e22fd721
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Tue Nov 29 13:17:11 2022 +0100
[hotfix] Fix exception logging for unavailable endpoints
---
.../manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java
index 0b77ea00e..fd05e13ee 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/pipeline/ExtensionsServiceLogExecutor.java
@@ -28,12 +28,16 @@ import org.apache.streampipes.serializers.json.JacksonSerializer;
import org.apache.streampipes.svcdiscovery.SpServiceDiscovery;
import org.apache.streampipes.svcdiscovery.api.model.DefaultSpServiceGroups;
import org.apache.streampipes.svcdiscovery.api.model.DefaultSpServiceTags;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.List;
public class ExtensionsServiceLogExecutor implements Runnable {
+ private static final Logger LOG = LoggerFactory.getLogger(ExtensionsServiceLogExecutor.class);
+
private static final String LOG_PATH = "/monitoring";
public void run() {
@@ -49,7 +53,7 @@ public class ExtensionsServiceLogExecutor implements Runnable {
SpEndpointMonitoringInfo monitoringInfo = parseLogResponse(response);
ExtensionsLogProvider.INSTANCE.addMonitoringInfos(monitoringInfo);
} catch (IOException e) {
- e.printStackTrace();
+ LOG.info("Could not fetch log info from endpoint {}", serviceEndpoint);
}
});
}