All pull requests

Pull requests

• [FLINK-40658][table] Preserve null ROW elements in UNNEST

  #29398·beetle0915 opened Oct 6, 2026Contributor·1 task done·

  ·

• [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator

  #29397·kotwal-itpro opened Oct 6, 2026·1 task done·

  ·
  1

• [FLINK-40836][checkpointing] Keep coordinator state when discarding in-flight data

  #29396·kotwal-itpro opened Oct 6, 2026·1 task done·

  ·
  1

• [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT

  #29395·kotwal-itpro opened Oct 6, 2026·1 task done·

  ·
  1

• [FLINK-40922][table-planner] Group keys of an aggregate with grouping sets are not a unique key

  #29394·kotwal-itpro opened Oct 6, 2026·1 task done·

  ·
  1

• [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression

  #29393·kotwal-itpro opened Oct 6, 2026·1 task done·

  ·
  1

• [FLINK-40921] Invoke statebackend's close() and dispose() in right order

  #29392·Zakelly opened Oct 6, 2026Contributor·

  ·
  1

• [FLINK-40903][runtime/network] Add source host info in TM disconnect error

  #29391·skywalker0618 opened Oct 5, 2026·1 task done·

  ·
  7

• [FLINK-40835][state] Forward bulk reads in CompressibleFSDataInputStream

  #29390·sarkaramrit1993 opened Oct 5, 2026·

  ·
  1

• [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue.

  target:release-1.20
  #29389·SAlexandru opened Oct 5, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue

  target:release-2.2
  #29388·SAlexandru opened Oct 5, 2026Contributor·

  ·
  1

• [BP-2.3][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue

  target:release-2.3
  #29387·SAlexandru opened Oct 5, 2026Contributor·

  ·
  1

• [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition

  #29386·MartijnVisser opened Oct 5, 2026Contributor·1 task done·

  ·
  7

• [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT

  #29385·AHeise opened Oct 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40901][table]Fixed the codegen bug w jsonType/Length

  #29384·VasShabu opened Oct 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40913][tests] Use a single vertex job in testStuckSyncPhaseFailsJob to avoid failures race

  #29383·Efrat19 opened Oct 5, 2026Contributor·1 task done·

  ·
  1

• Avoid full left-state scan in TemporalJoin by creating efficient minheap over statafull map

  #29382·stivsh opened Oct 5, 2026·1 task done·

  ·
  6

• [FLINK-40437][python] Add iteration and bounded retrieval to DataFrame API

  #29381·fdolce opened Oct 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40860][container] Add bin/minicluster.sh to run an application in a MiniCluster

  #29379·dalelane opened Oct 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40776][table-runtime] Cache query-parameter pattern in PARSE_URL

  #29375·uvashishtha opened Oct 3, 2026·1 task done·

  ·
  5

• [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism

  #29374·1996fanrui opened Oct 2, 2026Member·

  ·
  1

• [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction

  #29373·bvarghese1 opened Oct 2, 2026Contributor·

  ·
  3

• [FLINK-40627][clients] Protect against partially fetched or incorrect artifacts

  #29371·dalelane opened Oct 2, 2026Contributor·1 task·

  ·
  1

• [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT

  #29369·raminqaf opened Oct 2, 2026Contributor·1 task done·

  ·
  32

  

• [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API

  #29368·fhueske opened Oct 2, 2026Contributor·1 task done·

  ·
  13