23 Pull requests merged by 14 people

• [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [2.0]

  #26456 merged Apr 16, 2025

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

  #26307 merged Apr 16, 2025

• [FLINK-37670][runtime] Fix watermark alignment can deadlock job if there are no more splits to be assigned (1.20)

  #26467 merged Apr 16, 2025

• [FLINK-37670][runtime] Fix watermark alignment can deadlock job if there are no more splits to be assigned (2.0)

  #26468 merged Apr 16, 2025

• [FLINK-37668][state] Make compaction filter related config take effect for RocksDBStateBackend & ForStStateBackend

  #26451 merged Apr 16, 2025

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

  #26361 merged Apr 16, 2025

• [FLINK-37670][runtime] Fix watermark alignment can deadlock job if there are no more splits to be assigned

  #26453 merged Apr 15, 2025

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

  #26274 merged Apr 15, 2025

• [FLINK-37638] Avoid duplicate call on getEffectiveConfiguration

  #26428 merged Apr 15, 2025

• [BP-2.0][FLINK-37623][datastream] Async state support for process() in Datastream API

  #26439 merged Apr 15, 2025

• [FLINK-37605][runtime] Infer checkpoint id on endInput in sink

  #26433 merged Apr 14, 2025

• [FLINK-37671] Fix ChangelogMode#toString

  #26452 merged Apr 14, 2025

• [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend

  #26440 merged Apr 14, 2025

• [FLINK-37649][datagen] Datagen connector cannot set length for collection type

  #26437 merged Apr 14, 2025

• [1.19][FLINK-37664][docs] Integrate Kudu connector docs

  #26447 merged Apr 12, 2025

• [1.20][FLINK-37664][docs] Integrate Kudu connector docs

  #26448 merged Apr 12, 2025

• [hotfix] Avoid duplicate call on checkNotNull while calling fromProgramOptions

  #26429 merged Apr 11, 2025

• [FLINK-37643] Support partial deletes when converting to external data structures

  #26436 merged Apr 11, 2025

• [FLINK-37623][datastream] Async state support for process() in Datastream API

  #26419 merged Apr 11, 2025

• [FLINK-37642][runtime] Use the mailboxExecutor for operator in Async state processing

  #26435 merged Apr 10, 2025

• [FLINK-37610] Check if orderBy keys exists before accessing

  #26407 merged Apr 10, 2025

• [FLINK-37603] QueryOperation SQL Serialization customization

  #26389 merged Apr 10, 2025

• [hotfix] [docs] Typo fix in several docs

  #26432 merged Apr 10, 2025

22 Pull requests opened by 13 people

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

  #26438 opened Apr 10, 2025

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

  #26441 opened Apr 11, 2025

• [FLINK-37659][release] Generate reference data for state migration tests based on release-2.0.0

  #26442 opened Apr 11, 2025

• [FLINK-37660] Reenable Kryo serializer upgrade tests

  #26443 opened Apr 11, 2025

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

  #26444 opened Apr 11, 2025

• [FLINK-35458][test][type] Add serializer upgrade test for set serializer

  #26445 opened Apr 11, 2025

• [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup

  #26446 opened Apr 11, 2025

• [FLINK-37665]: Simplify DoubleMaximum.clone() Implementation

  #26449 opened Apr 13, 2025

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

  #26450 opened Apr 13, 2025

• [hotfix] Rename executionVertexId to executionVertex

  #26454 opened Apr 14, 2025

• [FLINK-37658][docs] Improve the Datagen connector docs

  #26455 opened Apr 14, 2025

• [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.20]

  #26457 opened Apr 14, 2025

• [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.19]

  #26458 opened Apr 14, 2025

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

  #26459 opened Apr 15, 2025

• [FLINK-37680][serializer] Add subclass cache for PojoSerializer

  #26461 opened Apr 15, 2025

• [hotfix] Remove unnecessary method override for method invoke

  #26462 opened Apr 15, 2025

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

  #26463 opened Apr 15, 2025

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

  #26464 opened Apr 15, 2025

• [hotfix] Avoid invalid thread for state reader

  #26465 opened Apr 16, 2025

• [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend

  #26466 opened Apr 16, 2025

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

  #26469 opened Apr 16, 2025

• [hotfix][runtime] Remove the redundant 'format' calling.

  #26470 opened Apr 17, 2025

40 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-37543][table-planner] Support sink reuse in batch mode

  #26379 commented on Apr 17, 2025 • 15 new comments

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

  #26313 commented on Apr 17, 2025 • 10 new comments

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

  #25837 commented on Apr 16, 2025 • 6 new comments

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

  #26378 commented on Apr 15, 2025 • 4 new comments

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

  #26431 commented on Apr 17, 2025 • 2 new comments

• [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse

  #26430 commented on Apr 16, 2025 • 2 new comments

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

  #26426 commented on Apr 15, 2025 • 2 new comments

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

  #26155 commented on Apr 15, 2025 • 1 new comment

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

  #26381 commented on Apr 13, 2025 • 1 new comment

• [FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate

  #26424 commented on Apr 10, 2025 • 1 new comment

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

  #23656 commented on Apr 15, 2025 • 1 new comment

• [FLINK-37548] Add Model DDL methods in TABLE API

  #26385 commented on Apr 10, 2025 • 0 new comments

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

  #26410 commented on Apr 13, 2025 • 0 new comments

• [hotfix] Remove the redundant config for execution target

  #26425 commented on Apr 11, 2025 • 0 new comments

• [hotfix] Correct the comments for FlinkSecurityManager

  #26325 commented on Apr 16, 2025 • 0 new comments

• [FLINK-37512] Fix the OOM for SlidingEventTimeWindows

  #26321 commented on Apr 16, 2025 • 0 new comments

• [hotfix] Rename loadJarFile to checkJarFile

  #26427 commented on Apr 11, 2025 • 0 new comments

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

  #26301 commented on Apr 15, 2025 • 0 new comments

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

  #26247 commented on Apr 10, 2025 • 0 new comments

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

  #26203 commented on Apr 11, 2025 • 0 new comments

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

  #26434 commented on Apr 10, 2025 • 0 new comments

• [FLINK-20454][format][debezium] Allow to read metadata for debezium-avro-confluent format

  #18744 commented on Apr 16, 2025 • 0 new comments

• Add support to pass Datadog API Key as environment variable

  #19684 commented on Apr 11, 2025 • 0 new comments

• [hotfix] [docs] fix scala code

  #21760 commented on Apr 16, 2025 • 0 new comments

• [FLINK-26760][flink-csv] The new CSV source (file system source + CSV…

  #24221 commented on Apr 10, 2025 • 0 new comments

• [FLINK-35704] Use ForkJoinPool in NonSplittingRecursiveEnumerator

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

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

  #25081 commented on Apr 12, 2025 • 0 new comments

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

  #25114 commented on Apr 16, 2025 • 0 new comments

• [FLINK-36160] Support hive advanced configuration

  #25258 commented on Apr 14, 2025 • 0 new comments

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

  #25445 commented on Apr 10, 2025 • 0 new comments

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

  #25510 commented on Apr 12, 2025 • 0 new comments

• FLINK-36485 remove deprecated method fromDataStream

  #25523 commented on Apr 16, 2025 • 0 new comments

• [FLINK-36487] Remove deprecated method createTemporaryView StreamTableE…

  #25524 commented on Apr 10, 2025 • 0 new comments

• FLINK-36479 remove deprecated method Table getSchema as

  #25540 commented on Apr 10, 2025 • 0 new comments

• [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager

  #25607 commented on Apr 10, 2025 • 0 new comments

• [FLINK-xx][table] Remove RelBuilder

  #25823 commented on Apr 11, 2025 • 0 new comments

• [hotfix][docs] Fix Apache Avro Specification Link

  #25850 commented on Apr 11, 2025 • 0 new comments

• [FLINK-36746] Fix the deadlock bug when initializing SerializedThrowable object.

  #25870 commented on Apr 15, 2025 • 0 new comments

• [FLINK-36988][table] Migrate LogicalCorrelateToJoinFromTemporalTableF…

  #25882 commented on Apr 15, 2025 • 0 new comments

• [FLINK-36992][table] Migrate SplitAggregateRule to java

  #25883 commented on Apr 11, 2025 • 0 new comments