Skip to content
Permalink
Browse files

0003865: Improve logging readability and appropriate levels

  • Loading branch information...
erilong committed Feb 13, 2019
1 parent 652e76e commit abade6eb0e04dae0c90fcf0b75a5a3507c49ae79
@@ -197,7 +197,6 @@ public String getTableSummary() {
if (tableCounts != null && !tableCounts.isEmpty()) {
StringBuilder buff = new StringBuilder();
for (String table : tableCounts.keySet()) {
Integer count = tableCounts.get(table);
buff.append(table).append(", ");
}

@@ -243,6 +242,9 @@ protected void incrementTableCounts(AbstractBatch batch) {
}
}


public void resetTableSummary() {
tableCounts.clear();
tableSummary.clear();
}

}
@@ -169,6 +169,7 @@ public void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status
*/
cumulativeDataProcessed = status.getDataProcessed();
cumulativeBatchesProcessed = status.getBatchesProcessed();
status.resetTableSummary();
} while ((immediatePullIfDataFound || nodeService.isDataLoadStarted()) && !status.failed()
&& lastBatchesProcessed > 0);
} else {
@@ -177,6 +177,7 @@ public void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status
cumulativeReloadBatchesProcessed = status.getReloadBatchesProcessed();
cumulativeDataProcessed = status.getDataProcessed();
cumulativeBatchesProcessed = status.getBatchesProcessed();
status.resetTableSummary();
} while (((immediatePushIfDataFound && lastBatchesProcessed > 0) || lastReloadBatchesProcessed > 0) && !status.failed());
} finally {
startTimesOfNodesBeingPushedTo.remove(node.getNodeId());

0 comments on commit abade6e

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