From 25dac5b1c5f0bfe75e420b0347320bafff939989 Mon Sep 17 00:00:00 2001 From: Lanqing Yang Date: Mon, 2 Oct 2023 20:31:20 -0700 Subject: [PATCH] chore: display AWS kensis error details (#12603) --- 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 c321a4c63fd7..4ed00b88a58b 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())