You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2017/07/28 10:31:43 UTC
spark git commit: [MINOR][BUILD] Fix current lint-java failures
Repository: spark
Updated Branches:
refs/heads/master a5a318997 -> 63d168cbb
[MINOR][BUILD] Fix current lint-java failures
## What changes were proposed in this pull request?
Fixes current failures in dev/lint-java
## How was this patch tested?
Existing linter, tests.
Author: Sean Owen <so...@cloudera.com>
Closes #18757 from srowen/LintJava.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/63d168cb
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/63d168cb
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/63d168cb
Branch: refs/heads/master
Commit: 63d168cbb8ebe80bfcf91a4d5070f1d9f3ec7aca
Parents: a5a3189
Author: Sean Owen <so...@cloudera.com>
Authored: Fri Jul 28 11:31:40 2017 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Fri Jul 28 11:31:40 2017 +0100
----------------------------------------------------------------------
.../org/apache/spark/network/TransportRequestHandlerSuite.java | 6 ++++--
.../org/apache/spark/shuffle/sort/ShuffleExternalSorter.java | 6 ++++--
.../spark/sql/execution/vectorized/ArrowColumnVector.java | 2 +-
3 files changed, 9 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/63d168cb/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java
----------------------------------------------------------------------
diff --git a/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java b/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java
index 1fb987a..1ed5711 100644
--- a/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java
+++ b/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java
@@ -105,7 +105,7 @@ public class TransportRequestHandlerSuite {
private List<GenericFutureListener> listeners = new ArrayList<>();
private boolean success;
- public ExtendedChannelPromise(Channel channel) {
+ ExtendedChannelPromise(Channel channel) {
super(channel);
success = false;
}
@@ -127,7 +127,9 @@ public class TransportRequestHandlerSuite {
listeners.forEach(listener -> {
try {
listener.operationComplete(this);
- } catch (Exception e) { }
+ } catch (Exception e) {
+ // do nothing
+ }
});
}
}
http://git-wip-us.apache.org/repos/asf/spark/blob/63d168cb/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java b/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java
index 338faaa..da6c55d 100644
--- a/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java
+++ b/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java
@@ -120,14 +120,16 @@ final class ShuffleExternalSorter extends MemoryConsumer {
this.taskContext = taskContext;
this.numPartitions = numPartitions;
// Use getSizeAsKb (not bytes) to maintain backwards compatibility if no units are provided
- this.fileBufferSizeBytes = (int) (long) conf.get(package$.MODULE$.SHUFFLE_FILE_BUFFER_SIZE()) * 1024;
+ this.fileBufferSizeBytes =
+ (int) (long) conf.get(package$.MODULE$.SHUFFLE_FILE_BUFFER_SIZE()) * 1024;
this.numElementsForSpillThreshold =
conf.getLong("spark.shuffle.spill.numElementsForceSpillThreshold", 1024 * 1024 * 1024);
this.writeMetrics = writeMetrics;
this.inMemSorter = new ShuffleInMemorySorter(
this, initialSize, conf.getBoolean("spark.shuffle.sort.useRadixSort", true));
this.peakMemoryUsedBytes = getMemoryUsage();
- this.diskWriteBufferSize = (int) (long) conf.get(package$.MODULE$.SHUFFLE_DISK_WRITE_BUFFER_SIZE());
+ this.diskWriteBufferSize =
+ (int) (long) conf.get(package$.MODULE$.SHUFFLE_DISK_WRITE_BUFFER_SIZE());
}
/**
http://git-wip-us.apache.org/repos/asf/spark/blob/63d168cb/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java
----------------------------------------------------------------------
diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java
index 31dea6a..59d66c5 100644
--- a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java
+++ b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java
@@ -322,7 +322,7 @@ public final class ArrowColumnVector extends ReadOnlyColumnVector {
anyNullsSet = numNulls > 0;
}
- private static abstract class ArrowVectorAccessor {
+ private abstract static class ArrowVectorAccessor {
private final ValueVector vector;
private final ValueVector.Accessor nulls;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org