18 Pull requests merged by 11 people

• [FLINK-38017][release] Add release note for release 2.1

  #26778 merged Jul 19, 2025

• [FLINK-38113][runtime] Rethrow fatal (including OOM) errors in Execution.deploy

  #26804 merged Jul 17, 2025

• [FLINK-37913][table] Add built-in OBJECT_OF function

  #26704 merged Jul 17, 2025

• [FLINK-38098][Runtime] Fix JobClientHeartbeatRequestBody deserialization error

  #26800 merged Jul 17, 2025

• [BP-2.0][FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying

  #26759 merged Jul 17, 2025

• [FLINK-38073][docs] Add documentation for the MultiJoin operator

  #26775 merged Jul 17, 2025

• [FLINK-38103][table] Fix error for inline structured types in DataTypeFactory

  #26799 merged Jul 15, 2025

• [FLINK-38091] Bump japicmp configuration post 1.20.2

  #26787 merged Jul 15, 2025

• [FLINK-38092] Bump japicmp configuration post 1.19.3

  #26786 merged Jul 15, 2025

• [FLINK-38103][table] Fix error for inline structured types in DataTypeFactory

  #26797 merged Jul 15, 2025

• [FLINK-37701][flink-runtime] Backporting of the fix to 2.0 for AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment.

  #26796 merged Jul 15, 2025

• [FLINK-38090][table] Align data type of inline structured types for TableResult.collect()

  #26795 merged Jul 14, 2025

• [FLINK-38090][table] Align data type of inline structured types for TableResult.collect()

  #26784 merged Jul 14, 2025

• [FLINK-38081][table] Support EXPLAIN before EXECUTE statement

  #26785 merged Jul 14, 2025

• [FLINK-38068][model] Build uber jar for open-ai model (#26770)

  #26782 merged Jul 14, 2025

• [BP-2.1][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790 #26791

  #26792 merged Jul 14, 2025

• [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally

  #26779 merged Jul 13, 2025

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

  #26301 merged Jul 12, 2025

13 Pull requests opened by 11 people

• [BP-2.0][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally

  #26790 opened Jul 13, 2025

• [BP-1.20][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790

  #26791 opened Jul 13, 2025

• [FLINK-38044][runtime-web] update angular to v19

  #26801 opened Jul 16, 2025

• [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL

  #26802 opened Jul 16, 2025

• [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging

  #26803 opened Jul 16, 2025

• [FLINK-38044][runtime-web] update angular to v20

  #26805 opened Jul 17, 2025

• [FLINK-37914][table] Add built-in OBJECT_UPDATE function

  #26806 opened Jul 17, 2025

• [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction

  #26807 opened Jul 17, 2025

• Bump on-headers and compression in /flink-runtime-web/web-dashboard

  #26808 opened Jul 17, 2025

• [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN

  #26809 opened Jul 18, 2025

• [FLINK-37973][table-planner] Add support for right joins to multijoin operator

  #26810 opened Jul 18, 2025

• [FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set

  #26811 opened Jul 18, 2025

• [hotfix][docs]Fix kafka doc properties table error

  #26812 opened Jul 19, 2025

113 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.

• Add Kafka-to-Kafka SQL Example to Documentation

  #26789 commented on Jul 18, 2025 • 9 new comments

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

  #26567 commented on Jul 18, 2025 • 4 new comments

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

  #25734 commented on Jul 14, 2025 • 4 new comments

• [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage

  #26781 commented on Jul 19, 2025 • 2 new comments

• [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception

  #26776 commented on Jul 19, 2025 • 1 new comment

• [FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES

  #26783 commented on Jul 19, 2025 • 1 new comment

• [hotfix] ELEMENT should throw TableRuntimeException

  #26719 commented on Jul 18, 2025 • 1 new comment

• [FLINK-38069] Fix return type nullability diffs of function ENCODE & DECODE in SQL and Table API

  #26771 commented on Jul 16, 2025 • 1 new comment

• [FLINK-37689] Improve the comments and variable names for TaskMailbox

  #26469 commented on Jul 18, 2025 • 0 new comments

• [FLINK-36465] Bump okhttp3 to 4.12.0

  #26472 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37308] Support pauseOrResumeSplits in HybridSource

  #26483 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot

  #26498 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph

  #26500 commented on Jul 18, 2025 • 0 new comments

• [FLINK-36659][docs] Update Kafka connector docs for 4.0.0

  #26501 commented on Jul 18, 2025 • 0 new comments

• [hotfix] Avoid duplicate operation !

  #26512 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37722] Eliminate redundant field initialization of PojoSerializer

  #26513 commented on Jul 18, 2025 • 0 new comments

• [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source

  #26514 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37746] Added serialVersionUID in MapTypeInfo class

  #26515 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37730][rest] Add client method for getting JM exception history

  #26525 commented on Jul 18, 2025 • 0 new comments

• [FLINK-38086][table] Make ChangelogNormalize reusable if possible

  #26780 commented on Jul 19, 2025 • 0 new comments

• [hotfix] Avoid invalid thread for state reader

  #26465 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37672] Bump protobuf-maven-plugin

  #26464 commented on Jul 15, 2025 • 0 new comments

• [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state

  #26463 commented on Jul 18, 2025 • 0 new comments

• [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0

  #26459 commented on Jul 15, 2025 • 0 new comments

• [FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec…

  #26450 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37661] Remove Kryo serializer reference data from version 1.x

  #26444 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37655][runtime] Convert WindowStagger into an interface

  #26441 commented on Jul 18, 2025 • 0 new comments

• [FLINK-35466][table] Implement star expansion in function calls in SE…

  #26438 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations

  #26434 commented on Jul 14, 2025 • 0 new comments

• [FLINK-35571][test] Can pass global test

  #26431 commented on Jul 18, 2025 • 0 new comments

• [hotfix] Rename loadJarFile to checkJarFile

  #26427 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37637] Avoid dead lock for Configuration's addAll

  #26426 commented on Jul 18, 2025 • 0 new comments

• [hotfix] Remove the redundant config for execution target

  #26425 commented on Jul 18, 2025 • 0 new comments

• [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

  #26777 commented on Jul 19, 2025 • 0 new comments

• [hotfix][docs] Update build documentation to require Java 17

  #26773 commented on Jul 19, 2025 • 0 new comments

• [hotfix] Adds Override annotation

  #26772 commented on Jul 19, 2025 • 0 new comments

• [FLINK-38050][UI] Correct Flink UI Dropdown Width

  #26768 commented on Jul 19, 2025 • 0 new comments

• [BP-2.0][FLINK-37422][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt

  #26763 commented on Jul 18, 2025 • 0 new comments

• [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group

  #26761 commented on Jul 19, 2025 • 0 new comments

• Update nightly-trigger.yml

  #26754 commented on Jul 19, 2025 • 0 new comments

• Enhance Javadoc documentation for WordCount Tokenizer class

  #26751 commented on Jul 19, 2025 • 0 new comments

• Add input validation to WordCount Tokenizer for robustness

  #26750 commented on Jul 18, 2025 • 0 new comments

• Use isEmpty() instead of length() > 0 in WordCount Tokenizer

  #26749 commented on Jul 18, 2025 • 0 new comments

• [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs.

  #26681 commented on Jul 18, 2025 • 0 new comments

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

  #26667 commented on Jul 18, 2025 • 0 new comments

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

  #26662 commented on Jul 18, 2025 • 0 new comments

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

  #26651 commented on Jul 18, 2025 • 0 new comments

• Fix documentation issue regarding to createTemporalTableFunction params

  #26645 commented on Jul 18, 2025 • 0 new comments

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

  #26640 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37865] Adds documentation for AsyncTableFunction

  #26611 commented on Jul 17, 2025 • 0 new comments

• [FLINK-34094] Adds documentation for AsyncScalarFunction

  #26610 commented on Jul 17, 2025 • 0 new comments

• [hotfix]Adds Override annotation

  #26604 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp

  #26594 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37827][table] Fix use `SHOW CREATE TABLE` for MATERIALIZED_TABLE

  #26584 commented on Jul 17, 2025 • 0 new comments

• [hotfix] Fix invalid comments in Committer

  #26578 commented on Jul 17, 2025 • 0 new comments

• [FLINK-35854][table] Upgrade Calcite version to 1.35.0

  #26547 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend

  #26538 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37162][hotfix][docs] Update some inaccurate descriptions.

  #26223 commented on Jul 17, 2025 • 0 new comments

• [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java`

  #26219 commented on Jul 17, 2025 • 0 new comments

• [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese

  #26196 commented on Jul 17, 2025 • 0 new comments

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

  #26162 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type

  #26155 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS.

  #26102 commented on Jul 15, 2025 • 0 new comments

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

  #26100 commented on Jul 17, 2025 • 0 new comments

• [FLINK-31275] extend lineage listener with QueryOperationEvent

  #26089 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors

  #26029 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37121][docs] Fix syntax and examples in create table statement doc

  #25982 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37088][k8s]support flink applicaton taskmanager log mounting

  #25944 commented on Jul 17, 2025 • 0 new comments

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

  #25825 commented on Jul 17, 2025 • 0 new comments

• [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark.

  #25629 commented on Jul 17, 2025 • 0 new comments

• [FLINK-30284][flink-metrics] Adding datacenter url property to datadog

  #25592 commented on Jul 17, 2025 • 0 new comments

• [FLINK-36161][docs]Update Integration Test Example with Sink API.

  #25590 commented on Jul 17, 2025 • 0 new comments

• [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module

  #25528 commented on Jul 17, 2025 • 0 new comments

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

  #25510 commented on Jul 17, 2025 • 0 new comments

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

  #25504 commented on Jul 17, 2025 • 0 new comments

• add array aggregate function

  #25275 commented on Jul 17, 2025 • 0 new comments

• [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format

  #25114 commented on Jul 17, 2025 • 0 new comments

• [FLINK-35704] Use ForkJoinPool in NonSplittingRecursiveEnumerator

  #24986 commented on Jul 16, 2025 • 0 new comments

• [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions

  #24826 commented on Jul 17, 2025 • 0 new comments

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

  #24443 commented on Jul 17, 2025 • 0 new comments

• [FLINK-33449][table]Support array_contains_seq function

  #23656 commented on Jul 17, 2025 • 0 new comments

• [FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url.

  #23610 commented on Jul 17, 2025 • 0 new comments

• [FLINK-32738][formats] PROTOBUF format supports projection push down

  #23323 commented on Jul 17, 2025 • 0 new comments

• [hotfix] [docs] fix scala code

  #21760 commented on Jul 17, 2025 • 0 new comments

• [hotfix] [docs] fix link URL to DataStream operators

  #21285 commented on Jul 17, 2025 • 0 new comments

• [hotfix] Unify the name for the collection of SlotOffer with slotOffers

  #26418 commented on Jul 18, 2025 • 0 new comments

• [hotfix] Rename registeredSlots to allocatedSlots

  #26417 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37618][table-planner] Fix PTFs INTERVAL argument

  #26410 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context

  #26381 commented on Jul 18, 2025 • 0 new comments

• [FLINK-37581] Avoid duplicate calculation for total Flink memory

  #26373 commented on Jul 17, 2025 • 0 new comments

• [hotfix] Simplify the calling on addShutdownHook

  #26363 commented on Jul 17, 2025 • 0 new comments

• [hotfix] Rename prefix to tag for FileChannelManagerImpl

  #26362 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator

  #26357 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37549][table][docs]: Fix some scala and markdown syntax errors in tableApi page

  #26341 commented on Jul 17, 2025 • 0 new comments

• [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety

  #26332 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust…

  #26330 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules

  #26329 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37522][docs] Add description for the config about file system connection limit

  #26326 commented on Jul 17, 2025 • 0 new comments

• [hotfix] Correct the comments for FlinkSecurityManager

  #26325 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows

  #26319 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese

  #26312 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server

  #26311 commented on Jul 17, 2025 • 0 new comments

• [FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction

  #26297 commented on Jul 17, 2025 • 0 new comments

• Aec pr for diff

  #26288 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions

  #26284 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor`

  #26278 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value.

  #26277 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37431]We should use guava Lists instead of curator shade Lists…

  #26263 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37427] Fix incorrect NPE message in StandaloneHaServices constructor

  #26258 commented on Jul 17, 2025 • 0 new comments

• [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads

  #26257 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37422][docs] Fix typo in streaming analytics zh document

  #26249 commented on Jul 17, 2025 • 0 new comments

• [FLINK-37403] Convert interval join to regular join for updating source

  #26230 commented on Jul 17, 2025 • 0 new comments

• [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire

  #26229 commented on Jul 17, 2025 • 0 new comments