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. Thetaskmanager.data.port
property can be configured for Flink in Cloudera Manager using a safety valve, and for SSB the property can be configured withSET
statement. - PyFlink Support
- Python API for Flink is supported in Cloudera Streaming Analytics that enables you to create Flink DataStream applications using Python.