Fix:12589 display kensis error details

risingwavelabs · Oct 2, 2023 · 38c9383 · 38c9383
1 parent 6fb7ae5
commit 38c9383
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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())