What's new in Streaming Analytics

Learn about the new Streaming Analytics features in Cloudera DataFlow for Data Hub 7.2.18.

The following new features are introduced in Streaming Analytics CDF for Data Hub 7.2.18:
Rebase to Apache Flink 1.18.0
Apache Flink 1.18.0 is supported in the Streaming Analytics 7.2.18 cluster definition.

For more information on what is included in the Apache Flink 1.18.0 version, see the Apache Flink 1.18.0 Release Announcementand Release Notes.

Application Mode
Support for Flink's Application Mode is added. Application Mode enables you to submit Flink applications that run entirely on the cluster side, differently from Per-Job and Session modes where the application driver code runs on the client side. In Application Mode, each application can execute multiple jobs that share cluster resources but are isolated from other applications. For more details, please check the Running a Flink job.
Support for custom data port range in Task Manager
The taskmanager.data.port Flink service configuration now supports multiple ports and port ranges for Flink jobs' Task Manager processes. The taskmanager.data.port property can be configured for Flink in Cloudera Manager using a safety valve, and for SSB the property can be configured with SET statement.
PyFlink Support
Python API for Flink is supported in Cloudera Streaming Analytics that enables you to create Flink DataStream applications using Python.