diff options
| author | Henry Saputra <henry@platfora.com> | 2013-11-19 16:56:23 -0800 |
|---|---|---|
| committer | Henry Saputra <henry@platfora.com> | 2013-11-19 16:56:23 -0800 |
| commit | 10be58f251b5e883295bd46383c0a9758555f8fc (patch) | |
| tree | 46b8272e427797b055971ac1fd480c8d06fa3867 /streaming | |
| parent | 9c934b640f76b17097f2cae87fef30b05ce854b7 (diff) | |
| download | spark-10be58f251b5e883295bd46383c0a9758555f8fc.tar.gz spark-10be58f251b5e883295bd46383c0a9758555f8fc.tar.bz2 spark-10be58f251b5e883295bd46383c0a9758555f8fc.zip | |
Another set of changes to remove unnecessary semicolon (;) from Scala code.
Passed the sbt/sbt compile and test
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala b/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala index 78a2c07204..9271914eb5 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala @@ -124,7 +124,9 @@ class CheckpointWriter(checkpointDir: String) extends Logging { def stop() { synchronized { - if (stopped) return ; + if (stopped) { + return + } stopped = true } executor.shutdown() |