issues  

Messages by Date

• 2025/09/19 Re: [PR] [BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/19 Re: [PR] [release-1.20][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 [jira] [Assigned] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Fabian Paul (Jira)
• 2025/09/19 [jira] [Commented] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator Timo Walther (Jira)
• 2025/09/19 [jira] [Resolved] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP Fabian Paul (Jira)
• 2025/09/19 [jira] [Commented] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP Fabian Paul (Jira)
• 2025/09/19 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/19 [PR] [FLINK-38279] Add SnapshotPendingSplitsState to MySQL checkpoint stat… [flink-cdc] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode ASF GitHub Bot (Jira)
• 2025/09/19 [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
• 2025/09/19 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• 2025/09/19 [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/19 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code [flink-cdc] via GitHub
• 2025/09/19 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/19 Re: [PR] Add FlinkCDC v3.5.0. [flink-web] via GitHub
• 2025/09/19 [jira] [Resolved] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters Maximilian Michels (Jira)
• 2025/09/19 [PR] [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules ASF GitHub Bot (Jira)
• 2025/09/19 [jira] [Created] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules Xiqian Yu (Jira)
• 2025/09/19 Re: [PR] [FLINK-38381] Enumerate Kafka partitions across Kafka clusters [flink-kubernetes-operator] via GitHub
• 2025/09/19 Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [release-2.1][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/19 Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• 2025/09/19 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2025/09/19 [PR] [Feature] ActionExecutionOperator handle watermark properly [flink-agents] via GitHub
• 2025/09/19 Re: [PR] [hotfix][table] Fix incorrect state ttl setting in KeyedLookupJoinWrapper [flink] via GitHub
• 2025/09/19 Re: [PR] Add partitioned async deserialization with ordered emission [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN Yanquan Lv (Jira)
• 2025/09/19 Re: [PR] [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• 2025/09/19 Re: [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] Add Kubernetes Operator 1.13.0 release [flink-web] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/19 [jira] [Resolved] (FLINK-38384) Bump lombok to 1.18.42 Sergey Nuyanzin (Jira)
• 2025/09/19 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38384][build] Bump lombok to 1.18.40 [flink] via GitHub
• 2025/09/19 [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] via GitHub
• 2025/09/19 [jira] [Assigned] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Martijn Visser (Jira)
• 2025/09/19 [jira] [Updated] (FLINK-38384) Bump lombok to 1.18.42 Sergey Nuyanzin (Jira)
• 2025/09/19 Re: [PR] [BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/19 Re: [PR] [release-1.20][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/19 [PR] [backport][release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/19 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/19 Re: [PR] [backport][release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 Re: [PR] [release-1.19][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 [PR] Add FlinkCDC v3.5.0. [flink-web] via GitHub
• 2025/09/19 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/19 [PR] [backport][release-2.1][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s ASF GitHub Bot (Jira)
• 2025/09/19 [PR] [backport][release-1.19][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/09/19 Re: [PR] [backport][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 [jira] [Created] (FLINK-38392) StreamPandasConversionTests failing Samrat Deb (Jira)
• 2025/09/19 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/19 [PR] [backport][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType Yanquan Lv (Jira)
• 2025/09/19 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/19 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Xuannan Su (Jira)
• 2025/09/19 [jira] [Resolved] (FLINK-38277) Enhance postgresSQL slot management capabilities Yanquan Lv (Jira)
• 2025/09/19 [jira] [Updated] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures Yanquan Lv (Jira)
• 2025/09/19 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. Xuannan Su (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core Ruan Hang (Jira)
• 2025/09/18 Re: [PR] [FLINK-37854][table] Support DATE_FORMAT with zone [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds ASF GitHub Bot (Jira)
• 2025/09/18 Re: [PR] [FLINK-37817] Adds bundled aggregates for group by (FLIP-491) [flink] via GitHub
• 2025/09/18 Re: [PR] Fix CVE-2022-25168 [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37817] Adds bundled aggregates for group by (FLIP-491) [flink] via GitHub
• 2025/09/18 Re: [PR] Fix CVE-2022-25168 [flink] via GitHub
• 2025/09/18 Re: [PR] [build] Update version to 3.6-SNAPSHOT. [flink-cdc] via GitHub
• 2025/09/18 Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [build] Update version to 3.6-SNAPSHOT. [flink-cdc] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure Lijie Wang (Jira)
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/18 [jira] [Closed] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
• 2025/09/18 Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] via GitHub
• 2025/09/18 Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/09/18 [PR] [build] Update version to 3.6-SNAPSHOT. [flink-cdc] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-33115) AbstractHadoopRecoverableWriterITCase is hanging with timeout on AZP ASF GitHub Bot (Jira)
• 2025/09/18 [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/09/18 [jira] [Commented] (FLINK-38363) WindowedStream.trigger supports trigger with async state Rui Xia (Jira)
• 2025/09/18 Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• 2025/09/18 [jira] [Assigned] (FLINK-38363) WindowedStream.trigger supports trigger with async state Zakelly Lan (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Zakelly Lan (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Rui Xia (Jira)
• 2025/09/18 Re: [PR] add handle chunkKeyColumn for Postgres [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/18 [I] [Feature] Provide Kafka-based implementation of ActionState [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/18 Re: [I] [Feature] [Integration] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/18 Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode ASF GitHub Bot (Jira)
• 2025/09/18 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38375][runtime] fix report slot numbers error [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 to support java 25 [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 to support java 25 [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 Sergey Nuyanzin (Jira)
• 2025/09/18 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading Yanquan Lv (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-23426) Support changelog processing in batch mode Alexey Leonov-Vendrovskiy (Jira)
• 2025/09/18 Re: [PR] [FLINK-38390][table] Compiliation of flink-core and flink-table-planner fails because of annotation processors [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38390][table] Compiliation of flink-core and flink-table-planner fails because of annotation processors [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/18 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/18 [jira] [Comment Edited] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
• 2025/09/18 [PR] [FLINK-38332][python] Bump pemja to 0.6.1 [flink] via GitHub
• 2025/09/18 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/09/18 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill Yanquan Lv (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38389) Add .show(), .head() and .tail() method to PyFlink Table API Zander Matheson (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors Sergey Nuyanzin (Jira)
• 2025/09/18 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38388) FLIP-541 Umbrella Issue Zander Matheson (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. Yanquan Lv (Jira)
• 2025/09/18 [PR] [hotfix] Bump Java setup action to version 5 [flink-shaded] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38350) Update Hadoop Library to 3.4.2 Paul Ashley (Jira)
• 2025/09/18 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
• 2025/09/18 [jira] [Closed] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator Ferenc Csaky (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Yanquan Lv (Jira)
• 2025/09/18 Re: [PR] [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38386][build] Fix attaching type annotations for jdk23+ [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38387) Bump spotless Sergey Nuyanzin (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable ASF GitHub Bot (Jira)
• 2025/09/18 Re: [PR] [FLINK-38386][build] Fix attaching type annotations for jdk23+ [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38386][build] Fix attaching type annotations for jdk23+ [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38386][build] Fix attaching type annotations for jdk23+ [flink] via GitHub
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/18 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable Sergey Nuyanzin (Jira)
• 2025/09/18 Re: [PR] [FLINK-38385][build] Bump mockito to 5.19.0 and byte-buddy to 1.17.6 [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38385) Bump byte-buddy to 1.17.6 ASF GitHub Bot (Jira)
• 2025/09/18 [PR] [FLINK-38385][build] Bump mockito to 5.19.0 and bute-buddy to 1.17.6 [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38385) Bump byte-buddy to 1.17.6 Sergey Nuyanzin (Jira)
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink] via GitHub
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode Sergey Nuyanzin (Jira)
• 2025/09/18 [PR] [FLINK-38384][build] Bump lombok to 1.18.40 [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38382) Confluent Schema Registry to support primitive types ASF GitHub Bot (Jira)
• 2025/09/18 Re: [PR] [FLINK-38382][kafka] Support avro primitive types in Confluent Schema Registry binding [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38384][build] Bump lombok to 1.18.40 [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/18 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-38384) Bump lombok to 1.18.40 ASF GitHub Bot (Jira)
• 2025/09/18 [jira] [Created] (FLINK-38384) Bump lombok to 1.18.40 Sergey Nuyanzin (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Gustavo de Morais (Jira)
• 2025/09/18 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/18 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/09/18 [jira] [Resolved] (FLINK-38059) [docs] Add fluss pipeline connector documentation Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase Yanquan Lv (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Yanquan Lv (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/18 [jira] [Assigned] (FLINK-23426) Support changelog processing in batch mode Timo Walther (Jira)
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38383) Automatically republish Flink Kubernetes Operator image when base image receives security patches Jaydeep Karia (Jira)
• 2025/09/18 [jira] [Commented] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Arvid Heise (Jira)
• 2025/09/18 [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator Yanquan Lv (Jira)
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error [flink] via GitHub
• 2025/09/18 [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/18 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/18 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/18 [jira] [Created] (FLINK-38382) Confluent Schema Registry to support primitive types nicolas paris (Jira)
• 2025/09/18 Re: [PR] [api] feat: Introduce per action state consistency API [flink-agents] via GitHub

• Earlier messages
• Later messages