issues  

Messages by Thread

• • 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
  • Re: [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40512][postgres] Cache typeRegistry to reduce the busy work on inferring schema change event [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40512][postgres] Cache typeRegistry to reduce the busy work on inferring schema change event [flink-cdc] via GitHub
• [PR] [API][Tool] Align Java and Python Tool outcome contracts [flink-agents] via GitHub
• [jira] [Created] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity Mao Jiayi (Jira)
• [PR] [FLINK-40431] [python] Support per-UDF concurrency and batch size in PyFlink DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40431][python] Support per-UDF concurrency and batch size in PyFlink DataFrame API [flink] via GitHub
• [jira] [Created] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list Hongshun Wang (Jira)
• [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
  • Re: [PR] [infra] Add a guide for AI-assisted PR implementation descriptions [flink-agents] via GitHub
• [jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector ASF GitHub Bot (Jira)
• [PR] [FLINK-35104] [pipeline-connector/kafka]support pipeline kafka source [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35104] [pipeline-connector/kafka]support pipeline kafka source [flink-cdc] via GitHub
• [PR] [hotfix] Modernize CI workflows: remove deprecated setup-maven, fix cache save guard, and add network timeouts [flink-connector-shared-utils] via GitHub
• [PR] [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-40511) Track and speed up slow integration tests (KafkaSinkITCase and friends) Sylwester Lachiewicz (Jira)
• [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
  • Re: [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
• [jira] [Updated] (FLINK-40510) Use Apache Parent POM 39 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
  • Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
  • Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
  • Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
  • Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• [jira] [Created] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink] via GitHub
  • Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink] via GitHub
• Re: [I] [Feature] Apply structured output to an agent's final output only [flink-agents] via GitHub
• [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
  • Re: [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
  • Re: [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
• Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] via GitHub
• [I] [Bug][security][skills] Bound download and extraction size for URL skill sources [flink-agents] via GitHub
  • Re: [I] [Bug][security][skills] Bound download and extraction size for URL skill sources [flink-agents] via GitHub

• Earlier messages
• Later messages