Skip to content

Commit 9c973e4

Browse files
author
Robert Kruszewski
committed
linting
1 parent 1fe3936 commit 9c973e4

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,14 +120,16 @@ final class ShuffleExternalSorter extends MemoryConsumer {
120120
this.taskContext = taskContext;
121121
this.numPartitions = numPartitions;
122122
// Use getSizeAsKb (not bytes) to maintain backwards compatibility if no units are provided
123-
this.fileBufferSizeBytes = (int) (long) conf.get(package$.MODULE$.SHUFFLE_FILE_BUFFER_SIZE()) * 1024;
123+
this.fileBufferSizeBytes =
124+
(int) (long) conf.get(package$.MODULE$.SHUFFLE_FILE_BUFFER_SIZE()) * 1024;
124125
this.numElementsForSpillThreshold =
125126
conf.getLong("spark.shuffle.spill.numElementsForceSpillThreshold", 1024 * 1024 * 1024);
126127
this.writeMetrics = writeMetrics;
127128
this.inMemSorter = new ShuffleInMemorySorter(
128129
this, initialSize, conf.getBoolean("spark.shuffle.sort.useRadixSort", true));
129130
this.peakMemoryUsedBytes = getMemoryUsage();
130-
this.diskWriteBufferSize = (int) (long) conf.get(package$.MODULE$.SHUFFLE_DISK_WRITE_BUFFER_SIZE());
131+
this.diskWriteBufferSize =
132+
(int) (long) conf.get(package$.MODULE$.SHUFFLE_DISK_WRITE_BUFFER_SIZE());
131133
}
132134

133135
/**

dev/lint-java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
SCRIPT_DIR="$( cd "$( dirname "$0" )" && pwd )"
2121
SPARK_ROOT_DIR="$(dirname $SCRIPT_DIR)"
2222

23-
ERRORS=$($SCRIPT_DIR/../build/mvn -Pkinesis-asl -Pmesos -Pyarn -Phive -Phive-thriftserver checkstyle:check | grep ERROR)
23+
ERRORS=$($SCRIPT_DIR/../build/mvn -Pkubernetes -Pkinesis-asl -Pmesos -Pyarn -Phive -Phive-thriftserver checkstyle:check | grep ERROR)
2424

2525
if test ! -z "$ERRORS"; then
2626
echo -e "Checkstyle checks failed at following occurrences:\n$ERRORS"

0 commit comments

Comments
 (0)