From 3c519d1a8b3b27409dc7700f8cab02cfd8f7d443 Mon Sep 17 00:00:00 2001 From: "Eric.Yang" Date: Mon, 2 Oct 2023 09:03:41 -0700 Subject: [PATCH] Fix:12589 display kensis error details --- src/connector/src/source/kinesis/source/reader.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/connector/src/source/kinesis/source/reader.rs b/src/connector/src/source/kinesis/source/reader.rs index c321a4c63fd7d..d1a9a45461a1c 100644 --- a/src/connector/src/source/kinesis/source/reader.rs +++ b/src/connector/src/source/kinesis/source/reader.rs @@ -250,7 +250,8 @@ impl KinesisSplitReader { .set_starting_sequence_number(starting_seq_num) .set_timestamp(starting_timestamp) .send() - .await?; + .await + .map_err(|e| anyhow!(DisplayErrorContext(e))); if let Some(iter) = resp.shard_iterator() { Ok(iter.to_owned())