37 Pull requests merged by 20 people

• [FLINK-36420][Formats/Avro] Bump avro from 1.11.3 to 1.11.4

  #25449 merged Oct 4, 2024

• [FLINK-36420][Formats/Avro] Bump avro from 1.11.3 to 1.11.4

  #25448 merged Oct 4, 2024

• [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java.

  #24420 merged Oct 3, 2024

• [FLINK-36181][ci] Use Java 11 to run documentation build

  #25451 merged Oct 3, 2024

• [FLINK-36420][Formats/Avro] Bump avro from 1.11.3 to 1.11.4

  #25447 merged Oct 3, 2024

• [FLINK-36417][table] Add support for hints in WatermarkAssigner

  #25444 merged Oct 3, 2024

• [FLINK-36336] Remove flink-java module

  #25435 merged Oct 3, 2024

• [FLINK-32483][tests] Ensure RescaleCheckpointManuallyITCase always ru…

  #25446 merged Oct 3, 2024

• [FLINK-35709][table-planner] Allow reordering source columns in CTAS and RTAS

  #25401 merged Oct 3, 2024

• [FLINK-36368] Do not prematurely merge CommittableManager

  #25405 merged Oct 2, 2024

• [FLINK-36355][runtime] Remove deprecated interfaces related to window and time

  #25389 merged Oct 2, 2024

• [FLINK-36416][table][runtime] Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API

  #25443 merged Oct 2, 2024

• [FLINK-36415][table] ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense

  #25441 merged Oct 1, 2024

• [FLINK-35928][state/forst] Bump forstjni version to 0.1.2-beta

  #25434 merged Oct 1, 2024

• [FLINK-36355][runtime] Remove deprecated SetupableStreamOperator

  #25407 merged Oct 1, 2024

• [FLINK-36355][runtime] Remove miscellaneous deprecated interfaces related to DataStream

  #25390 merged Oct 1, 2024

• [FLINK-36260][metrics] Fix numBytesInLocal and numBuffersInLocal being reported as remote

  #25438 merged Oct 1, 2024

• [FLINK-36355][runtime] Remove deprecated REST APIs

  #25436 merged Oct 1, 2024

• [FLINK-36336] Remove deprecated dataset API exclude table module

  #25419 merged Oct 1, 2024

• [FLINK-36325][statebackend] Implement basic restore from checkpoint for ForStStateBackend

  #25397 merged Sep 30, 2024

• [FLINK-36355][runtime] Remove deprecated CLI options

  #25424 merged Sep 30, 2024

• [FLINK-35764][runtime/metrics] Fix TimerGauge producing incorrect results when updating during a measurement

  #25351 merged Sep 30, 2024

• [Flink 36245] Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0

  #25331 merged Sep 30, 2024

• [FLINK-36355][runtime] Remove deprecated metrics

  #25417 merged Sep 30, 2024

• [FLINK-36344][runtime/metrics] Introduce lastCheckpointCompletedTimestamp metric

  #25399 merged Sep 30, 2024

• [hotfix] Compile error of ForStStateExecutor

  #25432 merged Sep 30, 2024

• [hotfix][runtime] Fix concurrency issue in callback runner of async state processing

  #25426 merged Sep 30, 2024

• [FLINK-36310][docs] Remove per-job mode, run-application and scala api related documents

  #25430 merged Sep 30, 2024

• [FLINK-36395][state/forst] Graceful quit for Forst StateBackend

  #25416 merged Sep 30, 2024

• [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend

  #25125 merged Sep 30, 2024

• [FLINK-36362][table] Remove dependency flink-java in table modules

  #25420 merged Sep 30, 2024

• [hotfix] Update the violations to avoid archi test failed

  #25429 merged Sep 30, 2024

• [FLINK-36389][security] Add check in DelegationTokenReceiverRepository for DT enabled flag

  #25412 merged Sep 29, 2024

• [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time

  #25261 merged Sep 29, 2024

• [FLINK-36376] More friendly error or warn message for misconfigured statebackend with async state processing

  #25403 merged Sep 29, 2024

• [FLINK-36373][state/forst] Support dispatch state requests in task thread

  #25408 merged Sep 29, 2024

• [FLINK-36378][table] Fix type extraction bug between java BigDecimal …

  #25404 merged Sep 28, 2024

11 Pull requests opened by 11 people

• [FLINK-36405][runtime][security] Fix startup issues on kerberos clusters.

  #25428 opened Sep 29, 2024

• [W.I.P] Run tests

  #25431 opened Sep 30, 2024

• [FLINK-35202][table] Support the execution of alter materialized table set freshness

  #25437 opened Sep 30, 2024

• Add timestamp_mapping.legacy option to avro-confluent format

  #25439 opened Sep 30, 2024

• [FLINK-36510][runtime] Support partial lineage info collection

  #25440 opened Oct 1, 2024

• [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes

  #25442 opened Oct 1, 2024

• [FLINK-33926][kubernetes]: Allow using job jars in the system classpath in native mode

  #25445 opened Oct 2, 2024

• [runtime-web] chore: update Angular to v15

  #25450 opened Oct 3, 2024

• [FLINK-36423] Fix RichMapPartitionFunction does not invoke open method in KeyedPartitionWindowedStream

  #25452 opened Oct 4, 2024

• [FLINK-36424][yarn] Update deprecated YARN RM/NM callback handlers in YarnResourceManagerDriver

  #25453 opened Oct 4, 2024

• Fixed Flaky test in org.apache.flink.table.planner.plan.hints.stream.StateTtlHintTest#testStateTtlHintWithJoinHint

  #25454 opened Oct 4, 2024

14 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-27355][runtime] Unregister JobManagerRunner after it's closed

  #25027 commented on Oct 3, 2024 • 6 new comments

• [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public

  #25081 commented on Sep 29, 2024 • 1 new comment

• [FLINK-33387][runtime] Introduce the abstraction and the interface about loading

  #25174 commented on Oct 1, 2024 • 1 new comment

• [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling

  #25218 commented on Oct 5, 2024 • 1 new comment

• [FLINK-36064][runtime] Refactor REST API for Client and Operator Coordinator Communication to Use String OperatorUid.

  #25227 commented on Sep 30, 2024 • 1 new comment

• [FLINK-36124][filesystem][s3]Make S3RecoverableFsDataOutputStream.sync not to close the stream

  #25231 commented on Sep 30, 2024 • 1 new comment

• [FLINK-35075][table] Migrate TwoStageOptimizedAggregateRule to java

  #24650 commented on Oct 4, 2024 • 0 new comments

• [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall…

  #24736 commented on Oct 5, 2024 • 0 new comments

• [FLINK-35282][FLINK-35520] PyFlink Support for Apache Beam > 2.49

  #24908 commented on Sep 29, 2024 • 0 new comments

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

  #25114 commented on Oct 2, 2024 • 0 new comments

• [FLINK-36335][runtime] Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext

  #25366 commented on Sep 29, 2024 • 0 new comments

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

  #25410 commented on Oct 3, 2024 • 0 new comments

• [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component

  #25414 commented on Sep 29, 2024 • 0 new comments

• [FLINK-36399][table] Fix incorrect cast behavior.

  #25418 commented on Sep 29, 2024 • 0 new comments