Skip to content
Snippets Groups Projects
Commit 8d089dd8 authored by Christian Wulf's avatar Christian Wulf
Browse files

fixed logging bug

parent adc39144
No related branches found
No related tags found
No related merge requests found
...@@ -94,13 +94,16 @@ class ExecutionInstantiation { ...@@ -94,13 +94,16 @@ class ExecutionInstantiation {
int color = DEFAULT_COLOR; int color = DEFAULT_COLOR;
Map<Stage, Integer> colors = new HashMap<Stage, Integer>(); Map<Stage, Integer> colors = new HashMap<Stage, Integer>();
Set<Stage> threadableStageJobs = configuration.getThreadableStages().keySet(); Set<Stage> threadableStageJobs = configuration.getThreadableStages().keySet();
Integer createdConnections = 0; int numCreatedConnections = 0;
for (Stage threadableStage : threadableStageJobs) { for (Stage threadableStage : threadableStageJobs) {
color++; color++;
colors.put(threadableStage, color); colors.put(threadableStage, color);
createdConnections = colorAndConnectStages(color, colors, threadableStage, configuration); numCreatedConnections += colorAndConnectStages(color, colors, threadableStage, configuration);
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Created " + numCreatedConnections + " connections");
} }
LOGGER.debug("Created " + createdConnections + " connections");
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment