You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mo...@apache.org on 2023/01/31 19:41:53 UTC
[flink-kubernetes-operator] branch main updated: [FLINK-29871] Upgraded flink dependencies to 1.16.1
This is an automated email from the ASF dual-hosted git repository.
morhidi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new d3c3c0c3 [FLINK-29871] Upgraded flink dependencies to 1.16.1
d3c3c0c3 is described below
commit d3c3c0c305c45fff24b93aad0322944875446f84
Author: Rodrigo <rm...@gmail.com>
AuthorDate: Tue Jan 31 11:41:46 2023 -0800
[FLINK-29871] Upgraded flink dependencies to 1.16.1
---
examples/advanced-ingress.yaml | 4 ++--
examples/basic-checkpoint-ha.yaml | 4 ++--
examples/basic-ingress.yaml | 4 ++--
examples/basic-reactive.yaml | 4 ++--
examples/basic-session-deployment-and-job.yaml | 4 ++--
examples/basic-session-deployment-only.yaml | 4 ++--
examples/basic.yaml | 4 ++--
examples/custom-logging.yaml | 4 ++--
examples/flink-python-example/Dockerfile | 4 ++--
examples/flink-python-example/python-example.yaml | 4 ++--
examples/flink-sql-runner-example/Dockerfile | 2 +-
examples/flink-sql-runner-example/sql-example.yaml | 2 +-
examples/pod-template.yaml | 4 ++--
.../operator/service/CustomCheckpointingStatisticsHeaders.java | 4 ++--
.../operator/service/CustomDashboardConfigurationHeaders.java | 4 ++--
pom.xml | 2 +-
16 files changed, 29 insertions(+), 29 deletions(-)
diff --git a/examples/advanced-ingress.yaml b/examples/advanced-ingress.yaml
index 62062d6c..50532194 100644
--- a/examples/advanced-ingress.yaml
+++ b/examples/advanced-ingress.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: advanced-ingress
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
ingress:
template: "/{{namespace}}/{{name}}(/|$)(.*)"
className: "nginx"
diff --git a/examples/basic-checkpoint-ha.yaml b/examples/basic-checkpoint-ha.yaml
index b344bf8c..c06c67ab 100644
--- a/examples/basic-checkpoint-ha.yaml
+++ b/examples/basic-checkpoint-ha.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-checkpoint-ha-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
state.savepoints.dir: file:///flink-data/savepoints
diff --git a/examples/basic-ingress.yaml b/examples/basic-ingress.yaml
index 52e3632d..f60a434a 100644
--- a/examples/basic-ingress.yaml
+++ b/examples/basic-ingress.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-ingress
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
ingress:
template: "{{name}}.{{namespace}}.flink.k8s.io"
flinkConfiguration:
diff --git a/examples/basic-reactive.yaml b/examples/basic-reactive.yaml
index eddf58b3..8901440a 100644
--- a/examples/basic-reactive.yaml
+++ b/examples/basic-reactive.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-reactive-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
scheduler-mode: REACTIVE
taskmanager.numberOfTaskSlots: "2"
diff --git a/examples/basic-session-deployment-and-job.yaml b/examples/basic-session-deployment-and-job.yaml
index 613bfdbe..c92342f6 100644
--- a/examples/basic-session-deployment-and-job.yaml
+++ b/examples/basic-session-deployment-and-job.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-session-deployment-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
jobManager:
resource:
memory: "2048m"
diff --git a/examples/basic-session-deployment-only.yaml b/examples/basic-session-deployment-only.yaml
index 812f3a0c..42c2d715 100644
--- a/examples/basic-session-deployment-only.yaml
+++ b/examples/basic-session-deployment-only.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-session-deployment-only-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
serviceAccount: flink
diff --git a/examples/basic.yaml b/examples/basic.yaml
index d63861de..2cee8ab3 100644
--- a/examples/basic.yaml
+++ b/examples/basic.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
serviceAccount: flink
diff --git a/examples/custom-logging.yaml b/examples/custom-logging.yaml
index 51220496..7f3c8412 100644
--- a/examples/custom-logging.yaml
+++ b/examples/custom-logging.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: custom-logging-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
serviceAccount: flink
diff --git a/examples/flink-python-example/Dockerfile b/examples/flink-python-example/Dockerfile
index 1deb3869..f2ff220c 100644
--- a/examples/flink-python-example/Dockerfile
+++ b/examples/flink-python-example/Dockerfile
@@ -16,7 +16,7 @@
# limitations under the License.
################################################################################
# Check https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/resource-providers/standalone/docker/#using-flink-python-on-docker for more details
-FROM flink:1.15
+FROM flink:1.16
# install python3: it has updated Python to 3.9 in Debian 11 and so install Python 3.7 from source, \
# it currently only supports Python 3.6, 3.7 and 3.8 in PyFlink officially.
@@ -36,7 +36,7 @@ apt-get clean && \
rm -rf /var/lib/apt/lists/*
# install PyFlink
-RUN pip3 install "apache-flink>=1.15.0,<1.16.0"
+RUN pip3 install "apache-flink>=1.16.0,<1.17.0"
# add python script
USER flink
diff --git a/examples/flink-python-example/python-example.yaml b/examples/flink-python-example/python-example.yaml
index d0c2fdc0..958f81b6 100644
--- a/examples/flink-python-example/python-example.yaml
+++ b/examples/flink-python-example/python-example.yaml
@@ -22,7 +22,7 @@ metadata:
name: python-example
spec:
image: flink-python-example:latest
- flinkVersion: v1_15
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "1"
serviceAccount: flink
@@ -35,7 +35,7 @@ spec:
memory: "2048m"
cpu: 1
job:
- jarURI: local:///opt/flink/opt/flink-python_2.12-1.15.3.jar # Note, this jarURI is actually a placeholder
+ jarURI: local:///opt/flink/opt/flink-python_2.12-1.16.1.jar # Note, this jarURI is actually a placeholder
entryClass: "org.apache.flink.client.python.PythonDriver"
args: ["-pyclientexec", "/usr/local/bin/python3", "-py", "/opt/flink/usrlib/python_demo.py"]
parallelism: 1
diff --git a/examples/flink-sql-runner-example/Dockerfile b/examples/flink-sql-runner-example/Dockerfile
index 3d687016..d46f9280 100644
--- a/examples/flink-sql-runner-example/Dockerfile
+++ b/examples/flink-sql-runner-example/Dockerfile
@@ -16,7 +16,7 @@
# limitations under the License.
################################################################################
-FROM flink:1.15
+FROM flink:1.16
RUN mkdir /opt/flink/usrlib
ADD target/flink-sql-runner-example-*.jar /opt/flink/usrlib/sql-runner.jar
diff --git a/examples/flink-sql-runner-example/sql-example.yaml b/examples/flink-sql-runner-example/sql-example.yaml
index 14865e05..0e29bab1 100644
--- a/examples/flink-sql-runner-example/sql-example.yaml
+++ b/examples/flink-sql-runner-example/sql-example.yaml
@@ -22,7 +22,7 @@ metadata:
name: sql-example
spec:
image: flink-sql-runner-example:latest
- flinkVersion: v1_15
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "1"
serviceAccount: flink
diff --git a/examples/pod-template.yaml b/examples/pod-template.yaml
index 9b01cdf5..17ca46ea 100644
--- a/examples/pod-template.yaml
+++ b/examples/pod-template.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: pod-template-example
spec:
- image: flink:1.15
- flinkVersion: v1_15
+ image: flink:1.16
+ flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
serviceAccount: flink
diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomCheckpointingStatisticsHeaders.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomCheckpointingStatisticsHeaders.java
index fd0f82c8..d5b2afab 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomCheckpointingStatisticsHeaders.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomCheckpointingStatisticsHeaders.java
@@ -21,13 +21,13 @@ package org.apache.flink.kubernetes.operator.service;
import org.apache.flink.runtime.rest.HttpMethodWrapper;
import org.apache.flink.runtime.rest.messages.EmptyRequestBody;
import org.apache.flink.runtime.rest.messages.JobMessageParameters;
-import org.apache.flink.runtime.rest.messages.MessageHeaders;
+import org.apache.flink.runtime.rest.messages.RuntimeMessageHeaders;
import org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus;
/** Custom Headers for handling checkpoint history in a multi-version compatible way. */
public class CustomCheckpointingStatisticsHeaders
- implements MessageHeaders<
+ implements RuntimeMessageHeaders<
EmptyRequestBody, CheckpointHistoryWrapper, JobMessageParameters> {
private static final CustomCheckpointingStatisticsHeaders INSTANCE =
diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfigurationHeaders.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfigurationHeaders.java
index 1105f23d..d40f8cab 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfigurationHeaders.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfigurationHeaders.java
@@ -21,13 +21,13 @@ package org.apache.flink.kubernetes.operator.service;
import org.apache.flink.runtime.rest.HttpMethodWrapper;
import org.apache.flink.runtime.rest.messages.EmptyMessageParameters;
import org.apache.flink.runtime.rest.messages.EmptyRequestBody;
-import org.apache.flink.runtime.rest.messages.MessageHeaders;
+import org.apache.flink.runtime.rest.messages.RuntimeMessageHeaders;
import org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus;
/** Message headers for the {@link CustomDashboardConfiguration}. */
public final class CustomDashboardConfigurationHeaders
- implements MessageHeaders<
+ implements RuntimeMessageHeaders<
EmptyRequestBody, CustomDashboardConfiguration, EmptyMessageParameters> {
public static final CustomDashboardConfigurationHeaders INSTANCE =
diff --git a/pom.xml b/pom.xml
index 146821a8..0c1e0ee4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -79,7 +79,7 @@ under the License.
<lombok.version>1.18.22</lombok.version>
<commons-lang3.version>3.12.0</commons-lang3.version>
<commons-io.version>2.11.0</commons-io.version>
- <flink.version>1.15.3</flink.version>
+ <flink.version>1.16.1</flink.version>
<slf4j.version>1.7.36</slf4j.version>
<log4j.version>2.17.1</log4j.version>