Refactor: Update MetaClient import and remove parallelism setting in …

…AddWorkerNodeRequest Signed-off-by: Shanicky Chen <[email protected]>
risingwavelabs · Nov 4, 2024 · 5a7017a · 5a7017a
1 parent c7ffdf6
commit 5a7017a
Showing 1 changed file with 1 addition and 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
@@ -29,7 +29,7 @@
 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.Common.WorkerNode.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);