17 Pull requests merged by 10 people

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

24 Pull requests opened by 15 people

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

  #26307 opened Mar 17, 2025

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

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

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

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

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

  #26322 opened Mar 19, 2025

• Cp FLINK-37222

  #26323 opened Mar 20, 2025

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

  #26324 opened Mar 20, 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

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

  #26331 opened Mar 20, 2025

• [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety

  #26332 opened Mar 20, 2025

• [hotfix] Rename the variable `result` to `config`

  #26333 opened Mar 21, 2025

• [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder

  #26334 opened Mar 21, 2025

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

  #26335 opened Mar 21, 2025

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

  #26336 opened Mar 21, 2025

18 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 21, 2025 • 10 new comments

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

  #25837 commented on Mar 21, 2025 • 6 new comments

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

  #26297 commented on Mar 21, 2025 • 4 new comments

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

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

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

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

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

  #26294 commented on Mar 21, 2025 • 2 new comments

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

  #26238 commented on Mar 18, 2025 • 2 new comments

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

  #26196 commented on Mar 16, 2025 • 1 new comment

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

  #26257 commented on Mar 20, 2025 • 1 new comment

• feat: adding service labels to flink config

  #26301 commented on Mar 20, 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 18, 2025 • 0 new comments

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

  #26276 commented on Mar 20, 2025 • 0 new comments

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

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

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

  #26263 commented on Mar 20, 2025 • 0 new comments

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

  #26193 commented on Mar 16, 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

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

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

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

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