diff --git a/ingester-protocol/pom.xml b/ingester-protocol/pom.xml
index 653cfe3..1a29458 100644
--- a/ingester-protocol/pom.xml
+++ b/ingester-protocol/pom.xml
@@ -10,7 +10,6 @@
     <artifactId>ingester-protocol</artifactId>
 
     <properties>
-        <arrow.flight.version>10.0.1</arrow.flight.version>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -29,7 +28,7 @@
         <dependency>
             <groupId>io.greptime</groupId>
             <artifactId>greptimedb-proto</artifactId>
-            <version>0.4.2</version>
+            <version>0.4.3</version>
         </dependency>
         <dependency>
             <groupId>com.google.guava</groupId>
diff --git a/ingester-protocol/src/main/java/io/greptime/WriteClient.java b/ingester-protocol/src/main/java/io/greptime/WriteClient.java
index 5511cc3..347253b 100644
--- a/ingester-protocol/src/main/java/io/greptime/WriteClient.java
+++ b/ingester-protocol/src/main/java/io/greptime/WriteClient.java
@@ -164,8 +164,10 @@ private CompletableFuture<Result<WriteOk, Err>> write0(WriteTables writeTables,
     }
 
     private CompletableFuture<Result<WriteOk, Err>> writeTo(Endpoint endpoint, WriteTables writeTables, Context ctx, int retries) {
+        // Some info will be set into the GreptimeDB Request header.
         String database = this.opts.getDatabase();
         AuthInfo authInfo = this.opts.getAuthInfo();
+
         Database.GreptimeRequest req = TableHelper.toGreptimeRequest(writeTables, database, authInfo);
         ctx.with("retries", retries);
 
@@ -211,12 +213,14 @@ public void onCompleted() {
                             }
                         });
 
+        // Some info will be set into the GreptimeDB Request header.
+        String database = this.opts.getDatabase();
+        AuthInfo authInfo = this.opts.getAuthInfo();
+
         return new Observer<WriteTables>() {
 
             @Override
             public void onNext(WriteTables writeTables) {
-                String database = WriteClient.this.opts.getDatabase();
-                AuthInfo authInfo = WriteClient.this.opts.getAuthInfo();
                 Database.GreptimeRequest req = TableHelper.toGreptimeRequest(writeTables, database, authInfo);
                 rpcObserver.onNext(req);
             }