diff --git a/Cargo.lock b/Cargo.lock
index 00e3d85442..b28b085798 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -6097,7 +6097,7 @@ dependencies = [
 [[package]]
 name = "greptime-proto"
 version = "0.1.0"
-source = "git+https://github.com/GreptimeTeam/greptime-proto.git?rev=32f467fa2ba2b3588a58381a24af83de09fbb00a#32f467fa2ba2b3588a58381a24af83de09fbb00a"
+source = "git+https://github.com/GreptimeTeam/greptime-proto.git?rev=4b6057ba34b8aaf06221585199ace5002b2af92b#4b6057ba34b8aaf06221585199ace5002b2af92b"
 dependencies = [
  "prost 0.14.1",
  "prost-types 0.14.1",
diff --git a/Cargo.toml b/Cargo.toml
index 55181077f8..f5d5e6721a 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -159,7 +159,7 @@ fs2 = "0.4"
 fst = "0.4.7"
 futures = "0.3"
 futures-util = "0.3"
-greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", rev = "32f467fa2ba2b3588a58381a24af83de09fbb00a" }
+greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", rev = "4b6057ba34b8aaf06221585199ace5002b2af92b" }
 hex = "0.4"
 hostname = "0.4.0"
 http = "1"
diff --git a/src/flow/src/server.rs b/src/flow/src/server.rs
index 9bda516f24..1b26fbbf15 100644
--- a/src/flow/src/server.rs
+++ b/src/flow/src/server.rs
@@ -124,6 +124,7 @@ impl flow_server::Flow for FlowService {
                     api::v1::region::InsertRequest {
                         region_id: insert.region_id,
                         rows: insert.rows,
+                        skip_wal: false,
                         partition_expr_version: insert.partition_expr_version,
                     }
                 })
diff --git a/src/operator/src/req_convert/common/partitioner.rs b/src/operator/src/req_convert/common/partitioner.rs
index b52a6f6be6..513f2ff030 100644
--- a/src/operator/src/req_convert/common/partitioner.rs
+++ b/src/operator/src/req_convert/common/partitioner.rs
@@ -44,6 +44,7 @@ impl<'a> Partitioner<'a> {
             .into_iter()
             .map(
                 |(region_number, (rows, partition_expr_version))| InsertRequest {
+                    skip_wal: false,
                     region_id: RegionId::new(table_id, region_number).into(),
                     rows: Some(rows),
                     partition_expr_version: partition_expr_version
diff --git a/src/operator/src/req_convert/insert/table_to_region.rs b/src/operator/src/req_convert/insert/table_to_region.rs
index a89b4d6204..2cddea1b2d 100644
--- a/src/operator/src/req_convert/insert/table_to_region.rs
+++ b/src/operator/src/req_convert/insert/table_to_region.rs
@@ -160,6 +160,7 @@ mod tests {
         version: Option<u64>,
     ) -> RegionInsertRequest {
         RegionInsertRequest {
+            skip_wal: false,
             region_id,
             rows: Some(Rows {
                 schema: vec![tag_column_schema("a", ColumnDataType::Int32)],