From 5a28cfa00d30ac6dc2259b51bff5d73cf14c1a6c Mon Sep 17 00:00:00 2001 From: manas-ctds Date: Wed, 19 Nov 2025 10:50:14 +0530 Subject: [PATCH 1/4] Update kinesis producer version to 1.0.6 (cherry picked from commit 6a3b447164598c2aa8bbda9df0836d39cca63cfa) --- pulsar-io/kinesis-kpl-shaded/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-io/kinesis-kpl-shaded/pom.xml b/pulsar-io/kinesis-kpl-shaded/pom.xml index 7ce8cdcc6e859..7bf98aba669cb 100644 --- a/pulsar-io/kinesis-kpl-shaded/pom.xml +++ b/pulsar-io/kinesis-kpl-shaded/pom.xml @@ -38,7 +38,7 @@ --> - 1.0.4 + 1.0.6 4.29.0 From 3da49976a069cc0430699a7dcc2616a2b10661e1 Mon Sep 17 00:00:00 2001 From: priyanshu-ctds Date: Mon, 6 Apr 2026 16:56:21 +0530 Subject: [PATCH 2/4] Extended timeout --- .../tests/integration/io/sinks/KinesisSinkTester.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java index 41228f1465fd8..84bc75c77f027 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java @@ -33,6 +33,8 @@ import java.util.List; import java.util.Map; import java.util.Set; +import java.util.concurrent.TimeUnit; + import lombok.AllArgsConstructor; import lombok.Cleanup; import lombok.Data; @@ -188,7 +190,10 @@ public void produceMessage(int numMessages, PulsarClient client, @Override public void validateSinkResult(Map kvs) { - Awaitility.await().untilAsserted(() -> internalValidateSinkResult(kvs)); + Awaitility.await() + .atMost(60, TimeUnit.SECONDS) + .pollInterval(2, TimeUnit.SECONDS) + .untilAsserted(() -> internalValidateSinkResult(kvs)); } @SneakyThrows From 4608cd1577ac00bb4e2bb7b507eb7a04005ef5cd Mon Sep 17 00:00:00 2001 From: priyanshu-ctds Date: Mon, 6 Apr 2026 17:24:24 +0530 Subject: [PATCH 3/4] Fix checkstyle issue --- .../pulsar/tests/integration/io/sinks/KinesisSinkTester.java | 1 - 1 file changed, 1 deletion(-) diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java index 84bc75c77f027..e86cb7b8c27ff 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java @@ -34,7 +34,6 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; - import lombok.AllArgsConstructor; import lombok.Cleanup; import lombok.Data; From bee549a68509b42225f08fcc767534b0583a20bf Mon Sep 17 00:00:00 2001 From: priyanshu-ctds Date: Mon, 6 Apr 2026 19:04:13 +0530 Subject: [PATCH 4/4] Extend timeout --- .../pulsar/tests/integration/io/sinks/KinesisSinkTester.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java index e86cb7b8c27ff..4001bf54af9d8 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java @@ -190,7 +190,7 @@ public void produceMessage(int numMessages, PulsarClient client, @Override public void validateSinkResult(Map kvs) { Awaitility.await() - .atMost(60, TimeUnit.SECONDS) + .atMost(300, TimeUnit.SECONDS) .pollInterval(2, TimeUnit.SECONDS) .untilAsserted(() -> internalValidateSinkResult(kvs)); }