ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[MINOR][BUILD] Fix Java Linter LineLength errors

Browse source 
## 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 <dongjoon@apache.org>

Closes #14255 from dongjoon-hyun/minor_java_linter.
This commit is contained in:
Dongjoon Hyun 2016-07-19 11:51:43 +01:00 committed by Sean Owen
parent 6ee40d2cc5
commit 556a9437ac
3 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java
View file

@ -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);

2
common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
View file

@ -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

6
examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
View file

@ -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$
}