diff --git a/flink-container/pom.xml b/flink-container/pom.xml
index ba1e1fa441bb4..ef11da69fce02 100644
--- a/flink-container/pom.xml
+++ b/flink-container/pom.xml
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-container
diff --git a/flink-core-api/pom.xml b/flink-core-api/pom.xml
index 39aab53173585..72438668916a3 100644
--- a/flink-core-api/pom.xml
+++ b/flink-core-api/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-core-api
diff --git a/flink-core/pom.xml b/flink-core/pom.xml
index 1d9ce41e84615..a5e02e946a610 100644
--- a/flink-core/pom.xml
+++ b/flink-core/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-core
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
index 338f9b660dc34..b2442dd003ed2 100755
--- a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
@@ -38,6 +38,7 @@
import java.util.concurrent.ThreadLocalRandom;
import java.util.stream.Collectors;
+import static org.apache.flink.configuration.ConfigConstants.ENV_JAVA_HOME;
import static org.apache.flink.configuration.MetricOptions.SYSTEM_RESOURCE_METRICS;
import static org.apache.flink.configuration.MetricOptions.SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL;
import static org.apache.flink.util.Preconditions.checkArgument;
@@ -622,6 +623,29 @@ public static boolean filterPrefixMapKey(String key, String candidate) {
return candidate.startsWith(prefixKey);
}
+ /**
+ * Set the JAVA_HOME variable in the provided environment map.
+ *
+ * This method follows a specific priority order to determine the JAVA_HOME value:
+ *
+ *
+ * - If the environment map already contains the JAVA_HOME key, the method does nothing.
+ *
- Otherwise, it attempts to retrieve JAVA_HOME from the Flink configuration using {@link
+ * CoreOptions#FLINK_JAVA_HOME}.
+ *
- If it isn't found in configuration, it falls back to the system environment variable.
+ *
- If a value is found through either source, it is added to the environment map.
+ *
+ */
+ public static void setJavaHomeEnv(Configuration configuration, Map env) {
+ if (!env.containsKey(ENV_JAVA_HOME)) {
+ Optional.ofNullable(
+ configuration
+ .getOptional(CoreOptions.FLINK_JAVA_HOME)
+ .orElse(System.getenv(ENV_JAVA_HOME)))
+ .ifPresent(javaHomeStr -> env.put(ENV_JAVA_HOME, javaHomeStr));
+ }
+ }
+
static Map convertToPropertiesPrefixed(
Map confData, String key) {
final String prefixKey = key + ".";
diff --git a/flink-datastream-api/pom.xml b/flink-datastream-api/pom.xml
index 58feae738c37e..aa2813cdef102 100644
--- a/flink-datastream-api/pom.xml
+++ b/flink-datastream-api/pom.xml
@@ -26,7 +26,7 @@ under the License.
flink-parent
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-datastream-api
diff --git a/flink-datastream/pom.xml b/flink-datastream/pom.xml
index ad2d08c15c088..fd6d939a84bb7 100644
--- a/flink-datastream/pom.xml
+++ b/flink-datastream/pom.xml
@@ -26,7 +26,7 @@ under the License.
flink-parent
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-datastream
diff --git a/flink-dist-scala/pom.xml b/flink-dist-scala/pom.xml
index 9cfe210242541..5f82af505fa74 100644
--- a/flink-dist-scala/pom.xml
+++ b/flink-dist-scala/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-dist-scala_${scala.binary.version}
diff --git a/flink-dist/pom.xml b/flink-dist/pom.xml
index 12edc97f8c574..c128dec0fe002 100644
--- a/flink-dist/pom.xml
+++ b/flink-dist/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-dist_${scala.binary.version}
diff --git a/flink-docs/pom.xml b/flink-docs/pom.xml
index a7054d01b5f84..81b814631169f 100644
--- a/flink-docs/pom.xml
+++ b/flink-docs/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-docs
diff --git a/flink-dstl/flink-dstl-dfs/pom.xml b/flink-dstl/flink-dstl-dfs/pom.xml
index dff7892cdf860..169d99d689628 100644
--- a/flink-dstl/flink-dstl-dfs/pom.xml
+++ b/flink-dstl/flink-dstl-dfs/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-dstl
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-dstl-dfs
diff --git a/flink-dstl/pom.xml b/flink-dstl/pom.xml
index c21f695058720..614329365f42e 100644
--- a/flink-dstl/pom.xml
+++ b/flink-dstl/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-dstl
diff --git a/flink-end-to-end-tests/flink-batch-sql-test/pom.xml b/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
index 4ffd2384ab0f5..4a84b83ea0041 100644
--- a/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
+++ b/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
@@ -24,7 +24,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-cli-test/pom.xml b/flink-end-to-end-tests/flink-cli-test/pom.xml
index f4e8afbc7ed58..9f93471386a24 100644
--- a/flink-end-to-end-tests/flink-cli-test/pom.xml
+++ b/flink-end-to-end-tests/flink-cli-test/pom.xml
@@ -24,7 +24,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml b/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
index 598e341783e2c..7b94d5fa25602 100644
--- a/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
+++ b/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml b/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
index fd26c289d0fbc..9599862d1c771 100644
--- a/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
+++ b/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-datastream-allround-test
diff --git a/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml b/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
index db24e822766d7..3178379905bf2 100644
--- a/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
+++ b/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
@@ -24,7 +24,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
@@ -43,7 +43,7 @@
org.apache.flink
flink-connector-files
- 2.0.0
+ 2.0.0.1-4.3.0-0
provided
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
index 6dcb171754562..050dda443628b 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-hive/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-hive/pom.xml
index 2d66ad26e3276..0dd11deee25ce 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-hive/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-hive/pom.xml
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0-SNAPSHOT
+ 2.0.0.1-4.3.0-0
4.0.0
@@ -34,7 +34,7 @@ under the License.
java.lang.NoClassDefFoundError: org/apache/hadoop/metrics/Updater errors
Using this dedicated property avoids CI failures with the Hadoop 3 profile
-->
- 2.10.2
+ 3.4.3.1-4.3.0-1
@@ -51,7 +51,7 @@ under the License.
org.apache.flink
- flink-sql-connector-hive-${hive.version}
+ flink-sql-connector-hive-4.0.0
${project.version}
@@ -148,7 +148,7 @@ under the License.
org.apache.flink
- flink-sql-connector-hive-${hive.version}
+ flink-sql-connector-hive-4.0.0
${project.version}
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-jdbc-driver/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-jdbc-driver/pom.xml
index 40ce5893f8493..f995e71fb3707 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-jdbc-driver/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-jdbc-driver/pom.xml
@@ -26,7 +26,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-end-to-end-tests-jdbc-driver
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-restclient/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-restclient/pom.xml
index c767a360e8dbf..4e9a8417f3b4d 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-restclient/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-restclient/pom.xml
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-scala/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-scala/pom.xml
index 32ef189d27ae4..15e163afc89df 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-scala/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-scala/pom.xml
@@ -21,7 +21,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml
index cf3af9b0d2d17..c9bf1e14f1bf2 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml
@@ -23,7 +23,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-failure-enricher-test/pom.xml b/flink-end-to-end-tests/flink-failure-enricher-test/pom.xml
index c4339b1929f7f..7e67ced0e0e18 100644
--- a/flink-end-to-end-tests/flink-failure-enricher-test/pom.xml
+++ b/flink-end-to-end-tests/flink-failure-enricher-test/pom.xml
@@ -24,7 +24,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xs
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-file-sink-test/pom.xml b/flink-end-to-end-tests/flink-file-sink-test/pom.xml
index ecf742cff4988..ab86afb77012d 100644
--- a/flink-end-to-end-tests/flink-file-sink-test/pom.xml
+++ b/flink-end-to-end-tests/flink-file-sink-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml b/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
index b9a4f9c014bd4..da4673e59f720 100644
--- a/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
+++ b/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-heavy-deployment-stress-test
diff --git a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
index 97cc83ddaefa9..2d51392aba9b8 100644
--- a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
+++ b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml b/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
index 912789f2fc60e..27ace679958eb 100644
--- a/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
+++ b/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml b/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
index 03b859750a057..9efa668c878c1 100644
--- a/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
+++ b/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-netty-shuffle-memory-control-test/pom.xml b/flink-end-to-end-tests/flink-netty-shuffle-memory-control-test/pom.xml
index bec5962647c57..6232918e784bb 100644
--- a/flink-end-to-end-tests/flink-netty-shuffle-memory-control-test/pom.xml
+++ b/flink-end-to-end-tests/flink-netty-shuffle-memory-control-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-netty-shuffle-memory-control-test
diff --git a/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml b/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
index df2f5e037c28e..dda2b2611ad20 100644
--- a/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
+++ b/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
@@ -29,7 +29,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml b/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
index 69534bd2255ac..a1e62108c6201 100644
--- a/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
+++ b/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
@@ -29,7 +29,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-plugins-test/another-dummy-fs/pom.xml b/flink-end-to-end-tests/flink-plugins-test/another-dummy-fs/pom.xml
index 8ca6f8b02261e..38039fd5bdcfb 100644
--- a/flink-end-to-end-tests/flink-plugins-test/another-dummy-fs/pom.xml
+++ b/flink-end-to-end-tests/flink-plugins-test/another-dummy-fs/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-plugins-test
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-plugins-test/dummy-fs/pom.xml b/flink-end-to-end-tests/flink-plugins-test/dummy-fs/pom.xml
index 7da098e59b109..0a17ab0eec72d 100644
--- a/flink-end-to-end-tests/flink-plugins-test/dummy-fs/pom.xml
+++ b/flink-end-to-end-tests/flink-plugins-test/dummy-fs/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-plugins-test
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-plugins-test/pom.xml b/flink-end-to-end-tests/flink-plugins-test/pom.xml
index 5afa4a1265905..87257da7c98ef 100644
--- a/flink-end-to-end-tests/flink-plugins-test/pom.xml
+++ b/flink-end-to-end-tests/flink-plugins-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
pom
diff --git a/flink-end-to-end-tests/flink-python-test/pom.xml b/flink-end-to-end-tests/flink-python-test/pom.xml
index b86f13ec1c205..0b209a3a3b871 100644
--- a/flink-end-to-end-tests/flink-python-test/pom.xml
+++ b/flink-end-to-end-tests/flink-python-test/pom.xml
@@ -23,7 +23,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-queryable-state-test/pom.xml b/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
index 508a21e4394f1..28baaf1268b02 100644
--- a/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
+++ b/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
@@ -23,7 +23,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/pom.xml b/flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/pom.xml
index 429276844489c..d1745f0161b23 100644
--- a/flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/pom.xml
+++ b/flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-quickstart-test/pom.xml b/flink-end-to-end-tests/flink-quickstart-test/pom.xml
index 63415682d953b..b263fdb93d475 100644
--- a/flink-end-to-end-tests/flink-quickstart-test/pom.xml
+++ b/flink-end-to-end-tests/flink-quickstart-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-rocksdb-state-memory-control-test/pom.xml b/flink-end-to-end-tests/flink-rocksdb-state-memory-control-test/pom.xml
index 9d59ff525bd2d..1c14686c1aa7f 100644
--- a/flink-end-to-end-tests/flink-rocksdb-state-memory-control-test/pom.xml
+++ b/flink-end-to-end-tests/flink-rocksdb-state-memory-control-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
index 8a74fc25b787c..4484c6c103abf 100644
--- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml
+++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-sql-gateway-test/pom.xml b/flink-end-to-end-tests/flink-sql-gateway-test/pom.xml
index dc4b63ece0830..0e94e2c605e53 100644
--- a/flink-end-to-end-tests/flink-sql-gateway-test/pom.xml
+++ b/flink-end-to-end-tests/flink-sql-gateway-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0-SNAPSHOT
+ 2.0.0.1-4.3.0-0
4.0.0
@@ -39,7 +39,7 @@ under the License.
org.apache.flink
- flink-sql-connector-hive-${hive.version}
+ flink-sql-connector-hive-4.0.0
${project.version}
@@ -166,11 +166,11 @@ under the License.
org.apache.flink
- flink-sql-connector-hive-${hive.version}
+ flink-sql-connector-hive-4.0.0
${project.version}
- flink-sql-connector-hive-${hive.version}-${project.version}.jar
+ flink-sql-connector-hive-4.0.0-${project.version}.jar
jar
${project.build.directory}/dependencies
diff --git a/flink-end-to-end-tests/flink-state-evolution-test/pom.xml b/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
index 01dfea1532d94..be8a4e3cd54fb 100644
--- a/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
+++ b/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-stream-sql-test/pom.xml b/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
index 37f804d85ab52..bd801a13701d5 100644
--- a/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
@@ -24,7 +24,7 @@
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml b/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
index f24c7494d4183..309071f0a3b18 100644
--- a/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-end-to-end-tests
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-stream-state-ttl-test
diff --git a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
index e0b66624924b3..f31a689ad63b4 100644
--- a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-tpcds-test/pom.xml b/flink-end-to-end-tests/flink-tpcds-test/pom.xml
index d24eb5c6497d5..dcae661db4036 100644
--- a/flink-end-to-end-tests/flink-tpcds-test/pom.xml
+++ b/flink-end-to-end-tests/flink-tpcds-test/pom.xml
@@ -21,7 +21,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/flink-tpch-test/pom.xml b/flink-end-to-end-tests/flink-tpch-test/pom.xml
index a6baa3b90c149..fd78056b84650 100644
--- a/flink-end-to-end-tests/flink-tpch-test/pom.xml
+++ b/flink-end-to-end-tests/flink-tpch-test/pom.xml
@@ -21,7 +21,7 @@ under the License.
flink-end-to-end-tests
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-end-to-end-tests/pom.xml b/flink-end-to-end-tests/pom.xml
index 7da250d39aed8..20b2ffc46618c 100644
--- a/flink-end-to-end-tests/pom.xml
+++ b/flink-end-to-end-tests/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
pom
diff --git a/flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/hadoop/entrypoint.sh b/flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/hadoop/entrypoint.sh
index 02b56ab07139f..8eb023df636a4 100755
--- a/flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/hadoop/entrypoint.sh
+++ b/flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/hadoop/entrypoint.sh
@@ -100,10 +100,6 @@ elif [ "$1" == "master" ]; then
sudo -E jps -v >> /var/log/hadoop/debugging.out
echo "--------------------" >> /var/log/hadoop/debugging.out
nohup sudo -E -u hdfs $HADOOP_PREFIX/bin/hdfs namenode 2>> /var/log/hadoop/namenode.err >> /var/log/hadoop/namenode.out &
- nohup sudo -E -u yarn $HADOOP_PREFIX/bin/yarn resourcemanager 2>> /var/log/hadoop/resourcemanager.err >> /var/log/hadoop/resourcemanager.out &
- nohup sudo -E -u yarn $HADOOP_PREFIX/bin/yarn timelineserver 2>> /var/log/hadoop/timelineserver.err >> /var/log/hadoop/timelineserver.out &
- nohup sudo -E -u mapred $HADOOP_PREFIX/bin/mapred historyserver 2>> /var/log/hadoop/historyserver.err >> /var/log/hadoop/historyserver.out &
-
kadmin -p ${KERBEROS_ADMIN_USER} -w ${KERBEROS_ADMIN_PASSWORD} -q "addprinc -randkey root@${KRB_REALM}"
kadmin -p ${KERBEROS_ADMIN_USER} -w ${KERBEROS_ADMIN_PASSWORD} -q "xst -k /root/root.keytab root"
@@ -130,6 +126,12 @@ elif [ "$1" == "master" ]; then
hdfs dfs -chown hadoop-user:hadoop-user /user/hadoop-user
kdestroy
+
+ # Start YARN services only after HDFS directories are ready
+ nohup sudo -E -u yarn $HADOOP_PREFIX/bin/yarn resourcemanager 2>> /var/log/hadoop/resourcemanager.err >> /var/log/hadoop/resourcemanager.out &
+ nohup sudo -E -u yarn $HADOOP_PREFIX/bin/yarn timelineserver 2>> /var/log/hadoop/timelineserver.err >> /var/log/hadoop/timelineserver.out &
+ nohup sudo -E -u mapred $HADOOP_PREFIX/bin/mapred historyserver 2>> /var/log/hadoop/historyserver.err >> /var/log/hadoop/historyserver.out &
+
echo "Finished master initialization"
while true; do sleep 1000; done
diff --git a/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
index 6a1eacbb61521..80de097f13888 100644
--- a/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
+++ b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
@@ -24,7 +24,7 @@ under the License.
flink-examples-build-helper
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-examples-streaming-state-machine
diff --git a/flink-examples/flink-examples-build-helper/pom.xml b/flink-examples/flink-examples-build-helper/pom.xml
index 03b7644d23569..d7794d626c84a 100644
--- a/flink-examples/flink-examples-build-helper/pom.xml
+++ b/flink-examples/flink-examples-build-helper/pom.xml
@@ -24,7 +24,7 @@ under the License.
flink-examples
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-examples-build-helper
diff --git a/flink-examples/flink-examples-streaming/pom.xml b/flink-examples/flink-examples-streaming/pom.xml
index 4eeb940f9ff07..02973a7dcdb30 100644
--- a/flink-examples/flink-examples-streaming/pom.xml
+++ b/flink-examples/flink-examples-streaming/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-examples
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-examples-streaming
diff --git a/flink-examples/flink-examples-table/pom.xml b/flink-examples/flink-examples-table/pom.xml
index e669b40cc59e1..bc2dcd1ef0351 100644
--- a/flink-examples/flink-examples-table/pom.xml
+++ b/flink-examples/flink-examples-table/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-examples
- 2.0.0
+ 2.0.0.1-4.3.0-0
Flink : Examples : Table
diff --git a/flink-examples/pom.xml b/flink-examples/pom.xml
index 49b86ab6602d6..f4d8891ed0239 100644
--- a/flink-examples/pom.xml
+++ b/flink-examples/pom.xml
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-examples
diff --git a/flink-external-resources/flink-external-resource-gpu/pom.xml b/flink-external-resources/flink-external-resource-gpu/pom.xml
index f6a41c584491c..69d9d7fdccdb9 100644
--- a/flink-external-resources/flink-external-resource-gpu/pom.xml
+++ b/flink-external-resources/flink-external-resource-gpu/pom.xml
@@ -25,7 +25,7 @@ under the License.
flink-external-resources
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-external-resource-gpu
diff --git a/flink-external-resources/pom.xml b/flink-external-resources/pom.xml
index b0169d1969678..1b214d9fc1981 100644
--- a/flink-external-resources/pom.xml
+++ b/flink-external-resources/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-external-resources
diff --git a/flink-filesystems/flink-azure-fs-hadoop/pom.xml b/flink-filesystems/flink-azure-fs-hadoop/pom.xml
index c25596bc07752..7ef0aaffddd60 100644
--- a/flink-filesystems/flink-azure-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-azure-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-azure-fs-hadoop
diff --git a/flink-filesystems/flink-fs-hadoop-shaded/pom.xml b/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
index 6e6a557bd80eb..249aff7ef73c8 100644
--- a/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
+++ b/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-fs-hadoop-shaded
diff --git a/flink-filesystems/flink-gs-fs-hadoop/pom.xml b/flink-filesystems/flink-gs-fs-hadoop/pom.xml
index dbe50a2eba0a5..895f3a516e9c6 100644
--- a/flink-filesystems/flink-gs-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-gs-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-gs-fs-hadoop
diff --git a/flink-filesystems/flink-hadoop-fs/pom.xml b/flink-filesystems/flink-hadoop-fs/pom.xml
index 4306dca791b49..0969e3c7fa95b 100644
--- a/flink-filesystems/flink-hadoop-fs/pom.xml
+++ b/flink-filesystems/flink-hadoop-fs/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-hadoop-fs
diff --git a/flink-filesystems/flink-oss-fs-hadoop/pom.xml b/flink-filesystems/flink-oss-fs-hadoop/pom.xml
index 19e43ddc6f4d4..88856f286d8b4 100644
--- a/flink-filesystems/flink-oss-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-oss-fs-hadoop/pom.xml
@@ -21,7 +21,7 @@ under the License.
flink-filesystems
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-filesystems/flink-s3-fs-base/pom.xml b/flink-filesystems/flink-s3-fs-base/pom.xml
index 6305293dfd998..7c2650fef9e31 100644
--- a/flink-filesystems/flink-s3-fs-base/pom.xml
+++ b/flink-filesystems/flink-s3-fs-base/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-s3-fs-base
diff --git a/flink-filesystems/flink-s3-fs-hadoop/pom.xml b/flink-filesystems/flink-s3-fs-hadoop/pom.xml
index a8fe3f94ab748..ebf447dd15fd2 100644
--- a/flink-filesystems/flink-s3-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-s3-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-s3-fs-hadoop
diff --git a/flink-filesystems/flink-s3-fs-presto/pom.xml b/flink-filesystems/flink-s3-fs-presto/pom.xml
index 103e3eb651a3e..79f10535db35e 100644
--- a/flink-filesystems/flink-s3-fs-presto/pom.xml
+++ b/flink-filesystems/flink-s3-fs-presto/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-filesystems
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-s3-fs-presto
diff --git a/flink-filesystems/pom.xml b/flink-filesystems/pom.xml
index f73b1609455bd..55d8f1bdacbaf 100644
--- a/flink-filesystems/pom.xml
+++ b/flink-filesystems/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-filesystems
diff --git a/flink-formats/flink-avro-confluent-registry/pom.xml b/flink-formats/flink-avro-confluent-registry/pom.xml
index 01ea2d44d9be9..b5e80b9a4daad 100644
--- a/flink-formats/flink-avro-confluent-registry/pom.xml
+++ b/flink-formats/flink-avro-confluent-registry/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-formats
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-formats/flink-avro/pom.xml b/flink-formats/flink-avro/pom.xml
index 959ebddebb1b4..6ca6fc7077a91 100644
--- a/flink-formats/flink-avro/pom.xml
+++ b/flink-formats/flink-avro/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-avro
diff --git a/flink-formats/flink-compress/pom.xml b/flink-formats/flink-compress/pom.xml
index 60a19b4d90b27..c86108c868012 100644
--- a/flink-formats/flink-compress/pom.xml
+++ b/flink-formats/flink-compress/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-compress
diff --git a/flink-formats/flink-csv/pom.xml b/flink-formats/flink-csv/pom.xml
index c93dfc738fed9..5b6be1b392a0d 100644
--- a/flink-formats/flink-csv/pom.xml
+++ b/flink-formats/flink-csv/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-csv
diff --git a/flink-formats/flink-format-common/pom.xml b/flink-formats/flink-format-common/pom.xml
index 5a4fe39dde09d..8666aab59cbe4 100644
--- a/flink-formats/flink-format-common/pom.xml
+++ b/flink-formats/flink-format-common/pom.xml
@@ -22,7 +22,7 @@ under the License.
flink-formats
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
4.0.0
diff --git a/flink-formats/flink-hadoop-bulk/pom.xml b/flink-formats/flink-hadoop-bulk/pom.xml
index 254463c23483b..c2598a5f7f729 100644
--- a/flink-formats/flink-hadoop-bulk/pom.xml
+++ b/flink-formats/flink-hadoop-bulk/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-hadoop-bulk
diff --git a/flink-formats/flink-json/pom.xml b/flink-formats/flink-json/pom.xml
index af4bb1c6ffe7c..392922c233a38 100644
--- a/flink-formats/flink-json/pom.xml
+++ b/flink-formats/flink-json/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-json
diff --git a/flink-formats/flink-orc-nohive/pom.xml b/flink-formats/flink-orc-nohive/pom.xml
index 28a1be6630edb..715707dc7949d 100644
--- a/flink-formats/flink-orc-nohive/pom.xml
+++ b/flink-formats/flink-orc-nohive/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-orc-nohive
diff --git a/flink-formats/flink-orc/pom.xml b/flink-formats/flink-orc/pom.xml
index 803a07aee5cc6..7ca4065506c1e 100644
--- a/flink-formats/flink-orc/pom.xml
+++ b/flink-formats/flink-orc/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-orc
diff --git a/flink-formats/flink-parquet/pom.xml b/flink-formats/flink-parquet/pom.xml
index a87ac284e12be..a40e7e4fd6164 100644
--- a/flink-formats/flink-parquet/pom.xml
+++ b/flink-formats/flink-parquet/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-parquet
diff --git a/flink-formats/flink-protobuf/pom.xml b/flink-formats/flink-protobuf/pom.xml
index 43b739b374c2d..896ba16190eaf 100644
--- a/flink-formats/flink-protobuf/pom.xml
+++ b/flink-formats/flink-protobuf/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-protobuf
diff --git a/flink-formats/flink-sequence-file/pom.xml b/flink-formats/flink-sequence-file/pom.xml
index f05ff410429d3..927fb5113df85 100644
--- a/flink-formats/flink-sequence-file/pom.xml
+++ b/flink-formats/flink-sequence-file/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sequence-file
diff --git a/flink-formats/flink-sql-avro-confluent-registry/pom.xml b/flink-formats/flink-sql-avro-confluent-registry/pom.xml
index d6419651191c6..439472dc458c1 100644
--- a/flink-formats/flink-sql-avro-confluent-registry/pom.xml
+++ b/flink-formats/flink-sql-avro-confluent-registry/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-avro-confluent-registry
diff --git a/flink-formats/flink-sql-avro/pom.xml b/flink-formats/flink-sql-avro/pom.xml
index cdb04cff7bb6b..8d0d680d1ecce 100644
--- a/flink-formats/flink-sql-avro/pom.xml
+++ b/flink-formats/flink-sql-avro/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-avro
diff --git a/flink-formats/flink-sql-csv/pom.xml b/flink-formats/flink-sql-csv/pom.xml
index 677b544f74767..878d434c0d7aa 100644
--- a/flink-formats/flink-sql-csv/pom.xml
+++ b/flink-formats/flink-sql-csv/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-csv
diff --git a/flink-formats/flink-sql-json/pom.xml b/flink-formats/flink-sql-json/pom.xml
index a7264cfc17b6e..8b47a795e1a43 100644
--- a/flink-formats/flink-sql-json/pom.xml
+++ b/flink-formats/flink-sql-json/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-json
diff --git a/flink-formats/flink-sql-orc/pom.xml b/flink-formats/flink-sql-orc/pom.xml
index 61dab2f4f10e4..ffd30bb897d21 100644
--- a/flink-formats/flink-sql-orc/pom.xml
+++ b/flink-formats/flink-sql-orc/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-orc
diff --git a/flink-formats/flink-sql-parquet/pom.xml b/flink-formats/flink-sql-parquet/pom.xml
index d346541f7bf6b..cdf56e9722d42 100644
--- a/flink-formats/flink-sql-parquet/pom.xml
+++ b/flink-formats/flink-sql-parquet/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-parquet
diff --git a/flink-formats/flink-sql-protobuf/pom.xml b/flink-formats/flink-sql-protobuf/pom.xml
index c84a0dd54e7c2..2b2149b07b583 100644
--- a/flink-formats/flink-sql-protobuf/pom.xml
+++ b/flink-formats/flink-sql-protobuf/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-formats
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-protobuf
diff --git a/flink-formats/pom.xml b/flink-formats/pom.xml
index 4b077ef15b109..35d251a57e2e6 100644
--- a/flink-formats/pom.xml
+++ b/flink-formats/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
diff --git a/flink-fs-tests/pom.xml b/flink-fs-tests/pom.xml
index 205909f1fe1e7..95f0c565e6a6e 100644
--- a/flink-fs-tests/pom.xml
+++ b/flink-fs-tests/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-fs-tests
diff --git a/flink-kubernetes/pom.xml b/flink-kubernetes/pom.xml
index 9032a31876e75..f09bbde475cbd 100644
--- a/flink-kubernetes/pom.xml
+++ b/flink-kubernetes/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-kubernetes
diff --git a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/KubernetesTaskManagerTestBase.java b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/KubernetesTaskManagerTestBase.java
index 29710b2ec18e0..3feaac01ccb20 100644
--- a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/KubernetesTaskManagerTestBase.java
+++ b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/KubernetesTaskManagerTestBase.java
@@ -18,6 +18,7 @@
package org.apache.flink.kubernetes.kubeclient;
+import org.apache.flink.configuration.CoreOptions;
import org.apache.flink.configuration.MemorySize;
import org.apache.flink.configuration.ResourceManagerOptions;
import org.apache.flink.configuration.TaskManagerOptions;
@@ -80,6 +81,7 @@ protected void setupFlinkConfig() {
TASK_MANAGER_MEMORY_LIMIT_FACTOR);
this.flinkConfig.set(
KubernetesConfigOptions.KUBERNETES_TASKMANAGER_ENTRYPOINT_ARGS, ENTRYPOINT_ARGS);
+ flinkConfig.set(CoreOptions.FLINK_JAVA_HOME, "/test/jdk");
}
@Override
diff --git a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesTaskManagerFactoryTest.java b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesTaskManagerFactoryTest.java
index 08d7444c2161d..52ff0d86dc9a6 100644
--- a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesTaskManagerFactoryTest.java
+++ b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesTaskManagerFactoryTest.java
@@ -87,7 +87,7 @@ void testContainer() {
assertThat(resultMainContainer.getImagePullPolicy())
.isEqualTo(CONTAINER_IMAGE_PULL_POLICY.name());
- assertThat(resultMainContainer.getEnv()).hasSize(5);
+ assertThat(resultMainContainer.getEnv()).hasSize(6);
assertThat(
resultMainContainer.getEnv().stream()
.anyMatch(envVar -> envVar.getName().equals("key1")))
diff --git a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesTaskManagerParametersTest.java b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesTaskManagerParametersTest.java
index 41d8e5d7dd71b..eaa03561e9661 100644
--- a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesTaskManagerParametersTest.java
+++ b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesTaskManagerParametersTest.java
@@ -105,7 +105,8 @@ protected void onSetup() throws Exception {
@Test
void testGetEnvironments() {
- assertThat(kubernetesTaskManagerParameters.getEnvironments()).isEqualTo(customizedEnvs);
+ assertThat(kubernetesTaskManagerParameters.getEnvironments())
+ .containsAllEntriesOf(customizedEnvs);
}
@Test
diff --git a/flink-libraries/flink-cep/pom.xml b/flink-libraries/flink-cep/pom.xml
index 8e37fd374957d..ba95bb758e46e 100644
--- a/flink-libraries/flink-cep/pom.xml
+++ b/flink-libraries/flink-cep/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-libraries
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-cep
diff --git a/flink-libraries/flink-state-processing-api/pom.xml b/flink-libraries/flink-state-processing-api/pom.xml
index 5de3c544d8921..730656e0763c9 100644
--- a/flink-libraries/flink-state-processing-api/pom.xml
+++ b/flink-libraries/flink-state-processing-api/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-libraries
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-state-processor-api
diff --git a/flink-libraries/pom.xml b/flink-libraries/pom.xml
index 69a3bbaaf3b18..62f05df16ea89 100644
--- a/flink-libraries/pom.xml
+++ b/flink-libraries/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-libraries
diff --git a/flink-metrics/flink-metrics-core/pom.xml b/flink-metrics/flink-metrics-core/pom.xml
index 069c35c480bad..4a813f1fb54a5 100644
--- a/flink-metrics/flink-metrics-core/pom.xml
+++ b/flink-metrics/flink-metrics-core/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-core
diff --git a/flink-metrics/flink-metrics-datadog/pom.xml b/flink-metrics/flink-metrics-datadog/pom.xml
index 3f58c9d189590..acb53bc298422 100644
--- a/flink-metrics/flink-metrics-datadog/pom.xml
+++ b/flink-metrics/flink-metrics-datadog/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-datadog
diff --git a/flink-metrics/flink-metrics-dropwizard/pom.xml b/flink-metrics/flink-metrics-dropwizard/pom.xml
index 1b286aca7029c..65a455a5e03f6 100644
--- a/flink-metrics/flink-metrics-dropwizard/pom.xml
+++ b/flink-metrics/flink-metrics-dropwizard/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-dropwizard
diff --git a/flink-metrics/flink-metrics-graphite/pom.xml b/flink-metrics/flink-metrics-graphite/pom.xml
index 89ad6f0abc7c5..fa55e31147f47 100644
--- a/flink-metrics/flink-metrics-graphite/pom.xml
+++ b/flink-metrics/flink-metrics-graphite/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-graphite
diff --git a/flink-metrics/flink-metrics-influxdb/pom.xml b/flink-metrics/flink-metrics-influxdb/pom.xml
index 2c2b62380774e..d1e125490ec40 100644
--- a/flink-metrics/flink-metrics-influxdb/pom.xml
+++ b/flink-metrics/flink-metrics-influxdb/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-influxdb
diff --git a/flink-metrics/flink-metrics-jmx/pom.xml b/flink-metrics/flink-metrics-jmx/pom.xml
index e8d10ab1bb5ed..9b69d6af8eb9c 100644
--- a/flink-metrics/flink-metrics-jmx/pom.xml
+++ b/flink-metrics/flink-metrics-jmx/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-jmx
diff --git a/flink-metrics/flink-metrics-otel/pom.xml b/flink-metrics/flink-metrics-otel/pom.xml
index 1a32ebcfa66aa..f266682f05b9c 100644
--- a/flink-metrics/flink-metrics-otel/pom.xml
+++ b/flink-metrics/flink-metrics-otel/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-otel
diff --git a/flink-metrics/flink-metrics-prometheus/pom.xml b/flink-metrics/flink-metrics-prometheus/pom.xml
index c064a38785bc5..81242a340e9fb 100644
--- a/flink-metrics/flink-metrics-prometheus/pom.xml
+++ b/flink-metrics/flink-metrics-prometheus/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-prometheus
diff --git a/flink-metrics/flink-metrics-slf4j/pom.xml b/flink-metrics/flink-metrics-slf4j/pom.xml
index ecabae4ced83e..a5583cd3d05da 100644
--- a/flink-metrics/flink-metrics-slf4j/pom.xml
+++ b/flink-metrics/flink-metrics-slf4j/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-slf4j
diff --git a/flink-metrics/flink-metrics-statsd/pom.xml b/flink-metrics/flink-metrics-statsd/pom.xml
index 033652c7263c6..982add4160346 100644
--- a/flink-metrics/flink-metrics-statsd/pom.xml
+++ b/flink-metrics/flink-metrics-statsd/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-metrics
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics-statsd
diff --git a/flink-metrics/pom.xml b/flink-metrics/pom.xml
index c7cffa8d84be8..3c5f85cb0ac17 100644
--- a/flink-metrics/pom.xml
+++ b/flink-metrics/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-metrics
diff --git a/flink-python/dev/dev-requirements.txt b/flink-python/dev/dev-requirements.txt
index 8c1eb18ffa5ca..dd18e76666cff 100755
--- a/flink-python/dev/dev-requirements.txt
+++ b/flink-python/dev/dev-requirements.txt
@@ -21,7 +21,7 @@ py4j==0.10.9.7
python-dateutil>=2.8.0,<3
cloudpickle~=2.2.0
avro>=1.12.0
-pandas>=1.3.0
+pandas>=1.3.0,<3.0.0
pyarrow>=5.0.0
pytz>=2018.3
numpy>=1.22.4
diff --git a/flink-python/pom.xml b/flink-python/pom.xml
index 9549a482482a9..96aba9bd3cec0 100644
--- a/flink-python/pom.xml
+++ b/flink-python/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-python
diff --git a/flink-python/setup.py b/flink-python/setup.py
index 2703f8d931cd4..3664a944a9d6b 100644
--- a/flink-python/setup.py
+++ b/flink-python/setup.py
@@ -322,7 +322,7 @@ def extracted_output_files(base_dir, file_path, output_directory):
'pytz>=2018.3', 'fastavro>=1.1.0,!=1.8.0', 'requests>=2.26.0',
'protobuf>=3.19.0',
'numpy>=1.22.4',
- 'pandas>=1.3.0',
+ 'pandas>=1.3.0,<3.0.0',
'pyarrow>=5.0.0',
'pemja==0.4.1;platform_system != "Windows"',
'httplib2>=0.19.0',
diff --git a/flink-queryable-state/flink-queryable-state-client-java/pom.xml b/flink-queryable-state/flink-queryable-state-client-java/pom.xml
index 93b43a3ced1a2..43660f9d52f98 100644
--- a/flink-queryable-state/flink-queryable-state-client-java/pom.xml
+++ b/flink-queryable-state/flink-queryable-state-client-java/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-queryable-state
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-queryable-state-client-java
diff --git a/flink-queryable-state/flink-queryable-state-runtime/pom.xml b/flink-queryable-state/flink-queryable-state-runtime/pom.xml
index 912fac644a385..bdc564af672c6 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/pom.xml
+++ b/flink-queryable-state/flink-queryable-state-runtime/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-queryable-state
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-queryable-state-runtime
diff --git a/flink-queryable-state/pom.xml b/flink-queryable-state/pom.xml
index 49bbf7f878d8d..c02260024991e 100644
--- a/flink-queryable-state/pom.xml
+++ b/flink-queryable-state/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-queryable-state
diff --git a/flink-quickstart/flink-quickstart-java/pom.xml b/flink-quickstart/flink-quickstart-java/pom.xml
index c19058bb5f06f..50c65fe32ae16 100644
--- a/flink-quickstart/flink-quickstart-java/pom.xml
+++ b/flink-quickstart/flink-quickstart-java/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-quickstart
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-quickstart-java
diff --git a/flink-quickstart/pom.xml b/flink-quickstart/pom.xml
index ab5c664b8a5d6..63fc6a3485ac6 100644
--- a/flink-quickstart/pom.xml
+++ b/flink-quickstart/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-quickstart
diff --git a/flink-rpc/flink-rpc-akka-loader/pom.xml b/flink-rpc/flink-rpc-akka-loader/pom.xml
index 8544a65b6f965..f1c7bba1da4bd 100644
--- a/flink-rpc/flink-rpc-akka-loader/pom.xml
+++ b/flink-rpc/flink-rpc-akka-loader/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-rpc
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-rpc-akka-loader
diff --git a/flink-rpc/flink-rpc-akka/pom.xml b/flink-rpc/flink-rpc-akka/pom.xml
index 5a771cb4e4138..15c9da29641e6 100644
--- a/flink-rpc/flink-rpc-akka/pom.xml
+++ b/flink-rpc/flink-rpc-akka/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-rpc
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-rpc-akka
diff --git a/flink-rpc/flink-rpc-core/pom.xml b/flink-rpc/flink-rpc-core/pom.xml
index c78f5470e7253..1e4b6dd3f1258 100644
--- a/flink-rpc/flink-rpc-core/pom.xml
+++ b/flink-rpc/flink-rpc-core/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-rpc
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-rpc-core
diff --git a/flink-rpc/pom.xml b/flink-rpc/pom.xml
index f7d55623593b4..ebaebd88b9ea3 100644
--- a/flink-rpc/pom.xml
+++ b/flink-rpc/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-rpc
diff --git a/flink-runtime-web/pom.xml b/flink-runtime-web/pom.xml
index db42593685fcb..c30c210866f09 100644
--- a/flink-runtime-web/pom.xml
+++ b/flink-runtime-web/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-runtime-web
diff --git a/flink-runtime/pom.xml b/flink-runtime/pom.xml
index 63b61b54f2146..4dcf5be34bb08 100644
--- a/flink-runtime/pom.xml
+++ b/flink-runtime/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-runtime
@@ -165,6 +165,14 @@ under the License.
+
+
+ net.jcip
+ jcip-annotations
+ 1.0
+ true
+
+
commons-io
commons-io
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java
index c6a34df24fd55..1ba09e6335d5a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java
@@ -19,14 +19,12 @@
package org.apache.flink.runtime.clusterframework;
import org.apache.flink.configuration.Configuration;
-import org.apache.flink.configuration.CoreOptions;
+import org.apache.flink.configuration.ConfigurationUtils;
import org.apache.flink.configuration.ResourceManagerOptions;
import java.util.HashMap;
import java.util.Map;
-import static org.apache.flink.configuration.ConfigConstants.ENV_JAVA_HOME;
-
/** This class describes the basic parameters for launching a TaskManager process. */
public class ContaineredTaskManagerParameters implements java.io.Serializable {
@@ -94,8 +92,7 @@ public static ContaineredTaskManagerParameters create(
}
// set JAVA_HOME
- config.getOptional(CoreOptions.FLINK_JAVA_HOME)
- .ifPresent(javaHome -> envVars.put(ENV_JAVA_HOME, javaHome));
+ ConfigurationUtils.setJavaHomeEnv(config, envVars);
// done
return new ContaineredTaskManagerParameters(taskExecutorProcessSpec, envVars);
diff --git a/flink-state-backends/flink-statebackend-changelog/pom.xml b/flink-state-backends/flink-statebackend-changelog/pom.xml
index 9f54f05c94aff..8e672a6caf16d 100644
--- a/flink-state-backends/flink-statebackend-changelog/pom.xml
+++ b/flink-state-backends/flink-statebackend-changelog/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-state-backends
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-statebackend-changelog
diff --git a/flink-state-backends/flink-statebackend-common/pom.xml b/flink-state-backends/flink-statebackend-common/pom.xml
index 6ccdb1ccc68e9..969fca7c675ea 100644
--- a/flink-state-backends/flink-statebackend-common/pom.xml
+++ b/flink-state-backends/flink-statebackend-common/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-state-backends
- 2.0.0
+ 2.0.0.1-4.3.0-0
..
diff --git a/flink-state-backends/flink-statebackend-forst/pom.xml b/flink-state-backends/flink-statebackend-forst/pom.xml
index c4a9d7bffea5c..01ce5c450869a 100644
--- a/flink-state-backends/flink-statebackend-forst/pom.xml
+++ b/flink-state-backends/flink-statebackend-forst/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-state-backends
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-statebackend-forst
diff --git a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java
index 774cb65f74ef1..0166b76e11c1c 100644
--- a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java
+++ b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java
@@ -144,6 +144,8 @@ private FSDataInputStream getStream() throws IOException {
fileBasedCache.incHitCounter();
return stream;
}
+ closeCachedStream();
+ return getStream();
}
fileBasedCache.incMissCounter();
return originalStream;
diff --git a/flink-state-backends/flink-statebackend-heap-spillable/pom.xml b/flink-state-backends/flink-statebackend-heap-spillable/pom.xml
index 674122908ca01..b218d31e6943a 100644
--- a/flink-state-backends/flink-statebackend-heap-spillable/pom.xml
+++ b/flink-state-backends/flink-statebackend-heap-spillable/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-state-backends
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-statebackend-heap-spillable
diff --git a/flink-state-backends/flink-statebackend-rocksdb/pom.xml b/flink-state-backends/flink-statebackend-rocksdb/pom.xml
index 906493285f4e7..84dcaabc1c61d 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/pom.xml
+++ b/flink-state-backends/flink-statebackend-rocksdb/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-state-backends
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-statebackend-rocksdb
diff --git a/flink-state-backends/pom.xml b/flink-state-backends/pom.xml
index ac3def9723a3b..5f087ef72ae77 100644
--- a/flink-state-backends/pom.xml
+++ b/flink-state-backends/pom.xml
@@ -27,7 +27,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-state-backends
diff --git a/flink-streaming-java/pom.xml b/flink-streaming-java/pom.xml
index e58242af73e57..c6394a148556a 100644
--- a/flink-streaming-java/pom.xml
+++ b/flink-streaming-java/pom.xml
@@ -25,7 +25,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-streaming-java
diff --git a/flink-table/flink-sql-client/pom.xml b/flink-table/flink-sql-client/pom.xml
index 40970368e4ccc..f2271f86a5662 100644
--- a/flink-table/flink-sql-client/pom.xml
+++ b/flink-table/flink-sql-client/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-client
diff --git a/flink-table/flink-sql-gateway-api/pom.xml b/flink-table/flink-sql-gateway-api/pom.xml
index 31964f02c8551..661f4edcd8de1 100644
--- a/flink-table/flink-sql-gateway-api/pom.xml
+++ b/flink-table/flink-sql-gateway-api/pom.xml
@@ -26,7 +26,7 @@
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-gateway-api
diff --git a/flink-table/flink-sql-gateway/pom.xml b/flink-table/flink-sql-gateway/pom.xml
index 917fcda9265e0..cbc7283ea082f 100644
--- a/flink-table/flink-sql-gateway/pom.xml
+++ b/flink-table/flink-sql-gateway/pom.xml
@@ -26,7 +26,7 @@
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-gateway
diff --git a/flink-table/flink-sql-jdbc-driver-bundle/pom.xml b/flink-table/flink-sql-jdbc-driver-bundle/pom.xml
index 80558ee267974..a8516f210f594 100644
--- a/flink-table/flink-sql-jdbc-driver-bundle/pom.xml
+++ b/flink-table/flink-sql-jdbc-driver-bundle/pom.xml
@@ -26,7 +26,7 @@
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-jdbc-driver-bundle
diff --git a/flink-table/flink-sql-jdbc-driver/pom.xml b/flink-table/flink-sql-jdbc-driver/pom.xml
index 95fc9f8efe9eb..7f70d5330dab6 100644
--- a/flink-table/flink-sql-jdbc-driver/pom.xml
+++ b/flink-table/flink-sql-jdbc-driver/pom.xml
@@ -26,7 +26,7 @@
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-jdbc-driver
diff --git a/flink-table/flink-sql-parser/pom.xml b/flink-table/flink-sql-parser/pom.xml
index 860c2096be8c1..dfcbe349644da 100644
--- a/flink-table/flink-sql-parser/pom.xml
+++ b/flink-table/flink-sql-parser/pom.xml
@@ -24,7 +24,7 @@ under the License.
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-sql-parser
diff --git a/flink-table/flink-table-api-bridge-base/pom.xml b/flink-table/flink-table-api-bridge-base/pom.xml
index 365a366f95673..772111524a6a1 100644
--- a/flink-table/flink-table-api-bridge-base/pom.xml
+++ b/flink-table/flink-table-api-bridge-base/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-bridge-base
diff --git a/flink-table/flink-table-api-java-bridge/pom.xml b/flink-table/flink-table-api-java-bridge/pom.xml
index ee5cc81593355..3c504b21eb498 100644
--- a/flink-table/flink-table-api-java-bridge/pom.xml
+++ b/flink-table/flink-table-api-java-bridge/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-java-bridge
diff --git a/flink-table/flink-table-api-java-uber/pom.xml b/flink-table/flink-table-api-java-uber/pom.xml
index ec777b72c9b81..559fab9662304 100644
--- a/flink-table/flink-table-api-java-uber/pom.xml
+++ b/flink-table/flink-table-api-java-uber/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-java-uber
diff --git a/flink-table/flink-table-api-java/pom.xml b/flink-table/flink-table-api-java/pom.xml
index 7f73719fbcabd..0e0fe9c449122 100644
--- a/flink-table/flink-table-api-java/pom.xml
+++ b/flink-table/flink-table-api-java/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-java
diff --git a/flink-table/flink-table-api-scala-bridge/pom.xml b/flink-table/flink-table-api-scala-bridge/pom.xml
index 8ae5db3be370e..2d2d59dccfcbe 100644
--- a/flink-table/flink-table-api-scala-bridge/pom.xml
+++ b/flink-table/flink-table-api-scala-bridge/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-scala-bridge_${scala.binary.version}
diff --git a/flink-table/flink-table-api-scala/pom.xml b/flink-table/flink-table-api-scala/pom.xml
index 5744209437fa3..9ff1352fb7759 100644
--- a/flink-table/flink-table-api-scala/pom.xml
+++ b/flink-table/flink-table-api-scala/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-api-scala_${scala.binary.version}
diff --git a/flink-table/flink-table-calcite-bridge/pom.xml b/flink-table/flink-table-calcite-bridge/pom.xml
index 81e7401a7868f..e49a509244574 100644
--- a/flink-table/flink-table-calcite-bridge/pom.xml
+++ b/flink-table/flink-table-calcite-bridge/pom.xml
@@ -23,7 +23,7 @@ under the License.
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-calcite-bridge
diff --git a/flink-table/flink-table-code-splitter/pom.xml b/flink-table/flink-table-code-splitter/pom.xml
index de96024b4ed80..4452c790883f1 100644
--- a/flink-table/flink-table-code-splitter/pom.xml
+++ b/flink-table/flink-table-code-splitter/pom.xml
@@ -24,7 +24,7 @@ under the License.
flink-table
org.apache.flink
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-code-splitter
diff --git a/flink-table/flink-table-common/pom.xml b/flink-table/flink-table-common/pom.xml
index b5cbec223e353..a89073f823e2c 100644
--- a/flink-table/flink-table-common/pom.xml
+++ b/flink-table/flink-table-common/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-common
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogTable.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogTable.java
index 5777a1755be34..a9c5196ab227a 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogTable.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogTable.java
@@ -56,6 +56,20 @@ static CatalogTable.Builder newBuilder() {
return new CatalogTable.Builder();
}
+ /** Creates an instance of {@link CatalogTable}. */
+ static CatalogTable of(
+ Schema schema,
+ @Nullable String comment,
+ List partitionKeys,
+ Map options) {
+ return newBuilder()
+ .schema(schema)
+ .comment(comment)
+ .partitionKeys(partitionKeys)
+ .options(options)
+ .build();
+ }
+
/**
* Creates an instance of {@link CatalogTable} from a map of string properties that were
* previously created with {@link ResolvedCatalogTable#toProperties()}.
diff --git a/flink-table/flink-table-planner-loader-bundle/pom.xml b/flink-table/flink-table-planner-loader-bundle/pom.xml
index d3d58b6317727..1367898758f62 100644
--- a/flink-table/flink-table-planner-loader-bundle/pom.xml
+++ b/flink-table/flink-table-planner-loader-bundle/pom.xml
@@ -26,7 +26,7 @@
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-planner-loader-bundle
diff --git a/flink-table/flink-table-planner-loader/pom.xml b/flink-table/flink-table-planner-loader/pom.xml
index 5598657822116..b3f5d3aaeb773 100644
--- a/flink-table/flink-table-planner-loader/pom.xml
+++ b/flink-table/flink-table-planner-loader/pom.xml
@@ -26,7 +26,7 @@
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-planner-loader
diff --git a/flink-table/flink-table-planner/pom.xml b/flink-table/flink-table-planner/pom.xml
index 721e39529fc15..0a35c8a694af4 100644
--- a/flink-table/flink-table-planner/pom.xml
+++ b/flink-table/flink-table-planner/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-planner_${scala.binary.version}
diff --git a/flink-table/flink-table-runtime/pom.xml b/flink-table/flink-table-runtime/pom.xml
index e9d68365daf55..fc95390e7ddeb 100644
--- a/flink-table/flink-table-runtime/pom.xml
+++ b/flink-table/flink-table-runtime/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-runtime
diff --git a/flink-table/flink-table-test-utils/pom.xml b/flink-table/flink-table-test-utils/pom.xml
index 658992f9dbe2a..66afa5f6dc5ec 100644
--- a/flink-table/flink-table-test-utils/pom.xml
+++ b/flink-table/flink-table-test-utils/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-table
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table-test-utils
diff --git a/flink-table/pom.xml b/flink-table/pom.xml
index 80f12dd63977f..3f158770d1e15 100644
--- a/flink-table/pom.xml
+++ b/flink-table/pom.xml
@@ -23,7 +23,7 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-table
diff --git a/flink-test-utils-parent/flink-clients-test-utils/pom.xml b/flink-test-utils-parent/flink-clients-test-utils/pom.xml
index ff11e733eae39..3d253f76dc76c 100644
--- a/flink-test-utils-parent/flink-clients-test-utils/pom.xml
+++ b/flink-test-utils-parent/flink-clients-test-utils/pom.xml
@@ -26,7 +26,7 @@ under the License.
org.apache.flink
flink-test-utils-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
flink-clients-test-utils
diff --git a/flink-test-utils-parent/flink-connector-test-utils/pom.xml b/flink-test-utils-parent/flink-connector-test-utils/pom.xml
index f41df5b1bd655..27aeb091ceb7c 100644
--- a/flink-test-utils-parent/flink-connector-test-utils/pom.xml
+++ b/flink-test-utils-parent/flink-connector-test-utils/pom.xml
@@ -25,7 +25,7 @@
org.apache.flink
flink-test-utils-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
1536m
@@ -167,8 +178,8 @@ under the License.
Starting Hadoop 3, org.apache.kerby will be used instead of MiniKDC. We may have
to revisit the impact at that time.
-->
- 3.2.4
- 2.3.10
+ 3.4.1
+ 4.3.0.1-4.3.0-0
1.5.6
1.20.0
tools/japicmp-output
@@ -1165,6 +1176,9 @@ under the License.
java21-target
+
+ [21,)
+
diff --git a/tools/ci/alibaba-mirror-settings.xml b/tools/ci/alibaba-mirror-settings.xml
index 34fddbe349455..f89b69d4d61b7 100644
--- a/tools/ci/alibaba-mirror-settings.xml
+++ b/tools/ci/alibaba-mirror-settings.xml
@@ -31,4 +31,11 @@ under the License.
confluent
+
+
+ arenadata
+ ${env.GITHUB_ACTOR}
+ ${env.GITHUB_TOKEN}
+
+
diff --git a/tools/ci/flink-ci-tools/pom.xml b/tools/ci/flink-ci-tools/pom.xml
index 8523fb126c55b..fbb13728e03fa 100644
--- a/tools/ci/flink-ci-tools/pom.xml
+++ b/tools/ci/flink-ci-tools/pom.xml
@@ -25,12 +25,12 @@ under the License.
org.apache.flink
flink-parent
- 2.0.0
+ 2.0.0.1-4.3.0-0
../../..
flink-ci-tools
- 2.0.0
+ 2.0.0.1-4.3.0-0
Flink : Tools : CI : Java
diff --git a/tools/ci/flink-ci-tools/src/main/resources/modules-defining-excess-dependencies.modulelist b/tools/ci/flink-ci-tools/src/main/resources/modules-defining-excess-dependencies.modulelist
index cc9b355b2f77d..08dddebaada90 100644
--- a/tools/ci/flink-ci-tools/src/main/resources/modules-defining-excess-dependencies.modulelist
+++ b/tools/ci/flink-ci-tools/src/main/resources/modules-defining-excess-dependencies.modulelist
@@ -21,4 +21,6 @@
flink-sql-connector-hive-2.3.10
flink-sql-connector-hive-3.1.3
+flink-sql-connector-hive-4.0.0
+flink-sql-connector-hive-4.3.0
flink-python
diff --git a/tools/ci/google-mirror-settings.xml b/tools/ci/google-mirror-settings.xml
index 49a3b7133e9a0..bd3b938644ea0 100644
--- a/tools/ci/google-mirror-settings.xml
+++ b/tools/ci/google-mirror-settings.xml
@@ -25,4 +25,11 @@ under the License.
central
+
+
+ arenadata
+ ${env.GITHUB_ACTOR}
+ ${env.GITHUB_TOKEN}
+
+
diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml
index 03b13fbc6761f..239acc1ae8b91 100644
--- a/tools/maven/checkstyle.xml
+++ b/tools/maven/checkstyle.xml
@@ -61,7 +61,7 @@ This file is based on the checkstyle file of Apache Beam.
-->
-
+