chore(deps): update greptime-proto for insert skip_wal

Signed-off-by: WenyXu <wenymedia@gmail.com>

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",

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"

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,
                     }
                 })

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

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)],