From 48c90583951b0315da5a5a0756dbfebf0107e818 Mon Sep 17 00:00:00 2001 From: Ajith Date: Thu, 2 Jan 2020 16:21:06 +0530 Subject: [PATCH] Make final --- .../org/apache/spark/network/server/OneForOneStreamManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java b/common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java index ebf2ccff40e46..cf3547a68bffc 100644 --- a/common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java +++ b/common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java @@ -57,7 +57,7 @@ private static class StreamState { int curChunk = 0; // Used to keep track of the number of chunks being transferred and not finished yet. - volatile AtomicLong chunksBeingTransferred = new AtomicLong(0L); + final AtomicLong chunksBeingTransferred = new AtomicLong(0L); StreamState(String appId, Iterator buffers, Channel channel) { this.appId = appId;