24 Pull requests merged by 14 people

• [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program

  #26673 merged Jun 13, 2025

• [Flink-37703][hadoop] Add more log info to locate the root cause of failed HadoopRecoverableWriterTest#testRecoverFromIntermWithoutAdditionalState in azure cron pipeline

  #26646 merged Jun 13, 2025

• [FLINK-37894][table] Introduce Index in CatalogTable

  #26632 merged Jun 12, 2025

• [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation

  #26378 merged Jun 12, 2025

• [FLINK-37916][table] Add StreamPhysicalMultiJoin

  #26664 merged Jun 12, 2025

• [FLINK-37933][table] Move TransformationScan/SinkProvider out of planner

  #26656 merged Jun 12, 2025

• [FLINK-37896][table-planner] Introduce a new trait derived from sink to source to check whether the downstream operators can accept duplicate data

  #26648 merged Jun 12, 2025

• [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect …

  #26669 merged Jun 12, 2025

• [FLINK-37928][table] Forbid cdc-stream for ML_PREDICT

  #26659 merged Jun 11, 2025

• [FLINK-37899][table] Use only producedBeforeRestore in CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG

  #26658 merged Jun 11, 2025

• [FLINK-37903][table] Support to use runtime config in ML_PREDICT

  #26654 merged Jun 11, 2025

• [FLINK-37876][table] Introduce async execution controller for key ordered in table runtime

  #26617 merged Jun 11, 2025

• [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM

  #26592 merged Jun 11, 2025

• [hotfix] Use correct FlinkVersion.v2_1

  #26661 merged Jun 10, 2025

• [FLIP-516][FLINK-37910][table] Add StreamExecMultiJoin

  #26647 merged Jun 10, 2025

• [FLINK-37935][table] Allow to read WindowingStrategy by downstream projects

  #26657 merged Jun 10, 2025

• [FLINK-37920][table] Reuse same util for AsyncCalc, AsyncLookupJoin a…

  #26653 merged Jun 10, 2025

• [FLINK-37901][table] Support to serde for StreamExecMLPredictTableFunction

  #26641 merged Jun 10, 2025

• [FLINK-37862][table] Support inline structured types in SQL

  #26638 merged Jun 10, 2025

• [FLINK-37875][table] Introduce key ordered async lookup join in planner

  #26616 merged Jun 10, 2025

• [FLINK-37814][table-planner] Add FlinkRightJoinToLeftJoinRule

  #26627 merged Jun 9, 2025

• [FLINK-37822][tests] Fix flaky test: OpenTelemetryMetricReporterITCase.testReport

  #26650 merged Jun 9, 2025

• [FLINK-37899][table] Stabilize JoinRestoreTest

  #26643 merged Jun 8, 2025

• [FLINK-37884][tests] Re-generate violations for CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API

  #26625 merged Jun 7, 2025

18 Pull requests opened by 15 people

• [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend

  #26651 opened Jun 8, 2025

• [FLINK-37799][model] Support OpenAI Model Function

  #26652 opened Jun 9, 2025

• [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL

  #26655 opened Jun 9, 2025

• [FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail

  #26660 opened Jun 10, 2025

• [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry

  #26662 opened Jun 10, 2025

• [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment.

  #26663 opened Jun 10, 2025

• Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test

  #26665 opened Jun 10, 2025

• [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config

  #26666 opened Jun 10, 2025

• [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function

  #26667 opened Jun 10, 2025

• [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join

  #26668 opened Jun 11, 2025

• [FLINK-37946][doc] fix sql syntax of page Table API & SQL EXPLAIN

  #26670 opened Jun 11, 2025

• [FLINK-37799][model][docs] Add document for OpenAI Model Function

  #26671 opened Jun 12, 2025

• [FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow

  #26675 opened Jun 12, 2025

• [FLINK-37938] ml_evaluation accumulator implementation

  #26676 opened Jun 13, 2025

• FLINK-37953: Add OBF password obfuscation support for SSL configurations

  #26677 opened Jun 13, 2025

• POC removing unaligned checkpoint flag from StreamConfig

  #26678 opened Jun 13, 2025

• [FLINK-37897][table-planner] Support converting a regular join to a delta join for the simplest pattern in planner

  #26679 opened Jun 13, 2025

• [FLINK-37935][table] Allow to read WindowingStrategy by downstream projects

  #26680 opened Jun 13, 2025

26 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• [FLINK-37794] ml_evaluate function

  #26644 commented on Jun 12, 2025 • 22 new comments

• [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader

  #26640 commented on Jun 13, 2025 • 12 new comments

• [FLINK-37548] Add Model DDL methods in TABLE API

  #26385 commented on Jun 13, 2025 • 9 new comments

• [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type

  #26567 commented on Jun 13, 2025 • 7 new comments

• Fix documentation issue regarding to createTemporalTableFunction params

  #26645 commented on Jun 12, 2025 • 1 new comment

• [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2

  #26620 commented on Jun 12, 2025 • 1 new comment

• [FLINK-37865] Adds documentation for AsyncTableFunction

  #26611 commented on Jun 10, 2025 • 1 new comment

• [FLINK-34094] Adds documentation for AsyncScalarFunction

  #26610 commented on Jun 10, 2025 • 1 new comment

• [FLINK-37591][table] Add some PruneEmptyRules

  #25826 commented on Jun 10, 2025 • 1 new comment

• [FLINK-37595][table] Add Join Remove Rules

  #25932 commented on Jun 11, 2025 • 1 new comment

• [FLINK-37898][table] Implement delta join operator

  #26649 commented on Jun 12, 2025 • 0 new comments

• [FLINK-35458][test][type] Add serializer upgrade test for set serializer

  #26445 commented on Jun 12, 2025 • 0 new comments

• [FLINK-37660] Reenable Kryo serializer upgrade tests

  #26443 commented on Jun 12, 2025 • 0 new comments

• [FLINK-37478] Adding service labels to flink config

  #26301 commented on Jun 13, 2025 • 0 new comments

• Bump esbuild and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard

  #26295 commented on Jun 13, 2025 • 0 new comments

• Aec pr for diff

  #26288 commented on Jun 12, 2025 • 0 new comments

• [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters

  #26201 commented on Jun 9, 2025 • 0 new comments

• [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False

  #26162 commented on Jun 9, 2025 • 0 new comments

• [FLINK-37245] Prevent masking null values in BinaryRowData

  #26100 commented on Jun 12, 2025 • 0 new comments

• [FLINK-37593][table] Add some Reduce Expression Rules

  #25825 commented on Jun 11, 2025 • 0 new comments

• [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler

  #25734 commented on Jun 9, 2025 • 0 new comments

• [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler.

  #25517 commented on Jun 7, 2025 • 0 new comments

• [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler

  #25510 commented on Jun 7, 2025 • 0 new comments

• [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler

  #25504 commented on Jun 9, 2025 • 0 new comments

• [FLINK-34587][table] Introduce MODE aggregate function

  #24443 commented on Jun 13, 2025 • 0 new comments

• [FLINK-31070][Table SQL/Client] Update jline from 3.21.0 to 3.22.0

  #21935 commented on Jun 8, 2025 • 0 new comments