95 Pull requests merged by 37 people

• [FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram

  #26374 merged Mar 31, 2025

• [FLINK-37584] Bump assertj-core

  #26376 merged Mar 31, 2025

• [BP-2.0][FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph.

  #26370 merged Mar 31, 2025

• [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph.

  #26369 merged Mar 31, 2025

• [hotfix] Replacing manual comparison logic with Long#compare

  #26343 merged Mar 28, 2025

• [FLINK-37408] Update all docker-compose references to docker compose

  #26239 merged Mar 28, 2025

• [FLINK-37556][metrics][otel][BP-2.0] Add missing dependencies for OpenTelemetry

  #26365 merged Mar 28, 2025

• [FLINK-37556][metrics][otel] Add missing dependencies for OpenTelemetry

  #26348 merged Mar 28, 2025

• [FLINK-37533][CI] Add action: write permission to stale PR github action

  #26360 merged Mar 27, 2025

• [FLINK-37568] Improve the method flatten of class GlobalConfiguration

  #26359 merged Mar 27, 2025

• [FLINK-37493][release] Update japicmp configuration for 2.0.0

  #26344 merged Mar 27, 2025

• [FLINK-37490][Release] Add 2.0 to PreviousDocs list

  #26345 merged Mar 27, 2025

• [FLINK-37426][FLIP-481] Introduce Event Reporting

  #26316 merged Mar 26, 2025

• [FLINK-37533][CI] Reduce the stale PR github action timeouts

  #26336 merged Mar 26, 2025

• [FLINK-37410][runtime/metrics] Split level Watermark metrics

  #26276 merged Mar 26, 2025

• [FLINK-37557][bp-1.20] Fix ResolvedSchema#getPrimaryKeyIndexes

  #26351 merged Mar 26, 2025

• [FLINK-37557][bp 2.0] Fix ResolvedSchema#getPrimaryKeyIndexes

  #26352 merged Mar 26, 2025

• [FLINK-36443][table][test] Improve flaky table source sink tests

  #26335 merged Mar 26, 2025

• [hotfix][clients] Refactor PackagedProgram#getJobJarAndDependencies to reduce some redundant lines.

  #26238 merged Mar 26, 2025

• [FLINK-37482] Improve the code for PrintSinkOutputWriter, PrintSinkFunction and PrintSink

  #26309 merged Mar 26, 2025

• [hotfix] Simplify the variable checkpointStatsSnapshotCacheExpireAfterWrite

  #26349 merged Mar 26, 2025

• [hotfix] Rename JobRestEndpointFactory to ApplicationRestEndpointFactory

  #26347 merged Mar 26, 2025

• [hotfix] Remove redundant config operation for ADDRESS and PORT

  #26342 merged Mar 26, 2025

• [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes

  #26350 merged Mar 25, 2025

• [hotfix] Rename the variable result to config

  #26333 merged Mar 25, 2025

• [hotfix] Preconditions.checkState should follows the Flink code style

  #26340 merged Mar 25, 2025

• [FLINK-37423][table] Support PTFs in Table API

  #26331 merged Mar 24, 2025

• [FLINK-37491][release] Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs

  #26322 merged Mar 24, 2025

• [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView

  #26323 merged Mar 24, 2025

• [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationC…

  #26324 merged Mar 24, 2025

• [FLINK-37475] Drop ChangelogNormalize for piping from upsert source to sink

  #26306 merged Mar 21, 2025

• [FLINK-37460][state] Make state processor API checkpoint ID configurable

  #26299 merged Mar 20, 2025

• [FLINK-37505][python] Add pyflink YAML based config support

  #26327 merged Mar 20, 2025

• [FLINK-37505][python] Add pyflink YAML based config support

  #26318 merged Mar 20, 2025

• [hotfix] Remove unnecessary InternalPriorityQueue

  #26315 merged Mar 20, 2025

• [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView if view is created by SQL

  #26314 merged Mar 20, 2025

• [FLINK-37412] Add MIN_RESOURCES TaskManagerLoadBalanceMode to maximize TM usage

  #26308 merged Mar 19, 2025

• [hotfix][doc] two modes instead of three

  #26300 merged Mar 19, 2025

• [FLINK-37463] make serialzer in ForStMapState Threadlocal

  #26286 merged Mar 19, 2025

• [FLINK-37243] Adds main thread callback to AsyncWaitOperator

  #26122 merged Mar 18, 2025

• [FLINK-37480][build] Bump japicmp to avoid false positives

  #26304 merged Mar 17, 2025

• [FLINK-37480][build] Bump japicmp to avoid false positives

  #26305 merged Mar 17, 2025

• [FLINK-30687][table] Fix wrong result of agg with fiter which references first input column

  #26302 merged Mar 17, 2025

• [FLINK-30687][table] Fix wrong result of agg with fiter which references first input column

  #26303 merged Mar 17, 2025

• [FLINK-37438] Improve the createLocalEnvironment by reduce duplicate operation on Configuration

  #26273 merged Mar 17, 2025

• [FLINK-30687][table] Fix wrong result of agg with fiter which references first input column

  #26296 merged Mar 17, 2025

• [FLINK-37432][release] Add release note for release 2.0

  #26266 merged Mar 17, 2025

• [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API

  #26281 merged Mar 14, 2025

• [FLINK-37460][state] Make state processor API checkpoint ID configurable

  #26285 merged Mar 14, 2025

• [FLINK-37457][python] Support asArgument in Python Table API

  #26292 merged Mar 13, 2025

• [FLINK-37466][table-api-java] Make DEFAULT explicit from Table API to planner

  #26290 merged Mar 13, 2025

• Revert "[FLINK-37158][tests] Introduce ForSt to existing ITCases

  #26291 merged Mar 13, 2025

• [FLINK-37446][table-api-java] Support named arguments in Table API

  #26282 merged Mar 12, 2025

• [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators

  #26283 merged Mar 12, 2025

• [FLINK-37158][tests] Introduce ForSt to existing ITCases

  #26000 merged Mar 12, 2025

• [FLINK-37302][table] Support PTFs with time and timer services

  #26250 merged Mar 10, 2025

• [FLINK-37381] [doc] Fix typo in Join document

  #26209 merged Mar 10, 2025

• [BP-2.0][FLINK-37439][state/forst] Support file override in wrapped file system

  #26280 merged Mar 10, 2025

• [FLINK-37439][state/forst] Support file override in wrapped file system

  #26279 merged Mar 10, 2025

• [FLINK-36402] edgeRemapings typo fixed to edgeRemappings

  #26275 merged Mar 9, 2025

• [FLINK-36402] edgeRemapings typo fixed to edgeRemappings

  #26220 merged Mar 8, 2025

• [BP-2.0][FLINK-37437][state/forst] Fix #exist and #getFileStatus to give the information of writing files

  #26272 merged Mar 8, 2025

• [FLINK-37437][state/forst] Fix #exist and #getFileStatus to give the information of writing files

  #26271 merged Mar 8, 2025

• [hotfix][doc] Fix link display.

  #25977 merged Mar 8, 2025

• [FLINK-37401] Add Job ID to logging context

  #26264 merged Mar 7, 2025

• [BP-2.0][FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend

  #26269 merged Mar 7, 2025

• [FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend

  #26267 merged Mar 7, 2025

• [hotfix] Remove unnecessary exclude in japicmp plugin

  #26261 merged Mar 7, 2025

• [BP-2.0][FLINK-37425] Sanity check before ForSt cache created

  #26254 merged Mar 6, 2025

• [FLINK-37425] Sanity check before ForSt cache created

  #26253 merged Mar 6, 2025

• [BP-2.0][state/forst] Backport commits about forst state to 2.0

  #26262 merged Mar 6, 2025

• [BP-2.0][FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations.

  #26259 merged Mar 6, 2025

• [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations.

  #26202 merged Mar 6, 2025

• [FLINK-37424][release] Using JDK11 for the nightly binary release

  #26260 merged Mar 6, 2025

• [FLINK-37424][release] Using JDK11 for the binary convenience release

  #26251 merged Mar 6, 2025

• [BP-2.0][docs] backports two fixes about documentation

  #26256 merged Mar 6, 2025

• [hotfix][docs] Fix label format in docs for state v2

  #26255 merged Mar 6, 2025

• [hotfix][docs] URL for test-filesystem is wrong in materialized table…

  #26252 merged Mar 6, 2025

• [FLINK-37420] fix AbstractAggregatingState add may return wrong result

  #26246 merged Mar 5, 2025

• [BP-2.0][FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload

  #26248 merged Mar 5, 2025

• [BP-2.0][FLINK-37387][build] Enable license check for jdk17 and jdk21

  #26244 merged Mar 5, 2025

• [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug

  #26242 merged Mar 5, 2025

• [FLINK-35810][BP-2.0] Fix AsyncWaitOperatorTest missing endInput bug

  #26241 merged Mar 5, 2025

• [backport][FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned.

  #26243 merged Mar 4, 2025

• [FLINK-33734] Merge unaligned checkpoint state handle

  #24247 merged Mar 4, 2025

• [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload

  #26237 merged Mar 4, 2025

• [FLINK-21912][pyflink] Introduce ResolvedSchema in Python Table API

  #26121 merged Mar 4, 2025

• [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter …

  #25896 merged Mar 4, 2025

• [FLINK-37402][table] Emit watermarks after record in TestSourceFunction and TestValuesRuntimeFunctions

  #26236 merged Mar 3, 2025

• [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible

  #26051 merged Mar 3, 2025

• [FLINK-37387][build] Enable license check for jdk17 and jdk21

  #26240 merged Mar 3, 2025

• [BP-2.0][FLINK-37148][docs] Update DataStream V2 documents for StateManager#getState and StateManager#getStateOptional methods

  #26234 merged Mar 3, 2025

• [FLINK-37148][docs] Update DataStream V2 documents for StateManager#getState and StateManager#getStateOptional methods

  #26233 merged Mar 3, 2025

• [BP-2.0][FLINK-36172][runtime] Optimize transient metric cleanup

  #26232 merged Mar 1, 2025

• [FLINK-36172][metrics][rest] Optimize transient metric cleanup

  #26204 merged Mar 1, 2025

52 Pull requests opened by 32 people

• [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs

  #26247 opened Mar 4, 2025

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

  #26249 opened Mar 5, 2025

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

  #26257 opened Mar 5, 2025

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

  #26258 opened Mar 6, 2025

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

  #26263 opened Mar 6, 2025

• [FLINK-36652] Upgrade Apache ORC Version to 1.9.4

  #26265 opened Mar 7, 2025

• [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter.

  #26274 opened Mar 8, 2025

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

  #26277 opened Mar 9, 2025

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

  #26278 opened Mar 9, 2025

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

  #26284 opened Mar 11, 2025

• Aec pr for diff

  #26288 opened Mar 12, 2025

• [hotfix][docs] flink docs zh content fix

  #26294 opened Mar 14, 2025

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

  #26295 opened Mar 14, 2025

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

  #26297 opened Mar 14, 2025

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

  #26301 opened Mar 14, 2025

• [FLINK-37197][docs] Update MongoDB docs for 2.0.0 release

  #26307 opened Mar 17, 2025

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

  #26311 opened Mar 18, 2025

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

  #26312 opened Mar 18, 2025

• [FLINK-37481] Add new multi way join operator

  #26313 opened Mar 18, 2025

• [FLINK-37504] Handle TLS Certificate Renewal

  #26317 opened Mar 18, 2025

• [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows

  #26319 opened Mar 19, 2025

• [FLINK-37511][rest] Use Jackson serialization in JobPlanInfo.Plan

  #26320 opened Mar 19, 2025

• [FLINK-37512] Fix the OOM for SlidingEventTimeWindows

  #26321 opened Mar 19, 2025

• [hotfix] Correct the comments for FlinkSecurityManager

  #26325 opened Mar 20, 2025

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

  #26326 opened Mar 20, 2025

• [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API

  #26328 opened Mar 20, 2025

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

  #26329 opened Mar 20, 2025

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

  #26330 opened Mar 20, 2025

• [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety

  #26332 opened Mar 20, 2025

• [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer

  #26339 opened Mar 24, 2025

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

  #26341 opened Mar 25, 2025

• Added Confluent to Vendor Solutions section

  #26346 opened Mar 25, 2025

• [FLINK-37558] Check right variable in addSpan

  #26353 opened Mar 26, 2025

• [FLINK-36443][table][test][bp-2.0] Improve flaky tests related to partition specs

  #26354 opened Mar 26, 2025

• [hotfix][docs] update create table syntax pseudo code

  #26355 opened Mar 26, 2025

• [FLINK-37570][metrics] Export default watermark if split doesn't have any

  #26356 opened Mar 26, 2025

• [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator

  #26357 opened Mar 26, 2025

• Add an example to use PTF

  #26358 opened Mar 27, 2025

• [FLINK-37540][table-planner] Introduce SupportsTargetColumnWriting sink ability

  #26361 opened Mar 27, 2025

• [hotfix] Rename prefix to tag for FileChannelManagerImpl

  #26362 opened Mar 27, 2025

• [hotfix] Simplify the calling on addShutdownHook

  #26363 opened Mar 27, 2025

• [FLINK-37569] Add userKeySerializer in RegisteredKeyValueStateBackend V2

  #26364 opened Mar 27, 2025

• [hotfix] [docs] Fix flink-connector-kafka version in "How to use Maven.." doc of Flink master

  #26366 opened Mar 27, 2025

• [hotfix] Avoid duplicate fetch the size of memory segment

  #26367 opened Mar 28, 2025

• [FLINK-37575] Simplify the code for creating Netty shuffle environment.

  #26368 opened Mar 28, 2025

• [hotfix] Avoid copy Set for variable implementedRpcGateways

  #26372 opened Mar 28, 2025

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

  #26373 opened Mar 28, 2025

• [FLINK-37547][docs] Document PTFs

  #26375 opened Mar 28, 2025

• [FLINK-37579] Avoid duplicate generate ResourceProfile

  #26377 opened Mar 31, 2025

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

  #26378 opened Mar 31, 2025

• [FLINK-37543][table-planner] Support sink reuse in batch mode

  #26379 opened Mar 31, 2025

• [FLINK-37542][table-planner] Support sink reuse in streaming mode

  #26380 opened Mar 31, 2025

33 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-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate

  #25753 commented on Mar 25, 2025 • 20 new comments

• [FLINK-34558][state] Support tracking state size

  #25837 commented on Mar 26, 2025 • 10 new comments

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

  #26223 commented on Mar 4, 2025 • 5 new comments

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

  #26196 commented on Mar 16, 2025 • 4 new comments

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

  #25592 commented on Mar 20, 2025 • 3 new comments

• [FLINK-35014] SqlNode to operation conversion for models

  #25834 commented on Mar 26, 2025 • 3 new comments

• [hotfix][tests] Use Junit5 import in FileSinkTest.

  #26193 commented on Mar 16, 2025 • 3 new comments

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

  #26230 commented on Mar 6, 2025 • 2 new comments

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

  #26162 commented on Mar 11, 2025 • 1 new comment

• [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java

  #25881 commented on Mar 26, 2025 • 1 new comment

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

  #26219 commented on Mar 2, 2025 • 1 new comment

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

  #26201 commented on Mar 11, 2025 • 0 new comments

• [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26.

  #26160 commented on Mar 11, 2025 • 0 new comments

• Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive

  #26158 commented on Mar 17, 2025 • 0 new comments

• Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10

  #26090 commented on Mar 4, 2025 • 0 new comments

• [FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator

  #26203 commented on Mar 27, 2025 • 0 new comments

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

  #26229 commented on Mar 6, 2025 • 0 new comments

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

  #25734 commented on Mar 27, 2025 • 0 new comments

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

  #25590 commented on Mar 3, 2025 • 0 new comments

• [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length

  #25576 commented on Mar 11, 2025 • 0 new comments

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

  #25528 commented on Mar 31, 2025 • 0 new comments

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

  #25517 commented on Mar 27, 2025 • 0 new comments

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

  #25510 commented on Mar 23, 2025 • 0 new comments

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

  #25504 commented on Mar 11, 2025 • 0 new comments

• [FLINK-33045][format avro-confluent] disable auto-registering schema in registry

  #25410 commented on Mar 25, 2025 • 0 new comments

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

  #25340 commented on Mar 29, 2025 • 0 new comments

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

  #24443 commented on Mar 14, 2025 • 0 new comments

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

  #23323 commented on Mar 13, 2025 • 0 new comments

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

  #21935 commented on Mar 9, 2025 • 0 new comments

• [FLINK-26944][Table SQL/API] Add ADD_MONTHS supported in SQL and Table API

  #20323 commented on Mar 22, 2025 • 0 new comments

• Add support to pass Datadog API Key as environment variable

  #19684 commented on Mar 26, 2025 • 0 new comments

• [FLINK-18590][json] Support json array explode to multi messages

  #13081 commented on Mar 10, 2025 • 0 new comments

• [FLINK-5601][Checkpointing] Watermark checkpointing

  #7013 commented on Mar 27, 2025 • 0 new comments