Downgrade Flink to 1.16 (#51)

* Downgrade Flink to 1.16

* Downgrade Flink runtime to 1.16

Author: ryannedolan

gradle/libs.versions.toml

@@ -3,19 +3,18 @@ assertj = "org.assertj:assertj-core:3.12.0"
 avro = "org.apache.avro:avro:1.10.2"
 calciteAvatica = "org.apache.calcite.avatica:avatica:1.23.0"
 calciteCore = "org.apache.calcite:calcite-core:1.34.0"
-flinkClients = "org.apache.flink:flink-clients:1.17.0"
-flinkConnectorBase = "org.apache.flink:flink-connector-base:1.17.0"
-flinkCore = "org.apache.flink:flink-core:1.17.0"
-flinkCsv = "org.apache.flink:flink-csv:1.17.0"
-flinkStreamingJava = "org.apache.flink:flink-streaming-java:1.17.0"
-flinkTableApiJava = "org.apache.flink:flink-table-api-java:1.17.0"
-flinkTableApiJavaBridge = "org.apache.flink:flink-table-api-java-bridge:1.17.0"
-flinkTableCommon = "org.apache.flink:flink-table-common:1.17.0"
-flinkTablePlanner = "org.apache.flink:flink-table-planner_2.12:1.17.0"
-flinkTableRuntime = "org.apache.flink:flink-table-runtime:1.17.0"
-flinkShadedForceShading = "org.apache.flink:flink-shaded-force-shading:17.0"
-flinkMetricsDropwizard = "org.apache.flink:flink-metrics-dropwizard:1.17.0"
-flinkConnectorKafka = "org.apache.flink:flink-sql-connector-kafka:1.17.0"
+flinkClients = "org.apache.flink:flink-clients:1.16.2"
+flinkConnectorBase = "org.apache.flink:flink-connector-base:1.16.2"
+flinkCore = "org.apache.flink:flink-core:1.16.2"
+flinkCsv = "org.apache.flink:flink-csv:1.16.2"
+flinkStreamingJava = "org.apache.flink:flink-streaming-java:1.16.2"
+flinkTableApiJava = "org.apache.flink:flink-table-api-java:1.16.2"
+flinkTableApiJavaBridge = "org.apache.flink:flink-table-api-java-bridge:1.16.2"
+flinkTableCommon = "org.apache.flink:flink-table-common:1.16.2"
+flinkTablePlanner = "org.apache.flink:flink-table-planner_2.12:1.16.2"
+flinkTableRuntime = "org.apache.flink:flink-table-runtime:1.16.2"
+flinkMetricsDropwizard = "org.apache.flink:flink-metrics-dropwizard:1.16.2"
+flinkConnectorKafka = "org.apache.flink:flink-sql-connector-kafka:1.16.2"
 flinkConnectorMySqlCdc = "com.ververica:flink-sql-connector-mysql-cdc:2.3.0"
 gson = "com.google.code.gson:gson:2.9.0"
 jackson = "com.fasterxml.jackson.core:jackson-core:2.14.1"

hoptimator-flink-runner/Dockerfile

@@ -1,2 +1,2 @@
-FROM flink:1.17
+FROM flink:1.16
 COPY ./build/libs/hoptimator-flink-runner-all.jar /opt/hoptimator-flink-runner.jar