diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-01-31 21:52:52 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-31 21:52:52 -0800 |
| commit | 39ab83e9577a5449fb0d6ef944dffc0d7cd00b4a (patch) | |
| tree | 4b21295a666e66b82c8e5c4fd47aecac8aaa6efc | |
| parent | c33f0ef41a1865de2bae01b52b860650d3734da4 (diff) | |
| download | spark-39ab83e9577a5449fb0d6ef944dffc0d7cd00b4a.tar.gz spark-39ab83e9577a5449fb0d6ef944dffc0d7cd00b4a.tar.bz2 spark-39ab83e9577a5449fb0d6ef944dffc0d7cd00b4a.zip | |
Small fix from last commit
| -rw-r--r-- | core/src/main/scala/spark/api/python/PythonRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/api/python/PythonRDD.scala b/core/src/main/scala/spark/api/python/PythonRDD.scala index 23e3149248..39758e94f4 100644 --- a/core/src/main/scala/spark/api/python/PythonRDD.scala +++ b/core/src/main/scala/spark/api/python/PythonRDD.scala @@ -122,8 +122,8 @@ private[spark] class PythonRDD[T: ClassManifest]( val update = new Array[Byte](len2) stream.readFully(update) accumulator += Collections.singletonList(update) - new Array[Byte](0) } + new Array[Byte](0) } } catch { case eof: EOFException => { |