diff --git a/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java b/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java
index a800b0f..5e08d39 100644
--- a/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java
+++ b/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java
@@ -17,7 +17,7 @@
 
 package org.apache.rocketmq.factory;
 
-import com.automq.rocketmq.controller.metadata.GrpcControllerClient;
+import com.automq.rocketmq.controller.client.GrpcControllerClient;
 import com.automq.rocketmq.cli.CliClientConfig;
 import org.apache.rocketmq.client.apis.ClientServiceProvider;
 
diff --git a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java
index a91927e..197b444 100644
--- a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java
+++ b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java
@@ -24,7 +24,7 @@
 import apache.rocketmq.controller.v1.MessageType;
 import apache.rocketmq.controller.v1.AcceptTypes;
 import apache.rocketmq.controller.v1.SubscriptionMode;
-import com.automq.rocketmq.controller.metadata.GrpcControllerClient;
+import com.automq.rocketmq.controller.client.GrpcControllerClient;
 import com.automq.rocketmq.cli.CliClientConfig;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionException;