use Flink 1.19 consistently throughout example jobs (#86)

Author: hpgrahsl

examples/custom-pipelines-hello-world/README.md

@@ -26,8 +26,8 @@ Run the following to build this example project using [Gradle](https://gradle.or
 
 Set the `job_file_path` property for the pipeline resource in _decodable-resources.yaml_ depending on your chosen build tool:
 
-* `target/custom-pipelines-hello-world-0.1.jar` when using Maven
-* `build/libs/custom-pipelines-hello-world-0.1-all.jar` when using Gradle
+* `target/custom-pipelines-hello-world-0.2.jar` when using Maven
+* `build/libs/custom-pipelines-hello-world-0.2-all.jar` when using Gradle
 
 Deploy the example to Decodable using the CLI:
 

examples/custom-pipelines-hello-world/build.gradle

@@ -16,10 +16,10 @@ group = 'co.decodable.examples'
 version = '0.2'
 
 ext {
-    flinkVersion = '1.20.1'
-    kafkaConnectorVersion = '3.4.0-1.20'
+    flinkVersion = '1.19.2'
+    kafkaConnectorVersion = '3.3.0-1.19'
     log4jVersion = '2.17.1'
-    sdkVersion = '1.20.1-1.0.0.Beta9'
+    sdkVersion = '1.19.2-1.0.0.Beta9'
 }
 
 repositories {

examples/custom-pipelines-hello-world/decodable-resources.yaml

@@ -123,17 +123,17 @@ spec:
     type: JAVA
 
     # When building with Maven
-    job_file_path: target/custom-pipelines-hello-world-0.2.jar
+    # job_file_path: target/custom-pipelines-hello-world-0.2.jar
     # When building with Gradle
-    # job_file_path: build/libs/custom-pipelines-hello-world-0.2-all.jar
+    job_file_path: build/libs/custom-pipelines-hello-world-0.2-all.jar
 
     # When running the DataStream API Job
     entry_class: co.decodable.examples.cpdemo.DataStreamJob
     # When running the Table API Job
     # entry_class: co.decodable.examples.cpdemo.TableAPIJob
 
     properties:
-        flink_version: 1.16-java11
+        flink_version: 1.19-java11
     execution:
       active: true
       task_count: 1

examples/custom-pipelines-hello-world/pom.xml

@@ -25,10 +25,10 @@
 		<scala.binary.version>2.12</scala.binary.version>
 		<maven.compiler.source>${target.java.version}</maven.compiler.source>
 		<maven.compiler.target>${target.java.version}</maven.compiler.target>
-		<decodable.pipeline.sdk.version>1.20.1-1.0.0.Beta9</decodable.pipeline.sdk.version>
-		<flink.kafka.connector.version>3.4.0-1.20</flink.kafka.connector.version>
+		<decodable.pipeline.sdk.version>1.19.2-1.0.0.Beta9</decodable.pipeline.sdk.version>
+		<flink.kafka.connector.version>3.3.0-1.19</flink.kafka.connector.version>
 		<aws.msk.iam.auth.version>1.1.6</aws.msk.iam.auth.version>
-		<flink.version>1.20.1</flink.version>
+		<flink.version>1.19.2</flink.version>
 		<log4j.version>2.17.1</log4j.version>
 	</properties>