From 5987352de5748719707feb472ff406a263d91aac Mon Sep 17 00:00:00 2001
From: StrikeW <wangsiyuanse@gmail.com>
Date: Sun, 18 Feb 2024 15:55:43 +0800
Subject: [PATCH] throw error

---
 src/connector/src/parser/unified/debezium.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/connector/src/parser/unified/debezium.rs b/src/connector/src/parser/unified/debezium.rs
index 5a54a550e816d..589fdfc8cfc45 100644
--- a/src/connector/src/parser/unified/debezium.rs
+++ b/src/connector/src/parser/unified/debezium.rs
@@ -261,7 +261,7 @@ where
                     Err(AccessError::Undefined {
                         name: "_id".to_string(),
                         path: path[0].to_string(),
-                    })
+                    })?
                 }
             }
             ["after" | "before", "payload"] => self.access(&[path[0]], Some(&DataType::Jsonb)),
@@ -282,7 +282,7 @@ where
                         Err(AccessError::Undefined {
                             name: "_id".to_string(),
                             path: "id".to_string(),
-                        })
+                        })?
                     }
                 } else {
                     ret