Skip to content

Commit 0200dd9

Browse files
committed
TEZ-4340: fix checkstyle/whitespace issues
1 parent 4450f32 commit 0200dd9

File tree

2 files changed

+7
-5
lines changed
  • tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped
  • tez-tests/src/test/java/org/apache/tez/test

2 files changed

+7
-5
lines changed

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/MergeManager.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -549,8 +549,9 @@ private void trackAndLogCloseInMemoryFile(MapOutput mapOutput) {
549549
private void startMemToDiskMerge() {
550550
synchronized (inMemoryMerger) {
551551
if (!inMemoryMerger.isInProgress()) {
552-
LOG.info(inputContext.getInputOutputVertexNames() + ": " + "Starting inMemoryMerger's merge since commitMemory=" +
553-
commitMemory + " > mergeThreshold=" + mergeThreshold +
552+
LOG.info(inputContext.getInputOutputVertexNames() + ": " +
553+
"Starting inMemoryMerger's merge since commitMemory=" + commitMemory +
554+
" > mergeThreshold=" + mergeThreshold +
554555
". Current usedMemory=" + usedMemory);
555556
inMemoryMapOutputs.addAll(inMemoryMergedMapOutputs);
556557
inMemoryMergedMapOutputs.clear();
@@ -788,8 +789,8 @@ public void merge(List<MapOutput> inputs) throws IOException, InterruptedExcepti
788789

789790
Writer writer = new InMemoryWriter(mergedMapOutputs.getMemory());
790791

791-
LOG.info(inputContext.getInputOutputVertexNames() + ": " + "Initiating Memory-to-Memory merge with " + noInMemorySegments +
792-
" segments of total-size: " + mergeOutputSize);
792+
LOG.info(inputContext.getInputOutputVertexNames() + ": " + "Initiating Memory-to-Memory merge with " +
793+
noInMemorySegments + " segments of total-size: " + mergeOutputSize);
793794

794795
if (Thread.currentThread().isInterrupted()) {
795796
return; // early exit

tez-tests/src/test/java/org/apache/tez/test/TestInput.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,8 @@ public void handleEvents(List<Event> inputEvents) throws Exception {
352352
if (event instanceof DataMovementEvent) {
353353
DataMovementEvent dmEvent = (DataMovementEvent) event;
354354
numCompletedInputs++;
355-
LOG.info(getContext().getInputOutputVertexNames() + " Received DataMovement event sourceId : " + dmEvent.getSourceIndex() +
355+
LOG.info(getContext().getInputOutputVertexNames() +
356+
" Received DataMovement event sourceId : " + dmEvent.getSourceIndex() +
356357
" targetId: " + dmEvent.getTargetIndex() +
357358
" version: " + dmEvent.getVersion() +
358359
" numInputs: " + getNumPhysicalInputs() +

0 commit comments

Comments
 (0)