All pull requests

Pull requests

• [BP-2.4][FLINK-41362][table] Reject VARIANT in primary key columns

  #29803·raminqaf opened Nov 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41361][core] Bound VARIANT object and array sizes by the value length

  #29802·raminqaf opened Nov 5, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41356][table] Support early fire in the async state interval join

  community-reviewed
  #29795·minxhe opened Nov 5, 2026·1 task done·

  ·
  6

• [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin

  community-reviewed
  #29794·minxhe opened Nov 5, 2026·1 task done·

  ·
  6

• [hotfix][test] Run testAcceptingOfferedSlotsWithoutResourceManagerConnected on a single threaded main executor

  #29788·snuyanzin opened Nov 4, 2026Contributor·1 task·

  ·
  2

  

• [FLINK-40494][docs] Document the UUID type

  community-reviewed
  #29783·raminqaf opened Nov 4, 2026Contributor·1 task done·

  ·
  6

  

• [BP-2.2][FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction

  target:release-2.2
  #29781·spuru9 opened Nov 4, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41327][table-runtime] Compare binary IN point-set values by content

  #29779·Zerolzj opened Nov 4, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41297][clients] Close the PackagedProgram of REST run-application submissions

  #29778·jagath25 opened Nov 4, 2026·1 task done·

  ·
  1

• [BP-1.20][FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision

  target:release-1.20
  #29775·1996fanrui opened Nov 3, 2026Member·1 task done·

  ·
  1

• [FLINK-35335][network] Hold back priority buffers on subpartitions blocked by aligned barriers

  #29766·spuru9 opened Nov 3, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41303][runtime-web] Only send job submission parameters in the request body

  target:release-1.20
  #29764·leosanqing opened Nov 3, 2026·

  ·
  2

• [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table

  community-reviewed
  #29761·spuru9 opened Nov 2, 2026Contributor·1 task done·

  ·
  7

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

  target:release-2.3
  #29759·1996fanrui opened Nov 2, 2026Member·1 task done·

  ·
  1

• [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness

  target:release-1.20
  #29758·1996fanrui opened Nov 2, 2026Member·1 task done·

  ·
  1

• [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs

  target:release-2.2
  #29757·1996fanrui opened Nov 2, 2026Member·1 task done·

  ·
  3

• [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction

  target:release-2.3
  #29755·1996fanrui opened Nov 2, 2026Member·1 task done·

  ·
  2

• FLINK-31737: Hide rescale buttons for batch jobs in WebUI

  #29754·ankitflow001 opened Nov 2, 2026·

  ·
  1

• [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed

  community-reviewedtarget:release-2.3
  #29752·1996fanrui opened Nov 2, 2026Member·1 task done·

  ·
  2

• [FLINK-31040][cep] Release a looping stage before a trailing notFollowedBy when its window expires

  #29728·mobanihan opened Nov 1, 2026·1 task done·

  ·
  2

• [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule

  #29724·hanyuzheng7 opened Oct 31, 2026Contributor·

  ·
  7

• [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder

  #29723·hanyuzheng7 opened Oct 31, 2026Contributor·

  ·
  13

• [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (release-1.20)

  target:release-1.20
  #29719·rakeshkodathala opened Oct 31, 2026Contributor·1 task done·

  ·
  1

• [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (release-2.4)

  target:release-2.4
  #29718·rakeshkodathala opened Oct 31, 2026Contributor·1 task done·

  ·
  1

• [FLINK-33165][runtime-web] Stop polling and show a notice when the viewed job no longer exists

  #29716·spuru9 opened Oct 31, 2026Contributor·1 task done·

  ·
  1