diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java index 1036055071..34f4acd2a6 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java @@ -1050,7 +1050,7 @@ protected OutgoingBatch extractOutgoingBatch(ProcessInfo extractInfo, Node targe } catch (ProtocolException e) { if (!configurationService.getNodeChannel(currentBatch.getChannelId(), false).getChannel().isContainsBigLob()) { log.warn(e.getMessage()); - log.info("Re-attempting extraction for batch {} with contains_big_lobs enabled for channel {}", + log.info("Re-attempting extraction for batch {} with contains_big_lobs temporarily enabled for channel {}", currentBatch.getBatchId(), currentBatch.getChannelId()); extractInfo.setTotalDataCount(currentBatch.getDataRowCount()); currentBatch.resetStats(); diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java index 222f2a8b13..87f774b8be 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java @@ -761,7 +761,7 @@ protected long routeDataForChannel(ProcessInfo processInfo, final NodeChannel no batch.resetRouterStats(); batchId = batch.getBatchId(); } - log.info("Re-attempting routing for batch {} with contains_big_lobs enabled for channel {}", + log.info("Re-attempting routing for batch {} with contains_big_lobs temporarily enabled for channel {}", batchId, nodeChannel.getChannelId()); dataCount = 0; gapDetector.addDataIds(context.getDataIds());