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 <rmene...@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>