issues  

Messages by Date

• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 [jira] [Closed] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase Timo Walther (Jira)
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] via GitHub
• 2025/08/14 Re: [PR] [FLINK-38221][pipeline-connector][postgres] Fix critical partition table discovery bug causing CDC data loss [flink-cdc] via GitHub
• 2025/08/14 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/14 Re: [PR] [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/14 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/14 [jira] [Assigned] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job Rui Fan (Jira)
• 2025/08/14 Re: [PR] [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context [flink] via GitHub
• 2025/08/14 [jira] [Comment Edited] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ RocMarshal (Jira)
• 2025/08/14 Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• 2025/08/14 Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• 2025/08/14 [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ RocMarshal (Jira)
• 2025/08/13 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found ASF GitHub Bot (Jira)
• 2025/08/13 [PR] [FLINK-38244] When the column name of mysql supports case-insensitive, fix the error that column name not being found. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] via GitHub
• 2025/08/13 Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found Hongshun Wang (Jira)
• 2025/08/13 [jira] [Updated] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table ASF GitHub Bot (Jira)
• 2025/08/13 [jira] [Created] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
• 2025/08/13 [jira] [Created] (FLINK-38244) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
• 2025/08/13 [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table Weiqing Yang (Jira)
• 2025/08/13 [jira] [Created] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table Weiqing Yang (Jira)
• 2025/08/13 Re: [PR] [FLINK-27491] Support env replacement in flink-kubernetes-operator [flink-kubernetes-operator] via GitHub
• 2025/08/13 [jira] [Resolved] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• 2025/08/13 Re: [PR] [FLINK-38204] Use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [hotfix][doc] Update uses of Upload documentation in build_docs.yml. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [hotfix][doc] Update uses of Upload documentation in build_docs.yml. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [hotfix][doc] Update uses of Upload documentation in build_docs.yml. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] via GitHub
• 2025/08/13 [PR] [hotfix][doc] Update uses of Upload documentation in build_docs.yml. [flink-cdc] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink ASF GitHub Bot (Jira)
• 2025/08/13 [PR] [FLINK-38204]use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. [flink-cdc] via GitHub
• 2025/08/13 [jira] [Commented] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• 2025/08/13 [jira] [Updated] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• 2025/08/13 [jira] [Created] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• 2025/08/13 [jira] [Updated] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• 2025/08/13 [jira] [Created] (FLINK-38240) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• 2025/08/13 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ ASF GitHub Bot (Jira)
• 2025/08/13 [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
• 2025/08/13 [jira] [Commented] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field Fabrizzio Chavez (Jira)
• 2025/08/13 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/08/13 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/08/13 Re: [PR] Mcp def [flink-agents] via GitHub
• 2025/08/13 Re: [PR] [FLINK-33306] Use observed source throughput as true processing rate [flink-kubernetes-operator] via GitHub
• 2025/08/13 Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] via GitHub
• 2025/08/13 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 Re: [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 [PR] [model] Support Deepseek Function [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38228][table] Respect state TTL in window operator; prevent do… [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] via GitHub
• 2025/08/13 Re: [PR] publish wheel for apache-flink-libraries [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink] via GitHub
• 2025/08/13 Re: [PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink] via GitHub
• 2025/08/13 Re: [PR] Add Kafka-to-Kafka SQL Example to Documentation [flink] via GitHub
• 2025/08/13 Re: [PR] publish wheel for apache-flink-libraries [flink] via GitHub
• 2025/08/13 Re: [PR] Update README.md for end-to-end tests [flink] via GitHub
• 2025/08/13 Re: [PR] Update japicmp configuration for 2.1.0 [flink] via GitHub
• 2025/08/13 Re: [PR] Fix watermark documentation [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38216][checkpoint][refactor] Split EndOfChannelStateEvent into EndOfInputChannelStateEvent and EndOfOutputChannelStateEvent [flink] via GitHub
• 2025/08/13 Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• 2025/08/13 [jira] [Updated] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer ASF GitHub Bot (Jira)
• 2025/08/13 [PR] [FLINK-38216][checkpoint][refactor] Split EndOfChannelStateEvent into EndOfInputChannelStateEvent and EndOfOutputChannelStateEvent [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-35141][Connectors/Pulsar] Update flink-connector-pulsar v4.2.0 for Flink 1.19 [flink-connector-pulsar] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-36377] [table-planner] Add LAST_VALUE support for ROW, ARRAY, MAP, and RAW types [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2025/08/13 Re: [PR] [hotfix] [docs] Fix typo in state v2 docs [flink] via GitHub
• 2025/08/13 Re: [PR] Update README.md for end-to-end tests [flink] via GitHub
• 2025/08/13 [PR] Seperate chat model abstraction [flink-agents] via GitHub
• 2025/08/13 [I] [Feature] [api][python] Separate the abstraction of ChatModel to connection and settings. [flink-agents] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/13 [jira] [Commented] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks Xuyang Zhong (Jira)
• 2025/08/13 Re: [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38111] [oceanbase]：Migrate OceanBase CDC Connector from LogProxy to Binlog Service. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38111] [oceanbase]：Migrate OceanBase CDC Connector from LogProxy to Binlog Service. [flink-cdc] via GitHub
• 2025/08/13 [jira] [Created] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI yuan (Jira)
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] via GitHub
• 2025/08/13 [jira] [Commented] (FLINK-38238) Failed to process MySQL table with varchar(0) column Yanquan Lv (Jira)
• 2025/08/13 [jira] [Assigned] (FLINK-38238) Failed to process MySQL table with varchar(0) column Yanquan Lv (Jira)
• 2025/08/13 [jira] [Updated] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase ASF GitHub Bot (Jira)
• 2025/08/13 [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] via GitHub
• 2025/08/13 [jira] [Commented] (FLINK-38238) Failed to process MySQL table with varchar(0) column wuzexian (Jira)
• 2025/08/13 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/13 [jira] [Created] (FLINK-38238) Failed to process MySQL table with varchar(0) column Yanquan Lv (Jira)
• 2025/08/13 [jira] [Resolved] (FLINK-38191) [Document] Add document for Fluss pipeline connector Yanquan Lv (Jira)
• 2025/08/13 Re: [PR] [FLINK-38111] [oceanbase]：Migrate OceanBase CDC Connector from LogProxy to Binlog Service. [flink-cdc] via GitHub
• 2025/08/13 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/13 [jira] [Resolved] (FLINK-38058) Add e2e test for fluss pipeline connector Yanquan Lv (Jira)
• 2025/08/13 [jira] [Resolved] (FLINK-35888) Add e2e test for paimon DataSink Yanquan Lv (Jira)
• 2025/08/13 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/13 [jira] [Closed] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor Timo Walther (Jira)
• 2025/08/13 Re: [PR] [FLINK-38230][table-planner] Add visitMultiJoin to StreamNDUPlanVisitor [flink] via GitHub
• 2025/08/12 [jira] [Created] (FLINK-38237) MongoDB CDC - row_kind virtual column is returning incorrect operation Type Fabrizzio Chavez (Jira)
• 2025/08/12 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/08/12 [jira] [Resolved] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method tchivs (Jira)
• 2025/08/12 [jira] [Commented] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data Feng Jin (Jira)
• 2025/08/12 Re: [PR] [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API [flink] via GitHub
• 2025/08/12 Re: [D] Community Sync [flink-agents] via GitHub
• 2025/08/12 [jira] [Assigned] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss Yanquan Lv (Jira)
• 2025/08/12 Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.4 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• 2025/08/12 Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 10.0.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• 2025/08/12 Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 10.0.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• 2025/08/12 [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.4 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• 2025/08/12 [jira] [Commented] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Max Feng (Jira)
• 2025/08/12 Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/12 [jira] [Resolved] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered Yanquan Lv (Jira)
• 2025/08/12 [jira] [Resolved] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Yanquan Lv (Jira)
• 2025/08/12 Re: [PR] [FLINK-37835] Fix NoPointException when start with latest-offset. [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/12 Re: [D] WIP: Replay-based Per Action State Consistency [flink-agents] via GitHub
• 2025/08/12 Re: [D] WIP: Replay-based Per Action State Consistency [flink-agents] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38228][table] Respect state TTL in window operator; prevent do… [flink] via GitHub
• 2025/08/12 [jira] [Commented] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Leonard Xu (Jira)
• 2025/08/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/08/12 Re: [I] [Feature] Optimize PythonFunction instantiation in `call_python_function` [flink-agents] via GitHub
• 2025/08/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/08/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/08/12 [I] [Feature] Support MCP integration [flink-agents] via GitHub
• 2025/08/12 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/08/12 Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] via GitHub
• 2025/08/12 Re: [D] WIP: Replay-based Per Action State Consistency [flink-agents] via GitHub
• 2025/08/12 Re: [D] WIP: Replay-based Per Action State Consistency [flink-agents] via GitHub
• 2025/08/12 Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] [FLINK-37293][pipeline-connector][oceanbase] Fix type converting and refactoring test cases [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] [FLINK-37293][pipeline-connector][oceanbase] Fix type converting and refactoring test cases [flink-cdc] via GitHub
• 2025/08/12 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2025/08/12 Re: [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] via GitHub
• 2025/08/12 [jira] [Created] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field Fabrizzio Chavez (Jira)
• 2025/08/12 Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/12 Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] via GitHub
• 2025/08/12 Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] via GitHub
• 2025/08/12 Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] via GitHub
• 2025/08/12 Re: [PR] [hotfix][docs] `WITH` in `CREATE DATABASE` is optional [flink] via GitHub
• 2025/08/12 [jira] [Created] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Max Feng (Jira)
• 2025/08/12 [jira] [Updated] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Max Feng (Jira)
• 2025/08/12 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/12 [jira] [Commented] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator Thomas Weise (Jira)
• 2025/08/12 [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] via GitHub
• 2025/08/12 [jira] [Updated] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling ASF GitHub Bot (Jira)
• 2025/08/12 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/12 [jira] [Closed] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
• 2025/08/12 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/12 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/12 Re: [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] via GitHub
• 2025/08/12 [jira] [Updated] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase Timo Walther (Jira)
• 2025/08/12 [jira] [Updated] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor Gustavo de Morais (Jira)

• Earlier messages
• Later messages