spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject [08/10] git commit: Adding small code comment
Date Tue, 21 Jan 2014 08:09:57 GMT
Adding small code comment


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/a917a87e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/a917a87e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/a917a87e

Branch: refs/heads/master
Commit: a917a87e02c5f094f81fa7f9e1702135f440da82
Parents: d46df96
Author: Patrick Wendell <pwendell@gmail.com>
Authored: Mon Jan 20 23:11:45 2014 -0800
Committer: Patrick Wendell <pwendell@gmail.com>
Committed: Mon Jan 20 23:11:45 2014 -0800

----------------------------------------------------------------------
 .../main/scala/org/apache/spark/storage/BlockObjectWriter.scala   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/a917a87e/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala b/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala
index 924ec7c..530712b 100644
--- a/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala
+++ b/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala
@@ -146,7 +146,8 @@ private[spark] class DiskBlockObjectWriter(
 
   override def commit(): Long = {
     if (initialized) {
-      // NOTE: Flush the serializer first and then the compressed/buffered output stream
+      // NOTE: Because Kryo doesn't flush the underlying stream we explicitly flush both
the
+      //       serializer stream and the lower level stream.
       objOut.flush()
       bs.flush()
       val prevPos = lastValidPosition


Mime
View raw message