From 0ce42c71d91f33f8f7e420373663cb9d8e9167ef Mon Sep 17 00:00:00 2001 From: nikhil-ctds Date: Wed, 9 Apr 2025 11:52:14 +0530 Subject: [PATCH 1/3] Update parquet.version to 1.15.1 --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index cf789bb3..6e4bea6c 100644 --- a/pom.xml +++ b/pom.xml @@ -49,7 +49,7 @@ 2.13.4.1 1.18.20 2.9.0-rc-202110221101 - 1.12.2 + 1.15.1 1.12.148 2.16.1 2.3.1 From aed58d41c7af8d8c5c7afef1896670b9feb2a820 Mon Sep 17 00:00:00 2001 From: nikhil-ctds Date: Wed, 9 Apr 2025 13:27:07 +0530 Subject: [PATCH 2/3] Change docker-image from streamnative/pulsar to apachepulsar/pulsar --- .../java/org/apache/pulsar/io/jcloud/PulsarTestBase.java | 2 +- .../apache/pulsar/io/jcloud/container/PulsarContainer.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java b/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java index 1c8ec760..2048a150 100644 --- a/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java +++ b/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java @@ -75,7 +75,7 @@ public static void prepare() throws Exception { log.info("-------------------------------------------------------------------------"); - final String pulsarImage = System.getProperty("pulsar.systemtest.image", "streamnative/pulsar:2.9.2.13"); + final String pulsarImage = System.getProperty("pulsar.systemtest.image", "apachepulsar/pulsar:latest"); pulsarService = new PulsarContainer(DockerImageName.parse(pulsarImage)); pulsarService.waitingFor(new HttpWaitStrategy() .forPort(BROKER_HTTP_PORT) diff --git a/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java b/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java index 31804099..4c67b6fb 100644 --- a/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java +++ b/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java @@ -32,9 +32,9 @@ public class PulsarContainer extends GenericContainer { public static final int BROKER_HTTP_PORT = 8080; public static final String METRICS_ENDPOINT = "/metrics"; - private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("streamnative/pulsar"); + private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("apachepulsar/pulsar"); @Deprecated - private static final String DEFAULT_TAG = "2.8.1.6"; + private static final String DEFAULT_TAG = "latest"; private boolean functionsWorkerEnabled = false; @@ -57,7 +57,7 @@ public PulsarContainer(String pulsarVersion) { public PulsarContainer(final DockerImageName dockerImageName) { super(dockerImageName); - dockerImageName.assertCompatibleWith(DockerImageName.parse("streamnative/pulsar")); + dockerImageName.assertCompatibleWith(DockerImageName.parse("apachepulsar/pulsar")); withExposedPorts(BROKER_PORT, BROKER_HTTP_PORT); withCommand("/pulsar/bin/pulsar", "standalone", "--no-functions-worker", "-nss"); From ebb3cd58d0603306ebbec612e429b2411a03bfda Mon Sep 17 00:00:00 2001 From: nikhil-ctds Date: Fri, 18 Apr 2025 17:55:31 +0530 Subject: [PATCH 3/3] Set hardcoded values to docker image tag --- src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java | 2 +- .../org/apache/pulsar/io/jcloud/container/PulsarContainer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java b/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java index 2048a150..40d1c869 100644 --- a/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java +++ b/src/test/java/org/apache/pulsar/io/jcloud/PulsarTestBase.java @@ -75,7 +75,7 @@ public static void prepare() throws Exception { log.info("-------------------------------------------------------------------------"); - final String pulsarImage = System.getProperty("pulsar.systemtest.image", "apachepulsar/pulsar:latest"); + final String pulsarImage = System.getProperty("pulsar.systemtest.image", "apachepulsar/pulsar:2.9.2"); pulsarService = new PulsarContainer(DockerImageName.parse(pulsarImage)); pulsarService.waitingFor(new HttpWaitStrategy() .forPort(BROKER_HTTP_PORT) diff --git a/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java b/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java index 4c67b6fb..dd3a6be4 100644 --- a/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java +++ b/src/test/java/org/apache/pulsar/io/jcloud/container/PulsarContainer.java @@ -34,7 +34,7 @@ public class PulsarContainer extends GenericContainer { private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("apachepulsar/pulsar"); @Deprecated - private static final String DEFAULT_TAG = "latest"; + private static final String DEFAULT_TAG = "2.8.1"; private boolean functionsWorkerEnabled = false;