issues  

Messages by Date

• 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
• 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-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers lincoln lee (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-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers lincoln lee (Jira)
• 2025/09/11 Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/11 [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Zakelly Lan (Jira)
• 2025/09/11 [jira] [Closed] (FLINK-36125) File not found exception on restoring state handles with file merging Zakelly Lan (Jira)
• 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 [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. lincoln lee (Jira)
• 2025/09/11 [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history ASF GitHub Bot (Jira)
• 2025/09/11 Re: [PR] [FLINK-38339][runtime] Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history. [flink] via GitHub
• 2025/09/11 [jira] [Resolved] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• 2025/09/11 Re: [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 Re: [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 [PR] [FLINK-38339][runtime] Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history. [flink] via GitHub
• 2025/09/11 [jira] [Resolved] (FLINK-38007) Prepare Flink 2.1 Release dalongliu (Jira)
• 2025/09/11 [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38338) Introduce the abstraction to describe a rescale event. ASF GitHub Bot (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38349) Bugs caused by floating-point operations Huny (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38175) Start End of Life discussion thread for now outdated Flink minor version dalongliu (Jira)
• 2025/09/11 [jira] [Created] (FLINK-38349) Bugs caused by floating-point operations Huny (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38094) Introduce pyflink.__version__ lincoln lee (Jira)
• 2025/09/11 [jira] [Created] (FLINK-38350) Update Hadoop Library to 3.4.2 Paul Ashley (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37826) Some serde-related perfs regression since May 19th lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
• 2025/09/11 [jira] [Closed] (FLINK-38165) Promote release 2.1 dalongliu (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38172) Update japicmp configuration dalongliu (Jira)
• 2025/09/11 [jira] [Closed] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin dalongliu (Jira)
• 2025/09/11 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/11 [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. lincoln lee (Jira)
• 2025/09/11 [jira] [Resolved] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures Yanquan Lv (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. lincoln lee (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
• 2025/09/11 [jira] [Updated] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled lincoln lee (Jira)
• 2025/09/11 Re: [PR] [hotfix] [docs] Fixed typo on Parameter name for OracleCDC Adapter [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [FLINK-36975][Connectors/AWS] Fix the AWS Config Option AWS_ROLE_CREDENTIALS_PROVIDER_OPTION to pick the right key [flink-connector-aws] via GitHub
• 2025/09/11 Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
• 2025/09/11 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [FLINK-32695] [Tests] Migrate Common Test cases away from legacy Source/Sink [flink] via GitHub
• 2025/09/11 [jira] [Commented] (FLINK-29731) Protobuf-confluent format Javad Saljooghi (Jira)
• 2025/09/11 Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/11 Re: [PR] [FLINK-32695] [Tests] Migrate Common Test cases away from legacy Source/Sink [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] via GitHub
• 2025/09/11 [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/11 [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [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-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/11 Re: [PR] FLINK-32695 Migrated SavepointReaderITTestBase to SourceV2. [flink] via GitHub
• 2025/09/11 Re: [PR] [FLINK-38258][model] support model args in ptf and add ml_predict builtin ptf [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 [jira] [Assigned] (FLINK-38329) Add labels to PRs showing the targeted version Ferenc Csaky (Jira)
• 2025/09/11 [jira] [Closed] (FLINK-38329) Add labels to PRs showing the targeted version Ferenc Csaky (Jira)
• 2025/09/11 Re: [PR] [FLINK-38329][GithubAction] Add target release label for back port PRs [flink] via GitHub
• 2025/09/11 Re: [PR] FLINK-32695 Migrated SavepointReaderITTestBase to SourceV2. [flink] via GitHub
• 2025/09/11 [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink ASF GitHub Bot (Jira)
• 2025/09/11 [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• 2025/09/11 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/09/11 [I] [Tech Debt] Refactoring CI of test cases in integration module [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Zakelly Lan (Jira)
• 2025/09/11 [jira] [Created] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source Shuo Cheng (Jira)
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] 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 [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [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-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 [I] [Tech Debt] Specify model to be used in ChatModelSetup. [flink-agents] 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] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/11 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/10 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/10 [jira] [Closed] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source Shuo Cheng (Jira)
• 2025/09/10 Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• 2025/09/10 [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Gabor Somogyi (Jira)
• 2025/09/10 [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Gabor Somogyi (Jira)
• 2025/09/10 [jira] [Updated] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost ASF GitHub Bot (Jira)
• 2025/09/10 Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
• 2025/09/10 [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• 2025/09/10 Re: [PR] [improve] Remove repeated dependency. [flink-cdc] via GitHub
• 2025/09/10 [jira] [Created] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• 2025/09/10 [jira] [Created] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
• 2025/09/10 Re: [PR] [api][python] Add built-in Ollama embedding model support [flink-agents] via GitHub
• 2025/09/10 Re: [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] via GitHub
• 2025/09/10 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• 2025/09/10 Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• 2025/09/10 [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
• 2025/09/10 [I] [Feature] Introduce new module `integrations` [flink-agents] via GitHub
• 2025/09/10 [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. ASF GitHub Bot (Jira)
• 2025/09/10 [jira] [Closed] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)

• Earlier messages
• Later messages