Apache Beam Enhances Runner Parity with Drain Support and MQTT Portability
Apache Beam activity this week focused on runner parity and expanded IO connector capabilities for ClickHouse and MQTT. The project introduced Pipeline Drain support for Dataflow and Flink along with sub second precision for ClickHouse timestamps.