issues  

Messages by Date

• 2025/09/15 [jira] [Created] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• 2025/09/15 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/15 [jira] [Updated] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs ASF GitHub Bot (Jira)
• 2025/09/15 [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
• 2025/09/15 [jira] [Assigned] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Dawid Wysakowicz (Jira)
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/09/15 Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/15 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/15 [jira] [Closed] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator Timo Walther (Jira)
• 2025/09/15 Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/15 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/15 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/15 [PR] Mcp complete 1 [flink-agents] via GitHub
• 2025/09/15 Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/15 Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
• 2025/09/15 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/15 [jira] [Updated] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Ramin Gharib (Jira)
• 2025/09/15 Re: [I] [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ RocMarshal (Jira)
• 2025/09/14 [I] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] via GitHub
• 2025/09/14 Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 [jira] [Resolved] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• 2025/09/14 [jira] [Updated] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/14 [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• 2025/09/14 Re: [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] via GitHub
• 2025/09/14 [jira] [Assigned] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• 2025/09/14 Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] via GitHub
• 2025/09/14 Re: [PR] [api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [FLINK-32695] [Tests] Migrate Common Test cases away from legacy Source/Sink [flink] via GitHub
• 2025/09/14 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/09/14 [jira] [Commented] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Samrat Deb (Jira)
• 2025/09/14 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/14 [jira] [Comment Edited] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Samrat Deb (Jira)
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 [jira] [Created] (FLINK-38354) ClassCastException occurs when submitting a task to flink cdc hunter (Jira)
• 2025/09/14 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/14 Re: [I] [Feature][api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/14 [jira] [Assigned] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• 2025/09/14 [jira] [Commented] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• 2025/09/14 Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [api] feat: Introduce ActionState related APIs [flink-agents] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/14 [jira] [Updated] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink ASF GitHub Bot (Jira)
• 2025/09/14 [PR] [FLINK-38319] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/14 [PR] Reuse byte array buffer in BlobServerConnection::run [flink] via GitHub
• 2025/09/14 Re: [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] via GitHub
• 2025/09/14 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/14 Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] via GitHub
• 2025/09/14 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/09/14 Re: [PR] [hotfix][connectors][CI] Replace https://archive.apache.org/ by https://dlcdn.apache.org/ for Flink release download for connectors [flink-connector-shared-utils] via GitHub
• 2025/09/13 Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] via GitHub
• 2025/09/13 [jira] [Updated] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key ASF GitHub Bot (Jira)
• 2025/09/13 [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2025/09/13 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/13 Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 [flink-cdc] via GitHub
• 2025/09/13 Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• 2025/09/13 [jira] [Commented] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT Jinkun Liu (Jira)
• 2025/09/13 [jira] [Commented] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Diljeet Singh (Jira)
• 2025/09/13 Re: [PR] [hotfix] Check for GNU tar [flink-connector-shared-utils] via GitHub
• 2025/09/13 [jira] [Comment Edited] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID LiuZeshan (Jira)
• 2025/09/13 [jira] [Commented] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID LiuZeshan (Jira)
• 2025/09/13 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/13 Re: [PR] [api][python] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] via GitHub
• 2025/09/13 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/13 [jira] [Assigned] (FLINK-37295) Update state ttl migration compatibility in docs Zakelly Lan (Jira)
• 2025/09/13 Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• 2025/09/13 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/13 Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] via GitHub
• 2025/09/12 [jira] [Updated] (FLINK-38351) Docker images support OpenJDK melin (Jira)
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] via GitHub
• 2025/09/12 [jira] [Updated] (FLINK-38331) Support displaying the hash keys on edges in web ui yisha zhou (Jira)
• 2025/09/12 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/12 Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• 2025/09/12 Re: [I] [Tech Debt][plan] Implement checkSignature for PythonFunction in Java [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 [jira] [Updated] (FLINK-37295) Update state ttl migration compatibility in docs ASF GitHub Bot (Jira)
• 2025/09/12 Re: [PR] [FLINK-38353][spans] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs xiangyu feng (Jira)
• 2025/09/12 [jira] [Commented] (FLINK-38351) Docker images support OpenJDK Yaroslav Tkachenko (Jira)
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37936][flink-table] Support STATE TTL hints for MultiJoin [flink] via GitHub
• 2025/09/12 [jira] [Updated] (FLINK-38353) FLIP-483: Add support for children Spans ASF GitHub Bot (Jira)
• 2025/09/12 [PR] FLIP-483: Add support for children Spans [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 [PR] [api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] via GitHub
• 2025/09/12 [I] [Feature][api][java] Separate the abstraction of ChatModel to connection and setup in Java. [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] Update README.md for end-to-end tests [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
• 2025/09/12 Re: [PR] [FLINK-37295][doc] Add state ttl migration compatibility to docs [flink] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs Zakelly Lan (Jira)
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs Gabor Somogyi (Jira)
• 2025/09/12 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 Re: [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] via GitHub
• 2025/09/12 Re: [PR] [Feature][Integrations][java] Integration with OllamaChatModel [flink-agents] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs Gabor Somogyi (Jira)
• 2025/09/12 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-37295) Update state ttl migration compatibility in docs Zakelly Lan (Jira)
• 2025/09/12 [jira] [Created] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator Timo Walther (Jira)
• 2025/09/12 [jira] [Assigned] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Martijn Visser (Jira)
• 2025/09/12 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file Feifan Wang (Jira)
• 2025/09/12 [jira] [Commented] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• 2025/09/12 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/12 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/12 [jira] [Created] (FLINK-38351) Docker images support OpenJDK melin (Jira)
• 2025/09/12 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/12 [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Grzegorz Liter (Jira)
• 2025/09/12 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 Re: [I] [Feature][api][java] Introduce Prompt, Tool and ChatModel in java [flink-agents] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
• 2025/09/11 [jira] [Assigned] (FLINK-38109) BlobServer isn't associated with the correct bind-host Ferenc Csaky (Jira)
• 2025/09/11 [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38265) Stream Split shouldn't finish when exception occors Ruan Hang (Jira)
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] FLINK-37953: Add OBF password obfuscation support for SSL configurations [flink] via GitHub
• 2025/09/11 [PR] [hotfix] [docs] Fixed typo on Parameter name for OracleCDC Adapter [flink-cdc] via GitHub
• 2025/09/11 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/11 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/11 [jira] [Resolved] (FLINK-38124) The autoscaling example misses README Maximilian Michels (Jira)
• 2025/09/11 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/11 Re: [PR] FLINK-32695 Migrated SavepointReaderITTestBase to SourceV2. [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38345][flink-connector-base] Added previousEnumerator resolution for HybridSource during checkpoint recovery [flink] via GitHub
• 2025/09/11 [jira] [Comment Edited] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Rion Williams (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext ASF GitHub Bot (Jira)
• 2025/09/11 [PR] [FLINK-38345][flink-connector-base] Added previousEnumerator resolution for HybridSource during checkpoint recovery [flink] via GitHub
• 2025/09/11 [PR] [BP-1.20][FLINK-37747][runtime] Use old subtask count for restored committable… #26546 [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• 2025/09/11 [jira] [Resolved] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• 2025/09/11 [jira] [Created] (FLINK-38332) Upgrade pemja to 0.6.1 Xuannan Su (Jira)
• 2025/09/11 [jira] [Commented] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Rion Williams (Jira)
• 2025/09/11 [jira] [Comment Edited] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• 2025/09/11 [jira] [Created] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/11 Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub

• Earlier messages
• Later messages