issues  

Messages by Date

• 2025/09/22 [PR] [FLINK-38401][table] Add getUpsertKeys support for StreamPhysicalMultiJoin [flink] via GitHub
• 2025/09/22 [jira] [Commented] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• 2025/09/22 [jira] [Created] (FLINK-38407) GroupAggregateRestoreTest failed in test_cron_azure table Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline Ruan Hang (Jira)
• 2025/09/22 [jira] [Created] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Ruan Hang (Jira)
• 2025/09/22 [jira] [Commented] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• 2025/09/22 Re: [PR] [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] via GitHub
• 2025/09/22 [jira] [Created] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table Ruan Hang (Jira)
• 2025/09/22 Re: [PR] [release-1.19][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/22 [jira] [Resolved] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• 2025/09/22 [PR] [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] via GitHub
• 2025/09/22 [jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline Ruan Hang (Jira)
• 2025/09/22 [PR] [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapte connect [flink-cdc] via GitHub
• 2025/09/22 Re: [PR] [release-2.1][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/22 Re: [PR] [FLINK-38398] Improve postgresSQL field Type supported precision.mode=connect [flink-cdc] via GitHub
• 2025/09/22 [jira] [Created] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys Gustavo de Morais (Jira)
• 2025/09/22 Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38398][pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config(#4129) [flink-cdc] via GitHub
• 2025/09/21 [PR] [FLINK-38398][pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config(#4129) [flink-cdc] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ Yanquan Lv (Jira)
• 2025/09/21 Re: [PR] [Feature][API][python] Use Python property to simplify the getter in RunnerContext [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38398] Improve postgresSQL field Type supported precision.mode=connect [flink-cdc] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed ASF GitHub Bot (Jira)
• 2025/09/21 Re: [PR] [DON"T REVIEW] Empty commit to trigger a CI test for FLINK-37892 [flink] via GitHub
• 2025/09/21 [jira] [Assigned] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ Yanquan Lv (Jira)
• 2025/09/21 [PR] [api][plan][java] Support built-in ReAct Agent in Java. [flink-agents] via GitHub
• 2025/09/21 [I] [Feature] [api][plan][java] Support built-in ReAct Agent in Java. [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join ASF GitHub Bot (Jira)
• 2025/09/21 [PR] [FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38363][Runtime] WindowedStream.trigger supports trigger with async state [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38363][Runtime] WindowedStream.trigger supports trigger with async state [flink] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38363) WindowedStream.trigger supports trigger with async state ASF GitHub Bot (Jira)
• 2025/09/21 [PR] [FLINK-38363][Runtime] WindowedStream.trigger supports trigger with async state [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] via GitHub
• 2025/09/21 Re: [PR] [Feature][API][python] Use Python property to simplify the getter in RunnerContext [flink-agents] via GitHub
• 2025/09/21 [PR] [BP-3.5][FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result lincoln lee (Jira)
• 2025/09/21 [jira] [Created] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result lincoln lee (Jira)
• 2025/09/21 [jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result lincoln lee (Jira)
• 2025/09/21 [jira] [Updated] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result lincoln lee (Jira)
• 2025/09/21 Re: [PR] [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules [flink-cdc] via GitHub
• 2025/09/21 Re: [PR] [Feature][API][python] Use Python property to simplify the getter in RunnerContext [flink-agents] via GitHub
• 2025/09/21 [jira] [Created] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join Xuyang Zhong (Jira)
• 2025/09/21 [jira] [Assigned] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join Xuyang Zhong (Jira)
• 2025/09/21 Re: [PR] [FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source [flink] via GitHub
• 2025/09/21 Re: [PR] [hotfix] fix reasoning extraction from Tongyi model [flink-agents] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ ouyangwulin (Jira)
• 2025/09/21 [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API Dian Fu (Jira)
• 2025/09/21 [jira] [Updated] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ ASF GitHub Bot (Jira)
• 2025/09/21 [PR] [FLINK-38398] Improve postgresSQL field Type supported precision.mode=connect [flink-cdc] via GitHub
• 2025/09/21 [jira] [Created] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ ouyangwulin (Jira)
• 2025/09/21 Re: [I] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] via GitHub
• 2025/09/21 Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [hotfix] fix reasoning extraction from Tongyi model [flink-agents] via GitHub
• 2025/09/21 Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
• 2025/09/21 [jira] [Commented] (FLINK-38397) Runtime Exception in Planner Gabor Somogyi (Jira)
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38397) Runtime Exception in Planner Ahmad Humayun (Jira)
• 2025/09/21 [jira] [Created] (FLINK-38397) Runtime Exception in Planner Ahmad Humayun (Jira)
• 2025/09/21 [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters ASF GitHub Bot (Jira)
• 2025/09/21 [PR] [FLINK-38110] fix PostgreSQL connector reads Chinese columns with garbled charactor [flink-cdc] via GitHub
• 2025/09/21 [jira] [Updated] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally ASF GitHub Bot (Jira)
• 2025/09/21 [jira] [Created] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally Sergey Nuyanzin (Jira)
• 2025/09/21 Re: [PR] [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable [flink] via GitHub
• 2025/09/20 Re: [PR] Fix CI and upgrade to use Flink 1.18.1 [flink-connector-pulsar] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/09/20 Re: [I] [Feature] Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/20 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
• 2025/09/20 Re: [PR] [BP-1.20][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
• 2025/09/20 [jira] [Assigned] (FLINK-38332) Upgrade pemja to 0.5.5 Dian Fu (Jira)
• 2025/09/20 Re: [PR] [minor] Fix potential sql connection statement issue. [flink-cdc] via GitHub
• 2025/09/20 [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI RocMarshal (Jira)
• 2025/09/20 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/20 [PR] [hotfix][table] Fix incorrect state ttl setting in KeyedLookupJoinWrapper [flink] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Kaiqi Dong (Jira)
• 2025/09/20 Re: [PR] [FLINK-36975][Connectors/AWS] Fix the AWS Config Option AWS_ROLE_CREDENTIALS_PROVIDER_OPTION to pick the right key [flink-connector-aws] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/20 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host Ferenc Csaky (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
• 2025/09/20 [I] [Feature] Async action properly handle checkpoint and per-action state [flink-agents] via GitHub
• 2025/09/20 [jira] [Resolved] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-37209) Add Embedding AI Model for Qwen Yanquan Lv (Jira)
• 2025/09/20 Re: [PR] [release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode [flink] via GitHub
• 2025/09/20 Re: [PR] [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true [flink-agents] via GitHub
• 2025/09/20 [PR] [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message [flink] via GitHub
• 2025/09/20 [jira] [Resolved] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-37736) Introduce Flink CDC metrics doc Yanquan Lv (Jira)
• 2025/09/20 [jira] [Created] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Ramin Gharib (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-35229) join An error occurred when the table was empty Xuannan Su (Jira)
• 2025/09/20 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/20 [jira] [Closed] (FLINK-38109) BlobServer isn't associated with the correct bind-host Ferenc Csaky (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/20 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.5.5 Dian Fu (Jira)
• 2025/09/20 [PR] [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error in CatalogManager [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/20 Re: [PR] Reuse byte array buffer in BlobServerConnection::run [flink] via GitHub
• 2025/09/20 [jira] [Created] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Zakelly Lan (Jira)
• 2025/09/20 Re: [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] via GitHub
• 2025/09/20 Re: [I] [Feature] Use Python property to simplify the getter in RunnerContext [flink-agents] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Sergei Morozov (Jira)
• 2025/09/20 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/20 [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility Thomas Cooper (Jira)
• 2025/09/20 Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
• 2025/09/20 Re: [I] [Feature] [Docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility Thomas Cooper (Jira)
• 2025/09/20 [jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2 Martijn Visser (Jira)
• 2025/09/20 Re: [PR] [WIP][BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38385) Bump byte-buddy to 1.17.6 Sergey Nuyanzin (Jira)
• 2025/09/20 [PR] [hotfix] fix reasoning extraction from Tongyi model [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/20 [PR] [hotfix] Adapt ollama integration after refactor chat model api. [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [BP-2.1][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host Ferenc Csaky (Jira)
• 2025/09/20 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/20 [jira] [Created] (FLINK-38343) Support store rescale history by ExecutionGraphInfoStore and query the rescale history with statistics. RocMarshal (Jira)
• 2025/09/20 Re: [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] via GitHub
• 2025/09/20 [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38392) StreamPandasConversionTests failing ASF GitHub Bot (Jira)
• 2025/09/20 [PR] Support MySQL in-source parallel deserialization [flink-cdc] via GitHub
• 2025/09/20 [PR] [FLINK-38379][table] Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows [flink] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md Rion Williams (Jira)
• 2025/09/20 Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 [jira] [Assigned] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules Xiqian Yu (Jira)
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/20 [PR] [BP-2.0][FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• 2025/09/20 [jira] [Created] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history RocMarshal (Jira)
• 2025/09/20 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE Sergey Nuyanzin (Jira)
• 2025/09/20 [PR] [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true [flink-agents] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• 2025/09/20 Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• 2025/09/20 Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/20 [PR] Add Flink 1.20.3 release [flink-web] via GitHub
• 2025/09/20 Re: [I] [Feature] Support Chroma Cloud [flink-agents] via GitHub
• 2025/09/20 [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API Kaiqi Dong (Jira)
• 2025/09/20 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [Feature] Support Chroma Cloud [flink-agents] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38268] Fix incorrect serialization of VARIANT type FLOAT [flink] via GitHub
• 2025/09/20 [jira] [Updated] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT ASF GitHub Bot (Jira)
• 2025/09/20 [PR] [FLINK-38268] Fix incorrect serialization of VARIANT type FLOAT [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/20 Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] via GitHub
• 2025/09/20 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/19 Re: [PR] [Feature] [api] Introduce per action state consistency API [flink-agents] via GitHub
• 2025/09/19 Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
• 2025/09/19 [PR] [Feature] Support Chroma Cloud [flink-agents] via GitHub
• 2025/09/19 [I] [Feature] Support Chroma Cloud [flink-agents] via GitHub
• 2025/09/19 [jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Sergio Chong (Jira)
• 2025/09/19 [jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Sergio Chong (Jira)
• 2025/09/19 [jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Sergio Chong (Jira)
• 2025/09/19 [jira] [Created] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Sergio Chong (Jira)
• 2025/09/19 [jira] [Created] (FLINK-38394) Upgrade Flink CDC to Flink 2 Mohsen Rezaei (Jira)
• 2025/09/19 Re: [PR] [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 to support java 25 [flink] via GitHub
• 2025/09/19 [jira] [Resolved] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 Sergey Nuyanzin (Jira)
• 2025/09/19 Re: [PR] [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 to support java 25 [flink] via GitHub
• 2025/09/19 Re: [PR] [FLINK-38385][build] Bump mockito to 5.19.0 and byte-buddy to 1.17.6 [flink] via GitHub
• 2025/09/19 [jira] [Resolved] (FLINK-38385) Bump byte-buddy to 1.17.6 Sergey Nuyanzin (Jira)
• 2025/09/19 [jira] [Resolved] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Sergey Nuyanzin (Jira)
• 2025/09/19 [jira] [Commented] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Sergey Nuyanzin (Jira)

• Earlier messages
• Later messages