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 <dongj...@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 <dongj...@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-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
