When you migrate your Flink jobs to a cluster that has a new supported version of
Flink, the applications need to use a new version of the artifacts provided by the Flink
deployment in your cluster. To avoid incompatibilities between the packaged artifacts of
your application and the artifacts provided by the Flink cluster, ensure that the POM file
of the application is updated to match the Flink version of the new Data Hub
cluster.
-
Navigate to , and select the environment where you have created your cluster.
-
Select the Streaming Analytics cluster from the list of Data
Hub clusters.
-
Access the latest Flink version of your cluster.
-
Navigate to , and select the environment where you have created your
cluster.
-
Select the Streaming Analytics cluster from the
list of Data Hub clusters.
-
Select Repository Details.
-
Search for the Cloudera Runtime Repository
Specification section, and review the Flink
version.
Name: FLINK
Version:
1.13.2-csadh1.5.0.0-cdh7.2.12.0-35-17794544
-
Update the
<flink.version>
property of your
POM
file using the Flink and Cloudera Streaming Analyitcs
(CSA) version of your Data Hub cluster.
You need to copy and paste only the prefix before the 'cdh'
version number: 1.13.2-csadh1.5.0.0
.
<properties>
...
<flink.version>1.13.2-csadh1.5.0.0</flink.version>
...
</properties>
...
<dependencies>
...
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>${flink.version}</version>
</dependency>
...
<dependencies>
-
Rebuild your JAR file.