The GitHub Actions job "Flink Connector Kafka CI" on 
flink-connector-kafka.git/FLINK-39792-multi-headers has failed.
Run started by GitHub user AHeise (triggered by AHeise).

Head commit for run:
643b0a2676855046022f92aa77284d6d08b389ba / Arvid Heise <[email protected]>
[FLINK-39792] Add multi-headers metadata key to Kafka connector

The existing headers metadata key (MAP<STRING, BYTES>) silently drops
duplicate header keys and loses insertion order, since iteration into a
HashMap lets the last value win. The new multi-headers key exposes headers
as ARRAY<ROW<name STRING, value BYTES>>, preserving wire order and
duplicate keys faithfully on both source and sink sides.

The two keys are mutually exclusive on the write path: declaring both in
the same table schema is rejected at planning time with a ValidationException.
Null header values are preserved; null header keys throw 
IllegalArgumentException
since the Kafka protocol does not permit them.

Co-Authored-By: Claude Sonnet 4.6 <[email protected]>

Report URL: 
https://github.com/apache/flink-connector-kafka/actions/runs/26622058918

With regards,
GitHub Actions via GitBox

Reply via email to