diff --git a/e2e_test/source_inline/kafka/avro/name_strategy.slt b/e2e_test/source_inline/kafka/avro/name_strategy.slt
index f0b49a36ea284..6d3211b03f1d4 100644
--- a/e2e_test/source_inline/kafka/avro/name_strategy.slt
+++ b/e2e_test/source_inline/kafka/avro/name_strategy.slt
@@ -105,7 +105,7 @@ with (
 sleep 2s
 
 
-query II
+query II retry 3 backoff 5s
 SELECT
  * except (rw_key)
 FROM
@@ -121,7 +121,7 @@ NULL id6 NULL NULL NULL NULL NULL NULL NULL -0.01 NULL (abcdefg) NULL NaN
 NULL id7 NULL NULL NULL NULL NULL NULL NULL -0.01 NULL NULL 67e55044-10b1-426f-9247-bb680e5fe0c8 NaN
 
 
-query II
+query II retry 3 backoff 5s
 SELECT
   *
 FROM
@@ -140,7 +140,7 @@ NULL id7 NULL NULL NULL NULL NULL NULL NULL -0.01 NULL NULL 67e55044-10b1-426f-9
 NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL NULL
 
 
-query II
+query II retry 3 backoff 5s
 SELECT
  * except (rw_key)
 FROM
diff --git a/e2e_test/source_inline/kafka/protobuf/opentelemetry.slt b/e2e_test/source_inline/kafka/protobuf/opentelemetry.slt
index f95b840b4054a..11b8f9d4558ac 100644
--- a/e2e_test/source_inline/kafka/protobuf/opentelemetry.slt
+++ b/e2e_test/source_inline/kafka/protobuf/opentelemetry.slt
@@ -27,7 +27,7 @@ flush;
 
 sleep 1s
 
-query T
+query T retry 3 backoff 5s
 select count(*) from opentelemetry_test;
 ----
 1