issues  

Messages by Date

• 2026/05/20 Re: [PR] [api][runtime] Extend agent skill loading repository. [flink-agents] via GitHub
• 2026/05/20 [jira] [Commented] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null Zhe Wang (Jira)
• 2026/05/20 [PR] [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders [flink-connector-elasticsearch] via GitHub
• 2026/05/20 Re: [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink] via GitHub
• 2026/05/20 [jira] [Updated] (FLINK-39716) ES timeout related config used the wrong time unit ASF GitHub Bot (Jira)
• 2026/05/20 [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch] via GitHub
• 2026/05/20 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/05/20 [jira] [Updated] (FLINK-39672) Update doc about Java Records Leonard Xu (Jira)
• 2026/05/20 [jira] [Resolved] (FLINK-39672) Update doc about Java Records Leonard Xu (Jira)
• 2026/05/20 [jira] [Comment Edited] (FLINK-39672) Update doc about Java Records Leonard Xu (Jira)
• 2026/05/20 [jira] [Updated] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39716) ES timeout related config used the wrong time unit reswqa (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39492) [Bug][StarRocks Connector] TIMESTAMP/TIMESTAMP_LTZ precision (microseconds) lost when sinking to StarRocks Thorne (Jira)
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 [jira] [Resolved] (FLINK-39706) Remove flink 2.1 testing from es connector main branch Weijie Guo (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39706) Remove flink 2.1 testing from es connector main branch Weijie Guo (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39622] [postgres] Fix O(N²) JDBC metadata lookups in CustomPostgresSchema d… [flink-cdc] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion Prashant Bhardwaj (Jira)
• 2026/05/19 [PR] [Feature][Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed Arvind Kandpal (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed ASF GitHub Bot (Jira)
• 2026/05/19 Re: [PR] [FLINK-36235][Stream] Ignore emitting null rowData when deserialized message fails [flink-connector-pulsar] via GitHub
• 2026/05/19 [PR] [FLINK-36235][Stream] Ignore emitting null rowData when deserialized message fails [flink-connector-pulsar] via GitHub
• 2026/05/19 [I] [Feature] [Integration][Java] Add built-in support for Azure OpenAI Chat Model [flink-agents] via GitHub
• 2026/05/19 [jira] [Closed] (FLINK-39653) [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix build issue Taranpreet Kaur (Jira)
• 2026/05/19 Re: [PR] [FLINK-39653] [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix build [flink-connector-opensearch] via GitHub
• 2026/05/19 Re: [I] [api][java] Support Agent Skill in java [flink-agents] via GitHub
• 2026/05/19 Re: [I] [Feature] Separate messages and arguments for prompt of chat method in BaseChatModelSetup [flink-agents] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39706][ci] Add flink 2.1 testing for v4.0 branch [flink-connector-elasticsearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39706][ci] Remove flink 2.1 testing from es connector main branch [flink-connector-elasticsearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 [I] [doc] Add doc and example for introducing YAML API [flink-agents] via GitHub
• 2026/05/19 [jira] [Assigned] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Xiqian Yu (Jira)
• 2026/05/19 [jira] [Resolved] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Xiqian Yu (Jira)
• 2026/05/19 Re: [PR] [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation [flink-cdc] via GitHub
• 2026/05/19 [I] [Tech Debt] Update flink version after 1.20.5 & 2.1.3 release. [flink-agents] via GitHub
• 2026/05/19 Re: [PR] [FLINK-XXXXX][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-XXXXX][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-XXXXX][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• 2026/05/19 [PR] [FLINK-XXXXX][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39496) Azure nightly doesn't run for newer commits for release 2.0 Hao Li (Jira)
• 2026/05/19 Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Hao Li (Jira)
• 2026/05/19 Re: [PR] [FLINK-39714][docs] Backport AGENTS.md [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Yaoxuan Wu (Jira)
• 2026/05/19 Re: [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 [PR] [FLINK-39714][docs] Backport AGENTS.md [flink] via GitHub
• 2026/05/19 [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 [PR] [FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 ASF GitHub Bot (Jira)
• 2026/05/19 [PR] FLINK-39714][docs] Backport AGENTS.md and AI disclosure [flink] via GitHub
• 2026/05/19 Re: [PR] Bump idna from 3.11 to 3.15 in /flink-python/docs [flink] via GitHub
• 2026/05/19 [PR] Bump idna from 3.11 to 3.15 in /flink-python/docs [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Mingliang Liu (Jira)
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink] via GitHub
• 2026/05/19 [jira] [Comment Edited] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules Arvind Kandpal (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 [jira] [Comment Edited] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed Arvind Kandpal (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Arvind Kandpal (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules Arvind Kandpal (Jira)
• 2026/05/19 Re: [PR] [FLINK-39691][operator] Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39691][operator] Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules [flink-kubernetes-operator] via GitHub
• 2026/05/19 [jira] [Assigned] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Rui Fan (Jira)
• 2026/05/19 Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs Purushottam Sinha (Jira)
• 2026/05/19 Re: [PR] [FLINK-39691][operator] Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules Pavel Zeger (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39692) Several catch blocks log the message but discard the captured exception Pavel Zeger (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules Pavel Zeger (Jira)
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Aleksandr Savonin (Jira)
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters Aleksandr Savonin (Jira)
• 2026/05/19 Re: [PR] [FLINK-39660][Connectors/Kinesis] Fix Netty event loop threads blocking behavior and concurrent activation race in FanOutKinesisShardSubscription [flink-connector-aws] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] via GitHub
• 2026/05/19 [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion ASF GitHub Bot (Jira)
• 2026/05/19 Re: [PR] [Flink-39425] [flink-metrics-otel] OpenTelemetryEventReporter logger fix for missing service.name [flink] via GitHub
• 2026/05/19 Re: [PR] [Flink-39425] [flink-metrics-otel] OpenTelemetryEventReporter logger fix for missing service.name [flink] via GitHub
• 2026/05/19 Re: [PR] [Flink-39425] [flink-metrics-otel] OpenTelemetryEventReporter logger fix for missing service.name [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39660][Connectors/Kinesis] Fix Netty event loop threads blocking behavior and concurrent activation race in FanOutKinesisShardSubscription [flink-connector-aws] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 [jira] [Resolved] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs Rui Fan (Jira)
• 2026/05/19 [jira] [Assigned] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs Rui Fan (Jira)
• 2026/05/19 Re: [PR] [FLINK-39693] Bump jackson, log4j, assertj to address CVEs [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [hotfix] Bump flink.version to 2.1.2 [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [hotfix] Bump flink.version to 2.1.2 [flink-connector-kafka] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion Prashant Bhardwaj (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion Prashant Bhardwaj (Jira)
• 2026/05/19 Re: [PR] [FLINK-39688] Share a single PluginManager across operator and webhook startup [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39688] Share a single PluginManager across operator and webhook startup [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG [flink] via GitHub
• 2026/05/19 Re: [PR] [hotfix] Bump flink.version to 2.1.2 [flink-connector-kafka] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Matthias Pohl (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Matthias Pohl (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Prashant Bhardwaj (Jira)
• 2026/05/19 [jira] [Comment Edited] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Prashant Bhardwaj (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Prashant Bhardwaj (Jira)
• 2026/05/19 Re: [PR] [api][runtime] Extend agent skill loading repository. [flink-agents] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire Matthias Pohl (Jira)
• 2026/05/19 [jira] [Closed] (FLINK-39464) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• 2026/05/19 Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39709][s3]Update documentation for native-s3 Implementation [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• 2026/05/19 [jira] [Closed] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable Aleksandr Savonin (Jira)
• 2026/05/19 [jira] [Commented] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable Aleksandr Savonin (Jira)
• 2026/05/19 Re: [PR] [FLINK-39703][tests] Fix flaky KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39703][tests] Fix flaky KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [hotfix] Bump flink.version to 2.1.2 [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39693] Bump jackson, log4j, assertj to address CVEs [flink-connector-kafka] via GitHub
• 2026/05/19 [jira] [Resolved] (FLINK-39699) Kafka connector CI failed on the main branch Rui Fan (Jira)
• 2026/05/19 [jira] [Updated] (FLINK-39709) Update documentation for native-s3-fs ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39709][s3]Update documentation for native-s3 Implementation [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39709) Update documentation for native-s3-fs Samrat Deb (Jira)
• 2026/05/19 Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36847][table] Fix enum field conversion in Table API to DataStream [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36847][table] Fix enum field conversion in Table API to DataStream [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36847][table] Fix enum field conversion in Table API to DataStream [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36781][table] Fix SQL REPL lag when using remote gateways [flink] via GitHub
• 2026/05/19 [jira] [Commented] (FLINK-36235) [Pulsar Connector] Ignore to emit the null rowData when deserialized message failed Arvind Kandpal (Jira)
• 2026/05/19 Re: [PR] [FLINK-36781][table] Fix SQL REPL lag when using remote gateways [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36781][table] Fix SQL REPL lag when using remote gateways [flink] via GitHub
• 2026/05/19 [PR] [hotfix] Fix nested-types (array, map, row, variant) coercions [flink-cdc] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics ASF GitHub Bot (Jira)
• 2026/05/19 [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 ASF GitHub Bot (Jira)
• 2026/05/19 Re: [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 [PR] [FLINK-39707] Update flink-connector-parent to 2.0.0 [flink-connector-opensearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39650][table] REGEXP_REPLACE plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics Gustavo de Morais (Jira)
• 2026/05/19 Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-34332][ci] Follow the principle of least privilege for GITHUB_TOKEN [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39691][operator] Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules [flink-kubernetes-operator] via GitHub
• 2026/05/19 Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• 2026/05/19 Re: [PR] [api][runtime] Extend agent skill loading repository. [flink-agents] via GitHub
• 2026/05/19 [jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive ASF GitHub Bot (Jira)
• 2026/05/19 Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
• 2026/05/19 Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
• 2026/05/19 [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• 2026/05/19 [I] [Feature] Kafka ActionStateStore should tombstone pruned ActionState records after checkpoint completion [flink-agents] via GitHub
• 2026/05/19 [jira] [Created] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Mukul Gupta (Jira)
• 2026/05/19 [jira] [Resolved] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options Dennis-Mircea Ciupitu (Jira)
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 [PR] [api][java] Introduce YAML API for declaring agents [flink-agents] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/05/19 Re: [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub

• Earlier messages
• Later messages