Skip to content
Permalink
Browse files

tweak logging message

  • Loading branch information...
erilong committed Mar 13, 2019
1 parent 5087c9a commit c2a0490d4aa21e501ceeee7f9fdc2066b456017c
@@ -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();
@@ -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());

0 comments on commit c2a0490

Please sign in to comment.
You can’t perform that action at this time.