issues  

Messages by Thread

• • Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• [jira] [Updated] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
  • [jira] [Updated] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• [jira] [Created] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled VISHAL B (Jira)
• [jira] [Commented] (FLINK-40423) Add Top-N support to DataFrame API Timo Theusner (Jira)
  • [jira] [Commented] (FLINK-40423) Add Top-N support to DataFrame API Dian Fu (Jira)
• [jira] [Resolved] (FLINK-40507) upgrade paimon to 2.0.0 Xiqian Yu (Jira)
• [jira] [Created] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• [PR] [hotfix][java][python] Harden Bash arithmetic evaluation [flink-agents] via GitHub
  • Re: [PR] [hotfix][java][python] Harden Bash arithmetic evaluation [flink-agents] via GitHub
• [jira] [Created] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job Juliusz Nadberezny (Jira)
• [I] [Feature] Introduce subagent framework and AGENT resource type [flink-agents] via GitHub
• [PR] FLINK-40531 Serialize parallelism overrides in a version-portable format [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns Arvid Heise (Jira)
  • [jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns Arvid Heise (Jira)
• [jira] [Updated] (FLINK-40513) Introduce multimodal AI functions for image understanding Mao Jiayi (Jira)
• [jira] [Reopened] (FLINK-40513) Introduce multimodal AI functions for image understanding Mao Jiayi (Jira)
• [jira] [Closed] (FLINK-40486) Introduce the UUID logical type Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Xiqian Yu (Jira)
• [jira] [Closed] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• [jira] [Commented] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• Re: [PR] [FLINK-37094][hive] Adapt Hive connector to Flink 2.0 API changes [flink-connector-hive] via GitHub
• [jira] [Commented] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• [jira] [Assigned] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• [jira] [Closed] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
  • Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
  • Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• [PR] [tools][ci] Fix the bats suite's boundary with the scripts it tests [flink-agents] via GitHub
  • Re: [PR] [tools][ci] Fix the bats suite's boundary with the scripts it tests [flink-agents] via GitHub
• [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
  • Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
  • Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
  • Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• [jira] [Updated] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Archit Goyal (Jira)
• [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
  • Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• [jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• [I] [Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API Hirson Zhang (Jira)
  • [jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API Hirson Zhang (Jira)
  • [jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• [jira] [Updated] (FLINK-40528) Codegen should be tolerate to partial deletes ASF GitHub Bot (Jira)
• [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40527) Update flink-shaded to 22.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
  • Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
  • Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
• [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Rango (Jira)
• [PR] [FLINK-39570] Bump Netty to 4.1.136.Final (release-20.0) [flink-shaded] via GitHub
• [jira] [Updated] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-40356) Add MAP_FROM_ENTRIES function Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• [jira] [Resolved] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• [jira] [Updated] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked ASF GitHub Bot (Jira)
• [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
  • Re: [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
  • Re: [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
• [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
  • Re: [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
  • Re: [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
• [jira] [Reopened] (FLINK-38544) FLIP-547 V2: Filtering record before processing with spilling strategy Rui Fan (Jira)
• [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
  • Re: [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
• [jira] [Updated] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier Rui Fan (Jira)
• [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
  • Re: [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
  • Re: [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
• [PR] [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled [flink] via GitHub
  • Re: [PR] [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled [flink] via GitHub
  • Re: [PR] [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled [flink] via GitHub
• [jira] [Created] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string Rui Fan (Jira)
• [jira] [Updated] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery ASF GitHub Bot (Jira)
• [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
  • Re: [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
  • Re: [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
  • Re: [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
• [PR] [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery [flink] via GitHub
  • Re: [PR] [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery [flink] via GitHub
  • Re: [PR] [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery [flink] via GitHub
• [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
  • Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
  • Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
  • Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
  • Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
• [jira] [Updated] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock Rui Fan (Jira)
• [jira] [Closed] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery Rui Fan (Jira)
• Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
  • Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
  • Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
  • Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• [jira] [Created] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel Rui Fan (Jira)
• [jira] [Created] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• Re: [PR] [FLINK-40243] Bump postgresql jdbc driver from 42.5.6 to 42.7.13 [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40424) Add windowing TVF support to DataFrame API Timo Theusner (Jira)
  • [jira] [Commented] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
  • Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• [PR] [plan][java][python] Reject unsafe Bash redirects [flink-agents] via GitHub
  • Re: [PR] [plan][java][python] Reject unsafe Bash redirects [flink-agents] via GitHub
• [jira] [Created] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked Rui Fan (Jira)
• [jira] [Comment Edited] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Martijn Visser (Jira)
  • [jira] [Comment Edited] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Efrat Levitan (Jira)
• [PR] [FLINK-39586][connector-base] Add watermark stall reproduction ITCase [flink] via GitHub
  • Re: [PR] [FLINK-39586][connector-base] Add watermark stall reproduction ITCase [flink] via GitHub
• [jira] [Created] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
• [jira] [Updated] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
  • [jira] [Updated] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
• Re: [PR] [FLINK-39813][Connectors/Kinesis] Add lineage support to Kinesis Streams connector [flink-connector-aws] via GitHub
• [jira] [Assigned] (FLINK-40430) Add configuration support to DataFrame API Dian Fu (Jira)
• [PR] [release-0.3][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
  • Re: [PR] [release-0.3][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Dian Fu (Jira)
  • [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Federico Dolce (Jira)
  • [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Federico Dolce (Jira)
• [jira] [Created] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• [jira] [Closed] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
• [PR] ci: update checkout, setup-python, and setup-java to current majors [flink-agents] via GitHub
  • Re: [PR] [ci] update checkout, setup-python, and setup-java to current majors [flink-agents] via GitHub
• [PR] [release-0.2][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
  • Re: [PR] [release-0.2][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• Re: [I] [Bug] PythonActionExecutor leaks Pemja PyObject references across task restarts [flink-agents] via GitHub
• Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• [jira] [Updated] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list Hongshun Wang (Jira)
• [PR] [hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
  • Re: [PR] [hotfix][runtime] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub

• Earlier messages
• Later messages