Update to Flink support policy
IBM’s conditions of support for Apache Flink in IBM Event Automation has been expanded. For more information, see the support policy statement.
Find out what is new in Event Processing version 1.5.x.
Release 1.5.3
Combine node: enhancements for mapping properties
Event Processing 1.5.3 introduces usability enhancements for mapping properties in the combine node. You can now search properties in the reference input stream, clear all mappings, expand or collapse property groups, and undo or redo changes when working with complex schemas that contain many properties or nested structures.
For more information, see combine node.
Monitoring event activity in running flows
Event Processing 1.5.3 introduces event activity metrics in the Flow metrics tab. You can now monitor detailed activity for event source and event destination nodes, including:
- Number of events sent or received by event source and event destination nodes
- Bytes read from event source nodes and bytes written to event destination nodes
- Message lag for event source nodes
These metrics provide deeper insights into the data flow through your event processing pipelines. You can use these insights to identify bottlenecks and optimize performance.
For more information, see monitoring event activity.
Session cluster monitoring
Event Processing 1.5.3 introduces the Session cluster page for monitoring the health and capacity of the Flink session cluster that supports your authoring environment. This page provides real-time visibility into TaskManager resource utilization and cluster capacity:
- TaskManager overview: View the number of free processing slots and total TaskManagers in your session cluster.
- Resource metrics: Monitor CPU load and memory usage for each TaskManager with visual indicators.
- Slot allocation: See how processing slots are distributed and utilized across TaskManagers.
- Log downloads: Download logs from individual TaskManagers, all TaskManagers, JobManager, or all logs combined using the dropdown menu.
For more information, see monitoring session cluster.
Apache Flink updated to 2.2.1
IBM Operator for Apache Flink version 1.5.3 update includes Apache Flink version 2.2.1.
Flink 1.20.3 is also supported, but only for deploying Flink jobs outside the Event Processing UI. The Event Processing UI is not supported when running a Flink instance with Flink 1.20.3.
Documentation: Highlighting differences between versions
Any difference in features or behavior introduced by Event Processing 1.5.3 compared to 1.5.2 or earlier is highlighted in this documentation by using the following graphic:
Security and bug fixes
Event Processing release 1.5.3 contains security and bug fixes.
Release 1.5.2
User-defined functions (UDFs) in SQL processor nodes
Event Processing 1.5.2 introduces support for user-defined functions (UDFs) in SQL processor nodes. You can use UDFs to extend the built-in functionality of Flink by writing custom logic in Java.
All UDFs available in Flink are supported. For more information, see configuring UDFs.
Processor node: merge multiple input streams with the combine node
Event Processing version 1.5.2 introduces the Combine node to merge multiple event sources into a single unified event stream by mapping properties to a reference event source schema.
Unlike joins, the combine node does not correlate events across streams. Instead, it merges events from multiple sources with the same schema into a single stream, allowing downstream nodes to process them consistently.
For more information, see combine node.
Metrics for monitoring running flows
Event Processing 1.5.2 introduces the Flow metrics tab where you can monitor the health and performance of running flows. The tab is available next to the Output events tab, and provides real-time insights into the current state of your flow including uptime, restarts, and checkpoint metrics.
For more information, see monitoring flow metrics.
Documentation: Highlighting differences between versions
Any difference in features or behavior introduced by Event Processing 1.5.2 compared to 1.5.1 or earlier is highlighted in this documentation by using the following graphic:
Security and bug fixes
Event Processing release 1.5.2 contains security and bug fixes.
Release 1.5.1
Additional outputs for conditional branching
Event Processing version 1.5.1 introduces additional output support for the Filter and SQL Processor nodes, enabling conditional branching with multiple output paths.
- Filter node: Configure an additional output to capture events that do not match the filter expression, enabling the use of both matched and unmatched events in downstream nodes for separate processing.
- SQL Processor node: Define multiple VIEW statements to create side outputs that split the processing logic and send different results to separate downstream nodes.
This feature provides greater flexibility in designing event processing flows with conditional logic and multiple processing paths.
Automatic merge of public certificates to the custom truststore
In Event Processing 1.5.1 and later, when you provide a custom truststore containing self-signed or internal CA certificates, public CA certificates are automatically added from the Java truststore to your custom truststore. This means that public CA certificates are maintained through regular Java version updates, and you are not required to manually add and update them. The truststore merge feature is enabled by default.
For more information, see configuring SSL.
Annotate on canvas with comments
Event Processing 1.5.1 introduces the commenting feature on the flow canvas. With comments, you can document your work directly on the canvas and collaborate with team members.
For more information, see adding comments to your flow.
Documentation: Highlighting differences between versions
Any difference in features or behavior introduced by Event Processing 1.5.1 compared to 1.5.0 or earlier is highlighted in this documentation by using the following graphic:
Security and bug fixes
Event Processing release 1.5.1 contains security and bug fixes.
Release 1.5.0
Support for Apache Flink 2.2.0
Event Processing 1.5.0 and later supports Apache Flink 2.2.0 for both UI-based flows and for Flink jobs deployed outside the Event Processing UI.
Flink 1.20.3 is also supported, but only for deploying Flink jobs outside the Event Processing UI. This includes:
- Testing jobs by using the Flink SQL client
- Deploying jobs by using the Apache SQL Runner sample
- Deploying customized jobs
The Event Processing UI is not supported when running a Flink instance with Flink 1.20.3.
To use Flink 1.20.3 for deploying Flink jobs, you must configure the FlinkDeployment custom resource to prevent automatic version upgrades. For more information, see upgrading.
Support for Red Hat OpenShift Container Platform 4.21
Event Processing version 1.5.0 introduces support for Red Hat OpenShift Container Platform 4.21.
Removal of support for OpenShift Container Platform 4.15
Event Processing 1.5.0 and later do not support OpenShift Container Platform version 4.15. For more information about supported versions, see the support matrix.
Removal of support for Kubernetes 1.25 and 1.26
Event Processing 1.5.0 and later do not support Kubernetes versions 1.25 and 1.26. For more information about supported versions, see the support matrix.
Security and bug fixes
Event Processing release 1.5.0 and IBM Operator for Apache Flink version 1.5.0 contain security and bug fixes.