Issues

• Keep remaining connector source attachments and release checks module-local

  datafusion-contrib/StreamFusion#658 · Filter by author liuyongvs opened on Nov 12, 2026

• Widen native Kafka source admission: metadata, non-raw keys, Canal include filters, nested CDC

  datafusion-contrib/StreamFusion#657 · Filter by author Flanderzz opened on Nov 12, 2026

• Kafka end-to-end suites run outside CI and have failing tests

  datafusion-contrib/StreamFusion#652 · Filter by author Flanderzz opened on Nov 12, 2026

• Native Kafka exactly-once sink commits duplicates after a commit-phase failover on Flink 1.18

  datafusion-contrib/StreamFusion#651 · Filter by author Flanderzz opened on Nov 12, 2026

• Protobuf decode on Flink 1.18 reads unset nested messages as NULL instead of default rows

  datafusion-contrib/StreamFusion#650 · Filter by author Flanderzz opened on Nov 12, 2026

• Native timestamp parsing differs from Flink's SMART and STRICT resolvers in JSON and CSV

  datafusion-contrib/StreamFusion#648 · Filter by author Flanderzz opened on Nov 12, 2026

• Native JSON decode differs from Flink on numeric strings, narrow integers, float spellings and containers

  datafusion-contrib/StreamFusion#647 · Filter by author Flanderzz opened on Nov 12, 2026

• Finish Kafka and format source ownership and test their actual module artifacts

  datafusion-contrib/StreamFusion#646 · Filter by author liuyongvs opened on Nov 12, 2026

• Align Delta, Fluss and Paimon production source ownership with deployment modules

  datafusion-contrib/StreamFusion#644 · Filter by author liuyongvs opened on Nov 12, 2026

• Finish separating historical evidence from maintained repository inputs

  datafusion-contrib/StreamFusion#641 · Filter by author liuyongvs opened on Nov 12, 2026

• CI: Paimon lookup failure-injection cleanup can terminate the TaskExecutor

  datafusion-contrib/StreamFusion#629 · Filter by author liuyongvs opened on Nov 10, 2026
  1

• Non-UTF-8 Flink STRING input is written as Arrow Utf8 and fails in native CONCAT

  datafusion-contrib/StreamFusion#622 · Filter by author liuyongvs opened on Nov 10, 2026
  2

• Reduce full-job copy and conversion costs for wide string-array JSON_STRING

  datafusion-contrib/StreamFusion#610 · Filter by author liuyongvs opened on Nov 6, 2026

• CI: investigate Paimon TableWriteTest temporary-directory cleanup failure

  datafusion-contrib/StreamFusion#609 · Filter by author liuyongvs opened on Nov 6, 2026

• P0: Bidirectional job and state compatibility between StreamFusion and stock Flink

  enhancementpriority: P0
  datafusion-contrib/StreamFusion#569 · Filter by author jordepic opened on Oct 30, 2026
  2

• Reduce represented collection boundary costs after native kernel coverage

  datafusion-contrib/StreamFusion#534 · Filter by author jordepic opened on Oct 27, 2026

• Extend exact STRING fusion and reduce cached Unicode and boundary costs

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#521 · Filter by author liuyongvs opened on Oct 26, 2026
  2

• Extend exact STRING intermediate transport for padding and overlay across relational operators

  datafusion-contrib/StreamFusion#519 · Filter by author liuyongvs opened on Oct 26, 2026
  1

• Implement exact native floating math paths currently delegated to the JVM

  enhancementpriority: P3
  datafusion-contrib/StreamFusion#513 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native LAG in time-ordered streaming OVER windows

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#512 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native PERCENTILE aggregation on released Flink 2.2

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#511 · Filter by author liuyongvs opened on Oct 26, 2026

• Track native execution support for the Flink PRINT debug scalar function

  enhancementpriority: P4
  datafusion-contrib/StreamFusion#510 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native PARSE_JSON and TRY_PARSE_JSON with VARIANT transport

  enhancementpriority: P3
  datafusion-contrib/StreamFusion#509 · Filter by author liuyongvs opened on Oct 26, 2026

• Extend native STRING ordering and dynamic trim beyond unproven source representations

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#508 · Filter by author liuyongvs opened on Oct 26, 2026
  2

• Replace remaining Calc SQL/JSON JVM evaluator signatures with compatible native kernels

  enhancementpriority: P1
  datafusion-contrib/StreamFusion#506 · Filter by author liuyongvs opened on Oct 26, 2026
  5