25 Pull requests merged by 11 people

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

21 Pull requests opened by 14 people

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

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

  #26343 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

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

  #26369 opened Mar 28, 2025

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

  #26370 opened Mar 28, 2025

• [FLINK-37579] Avoid duplicate generate ResourceProfile

  #26371 opened Mar 28, 2025

• [hotfix] Avoid copy Set for variable implementedRpcGateways

  #26372 opened Mar 28, 2025

30 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-37521][runtime] Introduce KeyedCoProcessOperator with async state API

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

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

  #26284 commented on Mar 27, 2025 • 6 new comments

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

  #26326 commented on Mar 25, 2025 • 4 new comments

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

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

• [FLINK-37512] Fix the OOM for SlidingEventTimeWindows

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

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

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

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

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

• [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety

  #26332 commented on Mar 21, 2025 • 1 new comment

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

  #26329 commented on Mar 24, 2025 • 0 new comments

• [hotfix] Correct the comments for FlinkSecurityManager

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

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

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

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

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

• [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows

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

• [FLINK-37504] Handle TLS Certificate Renewal

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  #26203 commented on Mar 27, 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-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module

  #25528 commented on Mar 28, 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-33045][format avro-confluent] disable auto-registering schema in registry

  #25410 commented on Mar 25, 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-5601][Checkpointing] Watermark checkpointing

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