Skip to content

Commit 631bc67

Browse files
committed
fix
1 parent bddb3a0 commit 631bc67

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java

+8-1
Original file line numberDiff line numberDiff line change
@@ -310,7 +310,14 @@ public void updateRegisterWorkerMeta(
310310
Map<String, DiskInfo> disks) {
311311
WorkerInfo workerInfo =
312312
new WorkerInfo(
313-
host, rpcPort, pushPort, fetchPort, replicatePort, internalPort, disks, null);
313+
host,
314+
rpcPort,
315+
pushPort,
316+
fetchPort,
317+
replicatePort,
318+
internalPort,
319+
disks,
320+
new HashMap<>());
314321
workerInfo.lastHeartbeat_$eq(System.currentTimeMillis());
315322
if (networkLocation != null
316323
&& !networkLocation.isEmpty()

0 commit comments

Comments
 (0)