Messages by Date
-
2026/05/20
[jira] [Updated] (FLINK-39379) Add support for state in ProcessTableFunctionTestHarness
ASF GitHub Bot (Jira)
-
2026/05/20
Re: [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-39716] Fix time unit for network timeout options [flink-connector-elasticsearch]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-39709][s3]Update documentation for native-s3 Implementation [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-39709][s3]Update documentation for native-s3 Implementation [flink]
via GitHub
-
2026/05/20
[jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode
Arvind Kandpal (Jira)
-
2026/05/20
[jira] [Updated] (FLINK-39492) [Bug][StarRocks Connector] TIMESTAMP/TIMESTAMP_LTZ precision (microseconds) lost when sinking to StarRocks
ASF GitHub Bot (Jira)
-
2026/05/20
[PR] FLINK-39492[starrocks] Fix microsecond precision loss for TIMESTAMP types in StarRocks sink [flink-cdc]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink]
via GitHub
-
2026/05/20
Re: [PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink]
via GitHub
-
2026/05/20
[PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink]
via GitHub
-
2026/05/20
Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink]
via GitHub
-
2026/05/20
Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37593][table] Add some Reduce Expression Rules [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink]
via GitHub
-
2026/05/20
Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink]
via GitHub
-
2026/05/20
Re: [PR] [hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37422][docs] Fix typo in streaming analytics zh document [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
-
2026/05/20
Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-37593][table] Add some Reduce Expression Rules [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink]
via GitHub
-
2026/05/20
Re: [PR] add array aggregate function [flink]
via GitHub
-
2026/05/20
Re: [PR] add array aggregate function [flink]
via GitHub
-
2026/05/20
Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink]
via GitHub
-
2026/05/20
[jira] [Created] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE
Ramin Gharib (Jira)
-
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