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 Cloudera 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 Cloudera Streaming Analytics cluster from the
list of Cloudera 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 Analytics version of your Cloudera 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.