Skip to content

Commit 08a6068

Browse files
committed
Fix stream reference
1 parent fe5b93f commit 08a6068

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/shuffle/ShufflePartitionPairsWriter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ private[spark] class ShufflePartitionPairsWriter(
6161
try {
6262
partitionStream = partitionWriter.openStream
6363
timeTrackingStream = new TimeTrackingOutputStream(writeMetrics, partitionStream)
64-
wrappedStream = serializerManager.wrapStream(blockId, partitionStream)
64+
wrappedStream = serializerManager.wrapStream(blockId, timeTrackingStream)
6565
objOut = serializerInstance.serializeStream(wrappedStream)
6666
} catch {
6767
case e: Exception =>

0 commit comments

Comments
 (0)