All pull requests

Pull requests

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

  #29724·hanyuzheng7 opened Oct 31, 2026Contributor·

  ·
  1

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

  #29723·hanyuzheng7 opened Oct 31, 2026Contributor·

  ·
  1

• [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

• [FLINK-41284][runtime] Return 404 for unknown applications and handle it in the dashboard

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

  ·
  1

• [BP-2.2][hotfix][ci] Run pyflink tests in parallel

  target:release-2.2
  #29714·snuyanzin opened Oct 31, 2026Contributor·

  ·
  1

• [BP-2.2][hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel

  target:release-2.2
  #29711·snuyanzin opened Oct 31, 2026Contributor·

  ·
  1

• [hotfix][state/forst] Do not advance an invalid iterator when reloading the MapState cache

  community-reviewed
  #29707·jayyyyqwq opened Oct 31, 2026·1 task·

  ·
  2

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

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

  ·
  1

• [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin

  community-reviewed
  #29705·bvarghese1 opened Oct 30, 2026Contributor·1 task done·

  ·
  5

• [BP-1.20][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA

  community-reviewedtarget:release-1.20
  #29704·snuyanzin opened Oct 30, 2026Contributor·

  ·
  4

• [BP-2.3][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops

  target:release-2.3
  #29700·spuru9 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

  

• [BP-2.4][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops

  target:release-2.4
  #29699·spuru9 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

  

• [FLINK-41273][table] Support set operations on unbounded tables in the Table API

  #29698·Timm0 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41282][table-planner] Use each multi-join step's own join colu…

  #29697·fresh-borzoni opened Oct 30, 2026Member·

  ·
  2

• [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.2)

  target:release-2.2
  #29696·rionmonster opened Oct 30, 2026Contributor·

  ·
  1

• [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3)

  target:release-2.3
  #29695·rionmonster opened Oct 30, 2026Contributor·

  ·
  1

• [hotfix][runtime] Fix typo 'refering' in process spec javadoc

  community-reviewed-LGTM
  #29691·garvitlnmiit opened Oct 30, 2026·1 task done·

  ·
  2

  

• [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types

  #29690·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  1

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

  community-reviewed
  #29689·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  3

• [FLINK-41279][table] Support the :: infix cast operator

  #29688·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference

  #29684·dylanhz opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41277][tests] test_file_sink.sh hangs in the second OpenSSL linkage run

  #29683·snuyanzin opened Oct 30, 2026Contributor·1 task·

  ·
  2

• [FLINK-41045][e2e] Increase slot request timeout in Kerberized YARN Docker tests

  target:release-1.20
  #29682·spuru9 opened Oct 30, 2026Contributor·1 task done·

  ·
  1