From 014d8eedbac9e8fc65c18f303a1b19068e4425fc Mon Sep 17 00:00:00 2001
From: streamnativebot <streamnativebot@streamnative.io>
Date: Mon, 11 Nov 2024 04:50:07 +0000
Subject: [PATCH] "Created by snbot"

---
 docs/lakehouse-sink.md   | 18 ++++----
 docs/lakehouse-source.md | 10 ++---
 image/Dockerfile         |  2 +-
 pom.xml                  | 92 ++++++++++++----------------------------
 4 files changed, 43 insertions(+), 79 deletions(-)

diff --git a/docs/lakehouse-sink.md b/docs/lakehouse-sink.md
index fbcc04f..0d31a2b 100644
--- a/docs/lakehouse-sink.md
+++ b/docs/lakehouse-sink.md
@@ -42,7 +42,7 @@ To build the Lakehouse sink connector from the source code, follow these steps.
 
    ```bash
    ls target
-   pulsar-io-lakehouse-{{connector:version}}.nar
+   pulsar-io-lakehouse-4.0.0.4.nar
    ```
 
 # How to configure
@@ -127,7 +127,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-hudi-pulsar"
         ],
-        "archive": "connectors/pulsar-io-hudi-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-hudi-4.0.0.4.nar",
         "processingGuarantees": "EFFECTIVELY_ONCE",
         "parallelism": 1,
         "configs":   {
@@ -151,7 +151,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-hudi-pulsar"
         ],
-        "archive": "connectors/pulsar-io-hudi-{{connector:version}}-cloud.nar",
+        "archive": "connectors/pulsar-io-hudi-4.0.0.4-cloud.nar",
         "parallelism": 1,
         "processingGuarantees": "EFFECTIVELY_ONCE",
         "configs":   {
@@ -179,7 +179,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-iceberg-pulsar"
         ],
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4.nar",
         "processingGuarantees":"EFFECTIVELY_ONCE",
         "configs":{
             "type":"iceberg",
@@ -207,7 +207,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-iceberg-pulsar"
         ],
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}-cloud.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4-cloud.nar",
         "processingGuarantees":"EFFECTIVELY_ONCE",
         "configs":{
             "type":"iceberg",
@@ -238,7 +238,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-delta-pulsar"
         ],
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4.nar",
         "processingGuarantees":"EFFECTIVELY_ONCE",
         "configs":{
             "type":"delta",
@@ -260,7 +260,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "inputs": [
           "test-delta-pulsar"
         ],
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}-cloud.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4-cloud.nar",
         "processingGuarantees":"EFFECTIVELY_ONCE",
         "configs":{
             "type":"delta",
@@ -330,7 +330,7 @@ This example describes how to use the Lakehouse sink connector to fetch data fro
 1. Copy the NAR package to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-lakehouse-{{connector:version}}.nar PULSAR_HOME/connectors/pulsar-io-lakehouse-{{connector:version}}.nar
+    cp pulsar-io-lakehouse-4.0.0.4.nar PULSAR_HOME/connectors/pulsar-io-lakehouse-4.0.0.4.nar
     ```
 
 2. Start Pulsar in standalone mode.
@@ -363,7 +363,7 @@ This example explains how to create a Lakehouse sink connector in an on-premises
 1. Copy the NAR package of the Lakehouse sink connector to the Pulsar connectors directory.
 
     ```bash
-    cp pulsar-io-lakehouse-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-lakehouse-{{connector:version}}.nar
+    cp pulsar-io-lakehouse-4.0.0.4.nar $PULSAR_HOME/connectors/pulsar-io-lakehouse-4.0.0.4.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
diff --git a/docs/lakehouse-source.md b/docs/lakehouse-source.md
index ccf4194..eeaa9bd 100644
--- a/docs/lakehouse-source.md
+++ b/docs/lakehouse-source.md
@@ -42,7 +42,7 @@ To build the Lakehouse source connector from the source code, follow these steps
 
    ```bash
    ls target
-   pulsar-io-lakehouse-{{connector:version}}.nar
+   pulsar-io-lakehouse-4.0.0.4.nar
    ```
 
 # How to configure
@@ -90,7 +90,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "parallelism":1,
         "topicName": "delta_source",
         "processingGuarantees":"ATLEAST_ONCE",
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4.nar",
         "configs":{
             "type":"delta",
             "checkpointInterval": 180,
@@ -115,7 +115,7 @@ You can create a configuration file (JSON or YAML) to set the properties if you
         "parallelism":1,
         "topicName": "delta_source",
         "processingGuarantees":"ATLEAST_ONCE",
-        "archive": "connectors/pulsar-io-lakehouse-{{connector:version}}-cloud.nar",
+        "archive": "connectors/pulsar-io-lakehouse-4.0.0.4-cloud.nar",
         "configs":{
             "type":"delta",
             "checkpointInterval": 180,
@@ -175,7 +175,7 @@ This example describes how to use the Lakehouse source connector to fetch data f
 1. Copy the NAR package to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-lakehouse-{{connector:version}}.nar PULSAR_HOME/connectors/pulsar-io-lakehouse-{{connector:version}}.nar
+    cp pulsar-io-lakehouse-4.0.0.4.nar PULSAR_HOME/connectors/pulsar-io-lakehouse-4.0.0.4.nar
     ```
 
 2. Start Pulsar in standalone mode.
@@ -206,7 +206,7 @@ This example explains how to create a Lakehouse source connector in an on-premis
 1. Copy the NAR package of the Lakehouse source connector to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-lakehouse-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-lakehouse-{{connector:version}}.nar
+    cp pulsar-io-lakehouse-4.0.0.4.nar $PULSAR_HOME/connectors/pulsar-io-lakehouse-4.0.0.4.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
diff --git a/image/Dockerfile b/image/Dockerfile
index de62491..d551b27 100644
--- a/image/Dockerfile
+++ b/image/Dockerfile
@@ -28,7 +28,7 @@ ENV JAVA_HOME=/usr
 # we need to update the download link once the version is updated
 RUN curl -Ls https://github.com/xerial/snappy-java/archive/refs/tags/$SNAPPY_VERSION.tar.gz | tar zxf - && cd snappy-java-$SNAPPY_VERSION && make clean-native native
 
-FROM streamnative/pulsar-functions-java-runner:${PULSAR_VERSION}
+FROM snstage/pulsar-functions-java-runner:${PULSAR_VERSION}
 USER 0
 COPY --from=snappy-java /tmp/libsnappyjava.so /usr/lib/libsnappyjava.so
 # need to configure -Dorg.xerial.snappy.use.systemlib=true in the jvm options to use the system lib
diff --git a/pom.xml b/pom.xml
index 46f6fda..da26e50 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="UTF-8"?>
+<?xml version='1.0' encoding='UTF-8'?>
 <!--
 
     Licensed to the Apache Software Foundation (ASF) under one
@@ -19,23 +19,18 @@
     under the License.
 
 -->
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <parent>
     <groupId>org.apache</groupId>
     <artifactId>apache</artifactId>
     <version>18</version>
   </parent>
-
   <modelVersion>4.0.0</modelVersion>
-
   <groupId>org.apache.pulsar.ecosystem</groupId>
   <artifactId>pulsar-io-lakehouse</artifactId>
-  <version>4.0.0-SNAPSHOT</version>
+  <version>4.0.0.4</version>
   <name>Pulsar Ecosystem :: IO Connector :: Lake House</name>
   <description>It is a lakehouse connector streaming convert data between lakehouse and Apache Pulsar.</description>
-
   <properties>
     <maven.compiler.source>8</maven.compiler.source>
     <maven.compiler.target>8</maven.compiler.target>
@@ -45,11 +40,10 @@
     <redirectTestOutputToFile>true</redirectTestOutputToFile>
     <spotbugs-annotations.version>4.2.2</spotbugs-annotations.version>
     <testRetryCount>0</testRetryCount>
-
     <!-- connector dependencies -->
     <jackson.version>2.13.2.1</jackson.version>
     <lombok.version>1.18.22</lombok.version>
-    <pulsar.version>2.10.0.4</pulsar.version>
+    <pulsar.version>4.0.0.4</pulsar.version>
     <log4j2.version>2.17.2</log4j2.version>
     <slf4j.version>1.7.25</slf4j.version>
     <hadoop.version>3.2.4</hadoop.version>
@@ -63,12 +57,10 @@
     <gcs.version>hadoop3-2.2.1</gcs.version>
     <curator.version>2.12.0</curator.version>
     <snappy.java.version>1.1.8.4</snappy.java.version>
-
     <!-- test dependencies -->
     <testng.version>7.3.0</testng.version>
     <awaitility.version>4.0.3</awaitility.version>
     <mockito.version>3.12.4</mockito.version>
-
     <!-- build plugin dependencies -->
     <license.plugin.version>3.0</license.plugin.version>
     <maven-checkstyle-plugin.version>3.1.2</maven-checkstyle-plugin.version>
@@ -77,10 +69,9 @@
     <nifi.nar.plugin.version>1.2.0</nifi.nar.plugin.version>
     <puppycrawl.checkstyle.version>8.37</puppycrawl.checkstyle.version>
     <spotbugs-maven-plugin.version>4.2.2</spotbugs-maven-plugin.version>
-    <cloudPkgSuffix></cloudPkgSuffix>
-    <test.additional.args />
+    <cloudPkgSuffix/>
+    <test.additional.args/>
   </properties>
-
   <licenses>
     <license>
       <name>Apache License, Version 2.0</name>
@@ -88,7 +79,6 @@
       <distribution>repo</distribution>
     </license>
   </licenses>
-
   <!-- keep all the dependencies used by all modules here -->
   <dependencyManagement>
     <dependencies>
@@ -182,8 +172,6 @@
         <artifactId>log4j-slf4j-impl</artifactId>
         <version>${log4j2.version}</version>
       </dependency>
-
-
       <!-- iceberg dependency -->
       <dependency>
         <groupId>org.apache.iceberg</groupId>
@@ -215,20 +203,17 @@
         <artifactId>iceberg-hive-metastore</artifactId>
         <version>${iceberg.version}</version>
       </dependency>
-
       <!-- delta lake dependency -->
       <dependency>
         <groupId>org.apache.parquet</groupId>
         <artifactId>parquet-avro</artifactId>
         <version>${parquet.avro.version}</version>
       </dependency>
-
       <dependency>
         <groupId>io.delta</groupId>
         <artifactId>delta-standalone_2.12</artifactId>
         <version>${delta.version}</version>
       </dependency>
-
       <dependency>
         <groupId>org.apache.parquet</groupId>
         <artifactId>parquet-column</artifactId>
@@ -239,7 +224,6 @@
         <artifactId>parquet-hadoop</artifactId>
         <version>${parquet.version}</version>
       </dependency>
-
       <dependency>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-api</artifactId>
@@ -250,13 +234,11 @@
         <artifactId>slf4j-simple</artifactId>
         <version>${slf4j.version}</version>
       </dependency>
-
       <dependency>
         <groupId>org.xerial.snappy</groupId>
         <artifactId>snappy-java</artifactId>
         <version>${snappy.java.version}</version>
       </dependency>
-
       <!--  Hoodie dependencies begin   -->
       <dependency>
         <groupId>org.apache.hudi</groupId>
@@ -270,7 +252,6 @@
         </exclusions>
       </dependency>
       <!--  Hoodie dependencies end    -->
-
       <!-- Cloud dependencies begin -->
       <dependency>
         <groupId>org.apache.hadoop</groupId>
@@ -288,14 +269,12 @@
         <artifactId>aws-java-sdk-bundle</artifactId>
         <version>${aws.sdk.version}</version>
       </dependency>
-
       <dependency>
         <groupId>com.google.cloud.bigdataoss</groupId>
         <artifactId>gcs-connector</artifactId>
         <version>${gcs.version}</version>
         <classifier>shaded</classifier>
       </dependency>
-
       <dependency>
         <groupId>org.apache.hadoop</groupId>
         <artifactId>hadoop-azure</artifactId>
@@ -311,10 +290,7 @@
           </exclusion>
         </exclusions>
       </dependency>
-
       <!-- Cloud dependencies end -->
-
-
       <!-- test dependencies -->
       <dependency>
         <groupId>org.testng</groupId>
@@ -340,13 +316,10 @@
         <version>${mockito.version}</version>
         <scope>test</scope>
       </dependency>
-
     </dependencies>
   </dependencyManagement>
-
   <!-- include the dependencies -->
   <dependencies>
-
     <!-- provided dependencies (available at compilation and test classpaths and *NOT* packaged) -->
     <dependency>
       <groupId>org.projectlombok</groupId>
@@ -358,13 +331,11 @@
       <artifactId>spotbugs-annotations</artifactId>
       <scope>provided</scope>
     </dependency>
-
     <!-- runtime dependencies -->
     <dependency>
       <groupId>io.streamnative</groupId>
       <artifactId>pulsar-io-core</artifactId>
     </dependency>
-
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
@@ -378,37 +349,30 @@
       <groupId>org.apache.hadoop</groupId>
       <artifactId>hadoop-client</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-api</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-core</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-parquet</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-common</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-data</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.iceberg</groupId>
       <artifactId>iceberg-hive-metastore</artifactId>
     </dependency>
-
     <dependency>
       <groupId>io.delta</groupId>
       <artifactId>delta-standalone_2.12</artifactId>
@@ -417,7 +381,6 @@
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-avro</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-column</artifactId>
@@ -426,7 +389,6 @@
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-hadoop</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.slf4j</groupId>
       <artifactId>slf4j-api</artifactId>
@@ -435,12 +397,10 @@
       <groupId>org.slf4j</groupId>
       <artifactId>slf4j-simple</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.xerial.snappy</groupId>
       <artifactId>snappy-java</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
@@ -461,12 +421,10 @@
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
     </dependency>
-
     <dependency>
       <groupId>io.netty</groupId>
       <artifactId>netty-common</artifactId>
     </dependency>
-
     <dependency>
       <groupId>org.apache.hudi</groupId>
       <artifactId>hudi-java-client</artifactId>
@@ -485,7 +443,6 @@
         </exclusion>
       </exclusions>
     </dependency>
-
     <dependency>
       <groupId>org.apache.curator</groupId>
       <artifactId>curator-framework</artifactId>
@@ -497,7 +454,6 @@
         </exclusion>
       </exclusions>
     </dependency>
-
     <dependency>
       <groupId>org.apache.hudi</groupId>
       <artifactId>hudi-client-common</artifactId>
@@ -511,7 +467,6 @@
         </exclusion>
       </exclusions>
     </dependency>
-
     <!-- test dependencies -->
     <dependency>
       <groupId>org.testng</groupId>
@@ -529,7 +484,6 @@
       <scope>test</scope>
     </dependency>
   </dependencies>
-
   <profiles>
     <profile>
       <id>cloud</id>
@@ -553,13 +507,11 @@
           <groupId>com.amazonaws</groupId>
           <artifactId>aws-java-sdk-bundle</artifactId>
         </dependency>
-
         <dependency>
           <groupId>com.google.cloud.bigdataoss</groupId>
           <artifactId>gcs-connector</artifactId>
           <classifier>shaded</classifier>
         </dependency>
-
         <dependency>
           <groupId>org.apache.hadoop</groupId>
           <artifactId>hadoop-azure</artifactId>
@@ -597,7 +549,6 @@
       </properties>
     </profile>
   </profiles>
-
   <build>
     <finalName>${project.artifactId}-${project.version}${cloudPkgSuffix}</finalName>
     <pluginManagement>
@@ -613,7 +564,7 @@
               <compilerArg>-Xlint:unchecked</compilerArg>
               <!-- https://issues.apache.org/jira/browse/MCOMPILER-205 -->
               <compilerArg>-Xpkginfo:always</compilerArg>
-	        </compilerArgs>
+            </compilerArgs>
           </configuration>
         </plugin>
         <!-- test -->
@@ -725,38 +676,32 @@
         </plugin>
       </plugins>
     </pluginManagement>
-
     <plugins>
-      <!-- compile --> 
+      <!-- compile -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-compiler-plugin</artifactId>
       </plugin>
-
       <!-- test -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-surefire-plugin</artifactId>
       </plugin>
-
       <!-- package -->
       <plugin>
         <groupId>org.apache.nifi</groupId>
         <artifactId>nifi-nar-maven-plugin</artifactId>
       </plugin>
-
       <!-- license -->
       <plugin>
         <groupId>com.mycila</groupId>
         <artifactId>license-maven-plugin</artifactId>
       </plugin>
-
       <!-- checkstyle -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-checkstyle-plugin</artifactId>
       </plugin>
-
       <!-- spotbugs -->
       <plugin>
         <groupId>com.github.spotbugs</groupId>
@@ -764,5 +709,24 @@
       </plugin>
     </plugins>
   </build>
-
+  <repositories>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-3429/content</url>
+    </repository>
+    <repository>
+      <id>nexus-snapshot</id>
+      <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
+    </repository>
+  </repositories>
+  <distributionManagement>
+    <snapshotRepository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
+    </snapshotRepository>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+    </repository>
+  </distributionManagement>
 </project>