You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by jk...@apache.org on 2021/01/08 13:52:22 UTC
[unomi] branch unomi-1.4.x updated: UNOMI-412: change some DEBUG
log to WARN, ERROR or INFO (#233)
This is an automated email from the ASF dual-hosted git repository.
jkevan pushed a commit to branch unomi-1.4.x
in repository https://gitbox.apache.org/repos/asf/unomi.git
The following commit(s) were added to refs/heads/unomi-1.4.x by this push:
new de63704 UNOMI-412: change some DEBUG log to WARN, ERROR or INFO (#233)
de63704 is described below
commit de63704ea46b4743e31e2f855c4ffece0f1ea459
Author: kevan Jahanshahi <ke...@jahia.com>
AuthorDate: Wed Jan 6 11:01:37 2021 +0100
UNOMI-412: change some DEBUG log to WARN, ERROR or INFO (#233)
* UNOMI-412: change some DEBUG log to WARN, ERROR or INFO
* UNOMI-412: code review improvements
---
.../unomi/router/core/processor/LineSplitFailureHandler.java | 2 +-
.../router/core/route/ProfileImportToUnomiRouteBuilder.java | 2 +-
.../apache/unomi/sfdc/services/internal/SFDCServiceImpl.java | 2 +-
.../mailchimp/services/internal/MailChimpServiceImpl.java | 4 ++--
.../elasticsearch/ElasticSearchPersistenceServiceImpl.java | 2 +-
.../conditions/ConditionESQueryBuilderDispatcher.java | 8 ++------
.../GeoLocationByPointSessionConditionEvaluator.java | 5 ++++-
.../unomi/plugins/request/actions/SetRemoteHostInfoAction.java | 10 ++++++++--
.../services/services/ClusterSystemStatisticsEventHandler.java | 2 +-
.../apache/unomi/services/services/DefinitionsServiceImpl.java | 2 +-
.../org/apache/unomi/services/services/EventServiceImpl.java | 2 +-
wab/src/main/java/org/apache/unomi/web/ContextServlet.java | 4 +---
12 files changed, 24 insertions(+), 21 deletions(-)
diff --git a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitFailureHandler.java b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitFailureHandler.java
index 7543e48..a7aeb1a 100644
--- a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitFailureHandler.java
+++ b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitFailureHandler.java
@@ -32,7 +32,7 @@ public class LineSplitFailureHandler implements Processor {
private static final Logger logger = LoggerFactory.getLogger(LineSplitFailureHandler.class.getName());
public void process(Exchange exchange) throws Exception {
- logger.debug("Route: {}, Error: {}", exchange.getProperty(Exchange.FAILURE_ROUTE_ID), exchange.getProperty(Exchange.EXCEPTION_CAUGHT));
+ logger.error("Route: {}, Error: {}", exchange.getProperty(Exchange.FAILURE_ROUTE_ID), exchange.getProperty(Exchange.EXCEPTION_CAUGHT));
ImportLineError importLineError = new ImportLineError();
if (exchange.getProperty(Exchange.EXCEPTION_CAUGHT) instanceof BadProfileDataFormatException) {
importLineError.setErrorCode(((BadProfileDataFormatException) exchange.getProperty(Exchange.EXCEPTION_CAUGHT)).getCause().getMessage());
diff --git a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/route/ProfileImportToUnomiRouteBuilder.java b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/route/ProfileImportToUnomiRouteBuilder.java
index 9c5a876..8336bf8 100644
--- a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/route/ProfileImportToUnomiRouteBuilder.java
+++ b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/route/ProfileImportToUnomiRouteBuilder.java
@@ -58,7 +58,7 @@ public class ProfileImportToUnomiRouteBuilder extends RouterAbstractRouteBuilder
.unmarshal(jacksonDataFormat)
.process(unomiStorageProcessor)
.otherwise()
- .log(LoggingLevel.DEBUG, "Failed message, skip processing!")
+ .log(LoggingLevel.WARN, "Failed message, skip processing!")
.end()
.aggregate(constant(true), new ArrayListAggregationStrategy())
.completionPredicate(exchangeProperty("CamelSplitComplete").isEqualTo("true"))
diff --git a/extensions/salesforce-connector/services/src/main/java/org/apache/unomi/sfdc/services/internal/SFDCServiceImpl.java b/extensions/salesforce-connector/services/src/main/java/org/apache/unomi/sfdc/services/internal/SFDCServiceImpl.java
index 6f7a92a..fb5fbd8 100644
--- a/extensions/salesforce-connector/services/src/main/java/org/apache/unomi/sfdc/services/internal/SFDCServiceImpl.java
+++ b/extensions/salesforce-connector/services/src/main/java/org/apache/unomi/sfdc/services/internal/SFDCServiceImpl.java
@@ -370,7 +370,7 @@ public class SFDCServiceImpl implements SFDCService {
sfdcLeadFields.put(consentSfdcId, consentValue);
logger.debug("Consent {} with value {} was mapped with {}", consentUnomiId, consentValue, consentSfdcId);
} else {
- logger.debug("Consent {} not found in current profile or not answered yet", consentUnomiId);
+ logger.warn("Consent {} not found in current profile or not answered yet", consentUnomiId);
}
}
}
diff --git a/extensions/unomi-mailchimp/services/src/main/java/org/apache/unomi/mailchimp/services/internal/MailChimpServiceImpl.java b/extensions/unomi-mailchimp/services/src/main/java/org/apache/unomi/mailchimp/services/internal/MailChimpServiceImpl.java
index a704f99..28de325 100644
--- a/extensions/unomi-mailchimp/services/src/main/java/org/apache/unomi/mailchimp/services/internal/MailChimpServiceImpl.java
+++ b/extensions/unomi-mailchimp/services/src/main/java/org/apache/unomi/mailchimp/services/internal/MailChimpServiceImpl.java
@@ -301,10 +301,10 @@ public class MailChimpServiceImpl implements MailChimpService {
|| StringUtils.isBlank(mergeFields.getJSONObject(mcTagName).get(CITY).toString())
|| StringUtils.isBlank(mergeFields.getJSONObject(mcTagName).get(COUNTRY).toString()))) {
mergeFields.remove(mcTagName);
- logger.debug("Can't map the address property {}, one of the mandatory field is missing (addr1, zip, city, country)", mcTagName);
+ logger.warn("Can't map the address property {}, one of the mandatory field is missing (addr1, zip, city, country)", mcTagName);
}
} else {
- logger.debug("Found property {} in MC list, if you need this property please update mapping or add the property to your MC list", mcTagName);
+ logger.warn("Found property {} in MC list, if you need this property please update mapping or add the property to your MC list", mcTagName);
}
}
}
diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
index 1ab84ff..ba4f395 100644
--- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
+++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
@@ -914,7 +914,7 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService,
final BulkResponse deleteResponse = deleteByScope.get();
if (deleteResponse.hasFailures()) {
// do something
- logger.debug("Couldn't remove by query " + query + ":\n{}", deleteResponse.buildFailureMessage());
+ logger.warn("Couldn't remove by query " + query + ":\n{}", deleteResponse.buildFailureMessage());
}
}
diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/conditions/ConditionESQueryBuilderDispatcher.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/conditions/ConditionESQueryBuilderDispatcher.java
index 56b280e..be2535c 100644
--- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/conditions/ConditionESQueryBuilderDispatcher.java
+++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/conditions/ConditionESQueryBuilderDispatcher.java
@@ -86,9 +86,7 @@ public class ConditionESQueryBuilderDispatcher {
}
// if no matching
- if (logger.isDebugEnabled()) {
- logger.debug("No matching query builder for condition {} and context {}", condition, context);
- }
+ logger.warn("No matching query builder for condition {} and context {}", condition, context);
return QueryBuilders.matchAllQuery();
}
@@ -120,9 +118,7 @@ public class ConditionESQueryBuilderDispatcher {
}
// if no matching
- if (logger.isDebugEnabled()) {
- logger.debug("No matching query builder for condition {} and context {}", condition, context);
- }
+ logger.warn("No matching query builder for condition {} and context {}", condition, context);
throw new UnsupportedOperationException();
}
}
diff --git a/plugins/baseplugin/src/main/java/org/apache/unomi/plugins/baseplugin/conditions/GeoLocationByPointSessionConditionEvaluator.java b/plugins/baseplugin/src/main/java/org/apache/unomi/plugins/baseplugin/conditions/GeoLocationByPointSessionConditionEvaluator.java
index 8de237b..12e8da6 100644
--- a/plugins/baseplugin/src/main/java/org/apache/unomi/plugins/baseplugin/conditions/GeoLocationByPointSessionConditionEvaluator.java
+++ b/plugins/baseplugin/src/main/java/org/apache/unomi/plugins/baseplugin/conditions/GeoLocationByPointSessionConditionEvaluator.java
@@ -61,7 +61,10 @@ public class GeoLocationByPointSessionConditionEvaluator implements ConditionEva
}
}
} catch (Exception e) {
- logger.debug("Cannot get properties", e);
+ logger.warn("Cannot evaluate condition, properties 'properties.location.lat' or 'properties.location.lon' not found, enable debug log level to see full stacktrace");
+ if (logger.isDebugEnabled()) {
+ logger.debug("Cannot evaluate condition", e);
+ }
}
return false;
}
diff --git a/plugins/request/src/main/java/org/apache/unomi/plugins/request/actions/SetRemoteHostInfoAction.java b/plugins/request/src/main/java/org/apache/unomi/plugins/request/actions/SetRemoteHostInfoAction.java
index cc1c5ae..11c9f74 100644
--- a/plugins/request/src/main/java/org/apache/unomi/plugins/request/actions/SetRemoteHostInfoAction.java
+++ b/plugins/request/src/main/java/org/apache/unomi/plugins/request/actions/SetRemoteHostInfoAction.java
@@ -229,7 +229,10 @@ public class SetRemoteHostInfoAction implements ActionExecutor {
}
return true;
} catch (IOException | GeoIp2Exception e) {
- logger.debug("Cannot resolve IP", e);
+ logger.warn("Cannot resolve IP {}, enable debug log level for complete stacktrace", remoteAddr);
+ if (logger.isDebugEnabled()) {
+ logger.debug("Cannot resolve IP", e);
+ }
}
return false;
}
@@ -240,7 +243,10 @@ public class SetRemoteHostInfoAction implements ActionExecutor {
try {
addr = InetAddress.getByName(remoteAddr);
} catch (UnknownHostException e) {
- logger.debug("Cannot resolve IP", e);
+ logger.warn("Cannot resolve IP {}, enable debug log level for complete stacktrace", remoteAddr);
+ if (logger.isDebugEnabled()) {
+ logger.debug("Cannot resolve IP", e);
+ }
return false;
}
// Check if the address is a valid special local or loop back
diff --git a/services/src/main/java/org/apache/unomi/services/services/ClusterSystemStatisticsEventHandler.java b/services/src/main/java/org/apache/unomi/services/services/ClusterSystemStatisticsEventHandler.java
index 2fef85c..27674bb 100644
--- a/services/src/main/java/org/apache/unomi/services/services/ClusterSystemStatisticsEventHandler.java
+++ b/services/src/main/java/org/apache/unomi/services/services/ClusterSystemStatisticsEventHandler.java
@@ -71,7 +71,7 @@ public class ClusterSystemStatisticsEventHandler extends CellarSupport implement
// check if the group is local
if (!groupManager.isLocalGroup(event.getSourceGroup().getName())) {
- logger.debug("CELLAR SYSTEM STATS: node is not part of the event cluster group {}",event.getSourceGroup().getName());
+ logger.info("CELLAR SYSTEM STATS: node is not part of the event cluster group {}",event.getSourceGroup().getName());
return;
}
diff --git a/services/src/main/java/org/apache/unomi/services/services/DefinitionsServiceImpl.java b/services/src/main/java/org/apache/unomi/services/services/DefinitionsServiceImpl.java
index 65f767e..d82f366 100644
--- a/services/src/main/java/org/apache/unomi/services/services/DefinitionsServiceImpl.java
+++ b/services/src/main/java/org/apache/unomi/services/services/DefinitionsServiceImpl.java
@@ -247,7 +247,7 @@ public class DefinitionsServiceImpl implements DefinitionsService, SynchronousBu
valueTypeByTag.put(tag, valueTypes);
} else {
// we found a tag that is not defined, we will define it automatically
- logger.debug("Unknown tag " + tag + " used in property type definition " + predefinedPropertyURL);
+ logger.warn("Unknown tag {} used in property type definition {}", tag, predefinedPropertyURL);
}
}
} catch (Exception e) {
diff --git a/services/src/main/java/org/apache/unomi/services/services/EventServiceImpl.java b/services/src/main/java/org/apache/unomi/services/services/EventServiceImpl.java
index 1334135..76c6e9d 100644
--- a/services/src/main/java/org/apache/unomi/services/services/EventServiceImpl.java
+++ b/services/src/main/java/org/apache/unomi/services/services/EventServiceImpl.java
@@ -132,7 +132,7 @@ public class EventServiceImpl implements EventService {
}
}
}
- logger.debug("Could not authenticate any third party servers");
+ logger.warn("Could not authenticate any third party servers for key: {}", key);
}
return null;
}
diff --git a/wab/src/main/java/org/apache/unomi/web/ContextServlet.java b/wab/src/main/java/org/apache/unomi/web/ContextServlet.java
index 01cbe95..ed5d06b 100644
--- a/wab/src/main/java/org/apache/unomi/web/ContextServlet.java
+++ b/wab/src/main/java/org/apache/unomi/web/ContextServlet.java
@@ -299,9 +299,7 @@ public class ContextServlet extends HttpServlet {
String masterProfileId = profile.getMergedWith();
Profile masterProfile = profileService.load(masterProfileId);
if (masterProfile != null) {
- if (logger.isDebugEnabled()) {
- logger.debug("Current profile was merged with profile {}, replacing profile in session", masterProfileId);
- }
+ logger.info("Current profile {} was merged with profile {}, replacing profile in session", currentProfile.getItemId(), masterProfileId);
profile = masterProfile;
if (session != null) {
session.setProfile(profile);