Skip to content

Commit b462a9e

Browse files
committed
chore: update proto version
1 parent 1ca4f6a commit b462a9e

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ etcd-client = "0.14"
130130
fst = "0.4.7"
131131
futures = "0.3"
132132
futures-util = "0.3"
133-
greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", rev = "31bdd4b7fef8acc3bc09ab95073792672bc2441d" }
133+
greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", rev = "583daa3fbbbe39c90b7b92d13646bc3291d9c941" }
134134
hex = "0.4"
135135
http = "1"
136136
humantime = "2.1"

src/store-api/src/region_request.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -331,10 +331,10 @@ fn make_region_bulk_inserts(
331331

332332
for req in requests.requests {
333333
let region_id = req.region_id;
334-
match req.r#type() {
334+
match req.payload_type() {
335335
api::v1::region::BulkInsertType::ArrowIpc => {
336336
// todo(hl): use StreamReader instead
337-
let reader = FileReader::try_new(Cursor::new(req.body), None)
337+
let reader = FileReader::try_new(Cursor::new(req.payload), None)
338338
.context(DecodeArrowIpcSnafu)?;
339339
let record_batches = reader
340340
.map(|b| b.map(BulkInsertPayload::ArrowIpc))

0 commit comments

Comments
 (0)