You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by zh...@apache.org on 2022/12/29 07:45:45 UTC
[incubator-celeborn] branch branch-0.2 updated: [CELEBORN-178][BUG] Default registered flag should be false, not null (#1123)
This is an automated email from the ASF dual-hosted git repository.
zhouky pushed a commit to branch branch-0.2
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/branch-0.2 by this push:
new 9951e9b7 [CELEBORN-178][BUG] Default registered flag should be false, not null (#1123)
9951e9b7 is described below
commit 9951e9b79f836d5db2322ca808b044fa4cecf9df
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Thu Dec 29 15:24:09 2022 +0800
[CELEBORN-178][BUG] Default registered flag should be false, not null (#1123)
---
.../scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala | 2 +-
.../org/apache/celeborn/service/deploy/worker/PushDataHandler.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala
index 0fa0e51b..62b846de 100644
--- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala
+++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala
@@ -42,7 +42,7 @@ class FetchHandler(val conf: TransportConf) extends BaseMessageHandler with Logg
var rpcSource: RPCSource = _
var storageManager: StorageManager = _
var partitionsSorter: PartitionFilesSorter = _
- var registered: AtomicBoolean = _
+ var registered: AtomicBoolean = new AtomicBoolean(false)
def init(worker: Worker): Unit = {
this.workerSource = worker.workerSource
diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
index a35b40f1..e9036879 100644
--- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
+++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
@@ -50,7 +50,7 @@ class PushDataHandler extends BaseMessageHandler with Logging {
var replicateThreadPool: ThreadPoolExecutor = _
var unavailablePeers: ConcurrentHashMap[WorkerInfo, Long] = _
var pushClientFactory: TransportClientFactory = _
- var registered: AtomicBoolean = _
+ var registered: AtomicBoolean = new AtomicBoolean(false)
var workerInfo: WorkerInfo = _
var diskReserveSize: Long = _
var partitionSplitMinimumSize: Long = _