Skip to content

Commit 64e1d79

Browse files
committed
Refactored exception message
1 parent fb04b52 commit 64e1d79

4 files changed

Lines changed: 4 additions & 4 deletions

File tree

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1526,7 +1526,7 @@ private void incrementNumSpills() throws IOException {
15261526
++numSpills;
15271527
if(spillFilesCountLimit != SPILL_FILES_COUNT_UNBOUNDED_LIMIT_VALUE && numSpills > spillFilesCountLimit) {
15281528
throw new IOException("Too many spill files got created, control it with " +
1529-
"mapreduce.task.spill.files.count.limit, current value: " + spillFilesCountLimit +
1529+
"tez.runtime.spill.files.count.limit, current value: " + spillFilesCountLimit +
15301530
", current spill count: " + numSpills);
15311531
}
15321532
}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/DefaultSorter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1419,7 +1419,7 @@ private void incrementNumSpills() throws IOException {
14191419
++numSpills;
14201420
if(spillFilesCountLimit != SPILL_FILES_COUNT_UNBOUNDED_LIMIT_VALUE && numSpills > spillFilesCountLimit) {
14211421
throw new IOException("Too many spill files got created, control it with " +
1422-
"mapreduce.task.spill.files.count.limit, current value: " + spillFilesCountLimit +
1422+
"tez.runtime.spill.files.count.limit, current value: " + spillFilesCountLimit +
14231423
", current spill count: " + numSpills);
14241424
}
14251425
}

tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/sort/impl/TestPipelinedSorter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -924,7 +924,7 @@ public void testSpillFilesCountBreach() throws IOException, NoSuchMethodExceptio
924924
String errorMessage = targetException.getMessage();
925925
if (errorMessage != null) {
926926
if(errorMessage.equals("Too many spill files got created, control it with " +
927-
"mapreduce.task.spill.files.count.limit, current value: 2, current spill count: 3")) {
927+
"tez.runtime.spill.files.count.limit, current value: 2, current spill count: 3")) {
928928
gotExceptionWithMessage = true;
929929
}
930930
}

tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/sort/impl/dflt/TestDefaultSorter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -636,7 +636,7 @@ public void testSpillFilesCountBreach() throws IOException, NoSuchMethodExceptio
636636
String errorMessage = targetException.getMessage();
637637
if (errorMessage != null) {
638638
if(errorMessage.equals("Too many spill files got created, control it with " +
639-
"mapreduce.task.spill.files.count.limit, current value: 2, current spill count: 3")) {
639+
"tez.runtime.spill.files.count.limit, current value: 2, current spill count: 3")) {
640640
gotExceptionWithMessage = true;
641641
}
642642
}

0 commit comments

Comments
 (0)