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 2016/07/19 10:51:46 UTC
spark git commit: [MINOR][BUILD] Fix Java Linter `LineLength` errors
Repository: spark
Updated Branches:
refs/heads/master 6ee40d2cc -> 556a9437a
[MINOR][BUILD] Fix Java Linter `LineLength` errors
## What changes were proposed in this pull request?
This PR fixes four java linter `LineLength` errors. Those are all `LineLength` errors, but we had better remove all java linter errors before release.
## How was this patch tested?
After pass the Jenkins, `./dev/lint-java`.
Author: Dongjoon Hyun <do...@apache.org>
Closes #14255 from dongjoon-hyun/minor_java_linter.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/556a9437
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/556a9437
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/556a9437
Branch: refs/heads/master
Commit: 556a9437ac7b55079f5a8a91e669dcc36ca02696
Parents: 6ee40d2
Author: Dongjoon Hyun <do...@apache.org>
Authored: Tue Jul 19 11:51:43 2016 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Tue Jul 19 11:51:43 2016 +0100
----------------------------------------------------------------------
.../spark/network/shuffle/ExternalShuffleBlockHandler.java | 3 ++-
.../java/org/apache/spark/network/yarn/YarnShuffleService.java | 2 +-
.../apache/spark/examples/sql/JavaSQLDataSourceExample.java | 6 ++++--
3 files changed, 7 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/556a9437/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java
----------------------------------------------------------------------
diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java
index 1cc0fb6..1270cef 100644
--- a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java
+++ b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java
@@ -113,7 +113,8 @@ public class ExternalShuffleBlockHandler extends RpcHandler {
}
} else if (msgObj instanceof RegisterExecutor) {
- final Timer.Context responseDelayContext = metrics.registerExecutorRequestLatencyMillis.time();
+ final Timer.Context responseDelayContext =
+ metrics.registerExecutorRequestLatencyMillis.time();
try {
RegisterExecutor msg = (RegisterExecutor) msgObj;
checkAuth(client, msg.appId);
http://git-wip-us.apache.org/repos/asf/spark/blob/556a9437/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
----------------------------------------------------------------------
diff --git a/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java b/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
index df17dac..22e47ac 100644
--- a/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
+++ b/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
@@ -131,7 +131,7 @@ public class YarnShuffleService extends AuxiliaryService {
try {
// In case this NM was killed while there were running spark applications, we need to restore
- // lost state for the existing executors. We look for an existing file in the NM's local dirs.
+ // lost state for the existing executors. We look for an existing file in the NM's local dirs.
// If we don't find one, then we choose a file to use to save the state next time. Even if
// an application was stopped while the NM was down, we expect yarn to call stopApplication()
// when it comes back
http://git-wip-us.apache.org/repos/asf/spark/blob/556a9437/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java b/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
index 2b94b9f..ec02c8b 100644
--- a/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
+++ b/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
@@ -110,11 +110,13 @@ public class JavaSQLDataSourceExample {
usersDF.select("name", "favorite_color").write().save("namesAndFavColors.parquet");
// $example off:generic_load_save_functions$
// $example on:manual_load_options$
- Dataset<Row> peopleDF = spark.read().format("json").load("examples/src/main/resources/people.json");
+ Dataset<Row> peopleDF =
+ spark.read().format("json").load("examples/src/main/resources/people.json");
peopleDF.select("name", "age").write().format("parquet").save("namesAndAges.parquet");
// $example off:manual_load_options$
// $example on:direct_sql$
- Dataset<Row> sqlDF = spark.sql("SELECT * FROM parquet.`examples/src/main/resources/users.parquet`");
+ Dataset<Row> sqlDF =
+ spark.sql("SELECT * FROM parquet.`examples/src/main/resources/users.parquet`");
// $example off:direct_sql$
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org