From d90fae634abddba84553b8b0dc1db2041d410096 Mon Sep 17 00:00:00 2001
From: Shanicky Chen <peng@risingwave-labs.com>
Date: Mon, 4 Nov 2024 15:31:25 +0800
Subject: [PATCH] Refactor: Update MetaClient import and remove parallelism
 setting in AddWorkerNodeRequest

Signed-off-by: Shanicky Chen <peng@risingwave-labs.com>
---
 .../src/main/java/com/risingwave/java/utils/MetaClient.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/java/common-utils/src/main/java/com/risingwave/java/utils/MetaClient.java b/java/common-utils/src/main/java/com/risingwave/java/utils/MetaClient.java
index 28c1383e668f3..75e9324c37e40 100644
--- a/java/common-utils/src/main/java/com/risingwave/java/utils/MetaClient.java
+++ b/java/common-utils/src/main/java/com/risingwave/java/utils/MetaClient.java
@@ -18,6 +18,7 @@
 import com.risingwave.proto.Catalog.Table;
 import com.risingwave.proto.ClusterServiceGrpc.ClusterServiceBlockingStub;
 import com.risingwave.proto.Common.HostAddress;
+import com.risingwave.proto.Common.WorkerNode.Property;
 import com.risingwave.proto.Common.WorkerType;
 import com.risingwave.proto.DdlServiceGrpc.DdlServiceBlockingStub;
 import com.risingwave.proto.DdlServiceOuterClass.GetTableRequest;
@@ -29,7 +30,6 @@
 import com.risingwave.proto.Hummock.UnpinVersionBeforeRequest;
 import com.risingwave.proto.HummockManagerServiceGrpc.HummockManagerServiceBlockingStub;
 import com.risingwave.proto.Meta.AddWorkerNodeRequest;
-import com.risingwave.proto.Meta.AddWorkerNodeRequest.Property;
 import com.risingwave.proto.Meta.AddWorkerNodeResponse;
 import com.risingwave.proto.Meta.HeartbeatRequest;
 import io.grpc.Grpc;
@@ -100,7 +100,6 @@ public MetaClient(String metaAddr, ScheduledExecutorService scheduler) {
                                 Property.newBuilder()
                                         .setIsStreaming(false)
                                         .setIsServing(false)
-                                        .setWorkerNodeParallelism(0)
                                         .build())
                         .build();
         AddWorkerNodeResponse resp = clusterStub.addWorkerNode(req);