You are viewing a plain text version of this content. The canonical link for it is here.

---

- Re: [PR] [FLINK-38044][runtime-web] update angular to v20 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/08/01 01:08:18 UTC, 5 replies.
- Re: [PR] [runtime-web] chore: bump angular to v19 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/08/01 01:34:53 UTC, 0 replies.
- Re: [PR] [hotfix] Fix security issues. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/01 02:02:38 UTC, 1 replies.
- Re: [PR] Bump on-headers and compression in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/08/01 02:05:44 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/08/01 02:06:00 UTC, 0 replies.
- [PR] 26805 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/08/01 02:35:53 UTC, 0 replies.
- Re: [PR] [FLINK-37973][table-planner] Add support for right joins to multijoin operator [flink] - posted by "SteveStevenpoor (via GitHub)" <gi...@apache.org> on 2025/08/01 03:48:53 UTC, 4 replies.
- [jira] [Updated] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/08/01 05:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/08/01 05:27:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/08/01 05:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2025/08/01 06:02:00 UTC, 10 replies.
- [jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Nic Townsend (Jira)" <ji...@apache.org> on 2025/08/01 06:03:00 UTC, 2 replies.
- Re: [PR] [Test][Do NOT MERGE] Test PR to check if the build fails [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/08/01 06:35:20 UTC, 0 replies.
- Re: [PR] [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2025/08/01 06:48:41 UTC, 3 replies.
- Re: [PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/08/01 06:51:15 UTC, 0 replies.
- Re: [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/08/01 06:52:46 UTC, 0 replies.
- [jira] [Created] (FLINK-38178) [RISC-V Support] - Comprehensive Tracking of RISC-V Architecture Support in Apache Flink - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 06:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38158) FLIP-484: Add custom metric variables to operators - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/08/01 06:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38158) FLIP-484: Add custom metric variables to operators - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/08/01 06:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38178) [RISC-V Support] - Comprehensive Tracking of RISC-V Architecture Support in Apache Flink - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 07:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 07:14:00 UTC, 2 replies.
- Re: [PR] [FLINK-37844][table] Add new ProjectMultiJoinTransposeRule [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/01 07:54:24 UTC, 6 replies.
- [jira] [Created] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/08/01 08:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/08/01 08:16:00 UTC, 1 replies.
- [PR] [FLINK-38179] Upgrade os-maven-plugin for RISC-V riscv64 support [flink] - posted by "gong-flying (via GitHub)" <gi...@apache.org> on 2025/08/01 08:55:57 UTC, 3 replies.
- Re: [PR] Upgrade os-maven-plugin for RISC-V riscv64 support [flink] - posted by "gong-flying (via GitHub)" <gi...@apache.org> on 2025/08/01 08:56:19 UTC, 0 replies.
- [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/08/01 09:03:55 UTC, 19 replies.
- [jira] [Commented] (FLINK-38132) CLONE - Improve the CSV reading process - posted by "Karan Makhija (Jira)" <ji...@apache.org> on 2025/08/01 10:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-38173][release] Generate reference data for state migration tests based on release-2.1.0 [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/08/01 11:19:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-38173) Update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/08/01 11:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38173) Update reference data for Migration Tests - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/08/01 11:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38170) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/08/01 11:21:00 UTC, 0 replies.
- Re: [PR] [api][python] Introduce Prompt, Tool and ChatModel in python [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/01 13:15:50 UTC, 4 replies.
- [jira] [Commented] (FLINK-36359) IT case for DDB Streams connector - posted by "Karan Makhija (Jira)" <ji...@apache.org> on 2025/08/01 13:20:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/08/01 15:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/08/01 15:35:00 UTC, 1 replies.
- [PR] [FLINK-38181] Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/08/01 15:45:25 UTC, 14 replies.
- [jira] [Assigned] (FLINK-36359) IT case for DDB Streams connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/08/01 16:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/01 18:26:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-34112) JavaCodeSplitter OOM - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/01 18:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context [flink] - posted by "xiangyuf (via GitHub)" <gi...@apache.org> on 2025/08/02 01:32:24 UTC, 1 replies.
- [PR] [FLINK-37735][serializer] Replace class.newInstance with constructor.newInstance [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/08/02 02:58:51 UTC, 6 replies.
- [jira] [Updated] (FLINK-37735) Replace class.newInstance with constructor.newInstance - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/02 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38182) lastCheckpointDuration is not right. - posted by "richard_zhulh (Jira)" <ji...@apache.org> on 2025/08/02 03:17:00 UTC, 0 replies.
- [PR] Add Flink 2.1.0 release [flink-web] - posted by "Pythoneryeah (via GitHub)" <gi...@apache.org> on 2025/08/02 03:43:08 UTC, 1 replies.
- [jira] [Updated] (FLINK-38182) lastCheckpointDuration is not right. - posted by "richard_zhulh (Jira)" <ji...@apache.org> on 2025/08/02 04:47:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38182) when checkpoint is failed,the lastCheckpointDuration metirc is not right. - posted by "richard_zhulh (Jira)" <ji...@apache.org> on 2025/08/02 04:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38182) When checkpoint is failed,the lastCheckpointDuration metirc is not right. - posted by "richard_zhulh (Jira)" <ji...@apache.org> on 2025/08/02 04:49:00 UTC, 0 replies.
- [PR] [hotfix] Do not run community review label on non Apache repo [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 08:43:18 UTC, 0 replies.
- Re: [PR] [hotfix] Do not run community review label and stale PR workflow on forks [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 08:44:51 UTC, 2 replies.
- [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] - posted by "qinf (via GitHub)" <gi...@apache.org> on 2025/08/02 10:49:28 UTC, 18 replies.
- [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/02 10:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] - posted by "mielientiev (via GitHub)" <gi...@apache.org> on 2025/08/02 13:27:04 UTC, 39 replies.
- [jira] [Resolved] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/02 14:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 14:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 14:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-38138] Fix OOB error in ColumnarArrayData [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 14:53:51 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 14:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 14:55:00 UTC, 3 replies.
- Re: [PR] [FLINK-38069] Fix return type nullability diffs of function ENCODE & DECODE in SQL and Table API [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 15:00:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 15:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 15:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 15:01:59 UTC, 6 replies.
- [jira] [Resolved] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/02 15:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 15:16:20 UTC, 2 replies.
- Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 15:19:36 UTC, 0 replies.
- Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/02 15:55:39 UTC, 0 replies.
- [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] - posted by "CatOrLeader (via GitHub)" <gi...@apache.org> on 2025/08/02 19:08:25 UTC, 0 replies.
- Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] - posted by "phamvinh1712 (via GitHub)" <gi...@apache.org> on 2025/08/02 23:00:50 UTC, 4 replies.
- [jira] [Created] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2025/08/03 03:21:00 UTC, 0 replies.
- [PR] [FLINK-38183] Fix the problem of data loss in the GTID disordered scenario [flink-cdc] - posted by "lzshlzsh (via GitHub)" <gi...@apache.org> on 2025/08/03 03:23:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/03 03:24:00 UTC, 5 replies.
- [PR] [api][java] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/03 04:10:18 UTC, 9 replies.
- Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/03 06:25:29 UTC, 1 replies.
- Re: [PR] [API][Runtime] Support agent and action asynchronous execution [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/03 07:54:01 UTC, 4 replies.
- [PR] [FLINK-38123] Upgrade flink version autscaling example [flink-kubernetes-operator] - posted by "kaygorodov (via GitHub)" <gi...@apache.org> on 2025/08/03 19:28:43 UTC, 0 replies.
- [jira] [Updated] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/03 19:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/08/03 19:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38124) The autoscaling example misses README - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2025/08/03 19:33:00 UTC, 1 replies.
- Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/04 01:14:25 UTC, 11 replies.
- [jira] [Assigned] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/08/04 01:48:00 UTC, 0 replies.
- Re: [PR] [minor] Fix potential sql connection statement issue [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/04 02:21:27 UTC, 8 replies.
- [jira] [Commented] (FLINK-35917) Failed to deserialize data of EventHeaderV4 - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2025/08/04 02:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/04 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/04 03:09:00 UTC, 0 replies.
- [PR] [FLINK-38184] one time of GetCopyOfBuffer is enough When serializing split. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/08/04 03:17:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/04 03:18:00 UTC, 6 replies.
- Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] - posted by "czy006 (via GitHub)" <gi...@apache.org> on 2025/08/04 08:38:38 UTC, 1 replies.
- [jira] [Closed] (FLINK-34840) [3.1][pipeline-connectors] Add Implementation of DataSink in Iceberg. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 08:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36799) iceberg sink supports pipeline configuration connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 08:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37847) [umbrella] Unstable test in FlinkCDC project - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 08:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38156) Pipeline E2E tests are currently bound to fail. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38156) Pipeline E2E tests are currently bound to fail. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37847) [umbrella] Unstable test in FlinkCDC project - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:02:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-37847) [umbrella] Unstable test in FlinkCDC project - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc] - posted by "junmuz (via GitHub)" <gi...@apache.org> on 2025/08/04 09:36:48 UTC, 11 replies.
- Re: [PR] [hotfix] Format code using tools/lint.sh [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/08/04 10:03:55 UTC, 0 replies.
- [I] [Feature][runtime][python] Support async execution for actions in python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/04 10:13:09 UTC, 1 replies.
- [I] [Feature][runtime][java] Support async execution for actions in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/04 10:13:25 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrated TimestampITCase to SourceV2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/04 11:06:28 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 11:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 11:36:00 UTC, 0 replies.
- [PR] [FLINK-38185][pipeline-connector][iceberg] Correctly handle the type conversion of TIMESTAMP_TITH_TIME_ZONE. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/04 11:39:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/04 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38186) Failed case: NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37314) The watermark and lateness document has an error which may mislead users - posted by "Liu (Jira)" <ji...@apache.org> on 2025/08/04 11:49:00 UTC, 2 replies.
- Re: [PR] [FLINK-38141][pipeline-connector/iceberg] Fix iceberg connector incorrect type mapping [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/04 12:00:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38141) Iceberg sink has an incorrect type conversion - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38187) Add metrics to KuduSource - posted by "Marton Greber (Jira)" <ji...@apache.org> on 2025/08/04 19:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-17524) Remove "An illegal reflective access operation has occurred" warnings on JDK11 - posted by "Dan Lipofsky (Jira)" <ji...@apache.org> on 2025/08/04 20:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38106) Job gets indefinitely stuck with "Job Not Found" events - posted by "vikasap (Jira)" <ji...@apache.org> on 2025/08/04 21:58:00 UTC, 0 replies.
- [PR] Update README.md for end-to-end tests [flink] - posted by "nikita-ivanov-cc (via GitHub)" <gi...@apache.org> on 2025/08/04 21:58:54 UTC, 7 replies.
- [jira] [Closed] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/08/05 01:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/05 02:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/08/05 02:27:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 02:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 02:35:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrated StreamTaskTimerITCase to new Source V2. [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/05 03:07:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Voon Hou (Jira)" <ji...@apache.org> on 2025/08/05 03:16:00 UTC, 0 replies.
- Re: [I] [Feature][api][python] Introduce Prompt, Tool and ChatModel in Python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/05 03:18:33 UTC, 0 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2025/08/05 04:51:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/08/05 05:44:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/05 05:51:00 UTC, 0 replies.
- [PR] [FLINK-38188][cdc-postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/08/05 05:56:53 UTC, 10 replies.
- [jira] [Updated] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/05 05:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/05 06:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-34989][ci] Reduces number of concurrent jobs for nightly runs [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/05 06:26:12 UTC, 1 replies.
- [jira] [Created] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38190) Support async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 06:58:00 UTC, 0 replies.
- Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/05 06:59:58 UTC, 0 replies.
- Re: [PR] [ci][fluss] Add MySQL to Fluss E2e IT case [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/05 07:11:55 UTC, 1 replies.
- [jira] [Created] (FLINK-38191) [Document] Add document for Fluss pipeline connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/05 07:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/05 08:11:00 UTC, 1 replies.
- [PR] [infra] fix: improve lint.sh and add license header check [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/08/05 08:27:20 UTC, 0 replies.
- Re: [I] [Feature][runtime] Support bounded source in flink operator [flink-agents] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/08/05 08:42:30 UTC, 0 replies.
- [jira] [Updated] (FLINK-38164) MySQL connector support LONG and LONG VARCHAR type - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/08/05 08:50:00 UTC, 1 replies.
- Re: [PR] [infra] fix: improve lint.sh and add license header check tool [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/05 09:02:58 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Removed SourceFunction Dependency from YarnTestCacheJob. [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/05 09:18:24 UTC, 0 replies.
- [jira] [Updated] (FLINK-35698) Parquet connector fails to load ROW after save - posted by "thuong le (Jira)" <ji...@apache.org> on 2025/08/05 09:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35698) Parquet connector fails to load ROW after save - posted by "thuong le (Jira)" <ji...@apache.org> on 2025/08/05 09:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35698) Parquet connector fails to load ROW after save - posted by "thuong le (Jira)" <ji...@apache.org> on 2025/08/05 09:28:00 UTC, 0 replies.
- [I] [Feature] [integration] Support ollama chat model in python. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/05 09:56:50 UTC, 0 replies.
- [PR] Integrate ollma chatmodel [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/05 10:02:27 UTC, 0 replies.
- [PR] [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type [flink-cdc] - posted by "doovvv (via GitHub)" <gi...@apache.org> on 2025/08/05 11:14:35 UTC, 4 replies.
- [jira] [Created] (FLINK-38192) Improve DynamicSourceUtils exception msg - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2025/08/05 11:23:00 UTC, 0 replies.
- [PR] Improve DynamicSourceUtils#validateAndApplyMetadata exception msg [flink] - posted by "LoveHeat (via GitHub)" <gi...@apache.org> on 2025/08/05 11:34:23 UTC, 0 replies.
- Re: [PR] [FLINK-38192] Improve DynamicSourceUtils#validateAndApplyMetadata exception msg [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/05 11:41:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-38192) Improve DynamicSourceUtils exception msg - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/05 11:42:00 UTC, 0 replies.
- Re: [PR] [Integration][ChatModel] Add built-in ollama chat model in python [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/05 12:42:33 UTC, 2 replies.
- Re: [PR] [FLINK-37827][table] Fix use `SHOW CREATE TABLE` for MATERIALIZED_TABLE [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/05 14:07:51 UTC, 1 replies.
- [jira] [Assigned] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/08/05 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/05 15:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/05 15:16:00 UTC, 4 replies.
- [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] - posted by "Frawless (via GitHub)" <gi...@apache.org> on 2025/08/05 15:19:54 UTC, 20 replies.
- [PR] [FLINK-36359][Connectors/DynamoDB] IT Case for DDB Streams connector [flink-connector-aws] - posted by "karanmakhija867 (via GitHub)" <gi...@apache.org> on 2025/08/05 15:21:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36359) IT case for DDB Streams connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/05 15:22:00 UTC, 0 replies.
- [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/05 18:06:27 UTC, 8 replies.
- [PR] Paimon connector - support table specific table.properties config [flink-cdc] - posted by "nickdelnano (via GitHub)" <gi...@apache.org> on 2025/08/06 00:30:38 UTC, 0 replies.
- [D] Flink-Agents Memory Design [flink-agents] - posted by "coderplay (via GitHub)" <gi...@apache.org> on 2025/08/06 01:18:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-37314) The watermark and lateness document has an error which may mislead users - posted by "Liu (Jira)" <ji...@apache.org> on 2025/08/06 02:11:00 UTC, 0 replies.
- [PR] [FLINK-37314][Documentation] Fix the definition of lateness to t_w - t instead of t - t_w [flink] - posted by "Myracle (via GitHub)" <gi...@apache.org> on 2025/08/06 02:22:41 UTC, 3 replies.
- [jira] [Created] (FLINK-38194) Iceberg connector supports auto-creating namespace - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/08/06 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "cuiyanxiang (Jira)" <ji...@apache.org> on 2025/08/06 03:42:00 UTC, 0 replies.
- [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc] - posted by "doovvv (via GitHub)" <gi...@apache.org> on 2025/08/06 03:46:14 UTC, 8 replies.
- [jira] [Updated] (FLINK-38194) Iceberg connector supports auto-creating namespace - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 03:47:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/06 03:59:00 UTC, 0 replies.
- Re: [I] [Feature][api][java] Introduce Prompt, Tool and ChatModel in java [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/06 04:15:23 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/06 04:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/06 04:33:00 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-38138] Fix OOB error in ColumnarArrayData [flink] - posted by "voonhous (via GitHub)" <gi...@apache.org> on 2025/08/06 04:33:04 UTC, 1 replies.
- [PR] [BP-1.19][FLINK-38138] Fix OOB error in ColumnarArrayData [flink] - posted by "voonhous (via GitHub)" <gi...@apache.org> on 2025/08/06 04:41:13 UTC, 1 replies.
- [jira] [Created] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/06 05:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/06 05:18:00 UTC, 4 replies.
- [PR] [FLINK-38195][table][docs]: Fix some markdown syntax errors in tableApi page [flink] - posted by "CuiYanxiang (via GitHub)" <gi...@apache.org> on 2025/08/06 05:55:43 UTC, 3 replies.
- [jira] [Updated] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38197) Data Errors Caused by Default Added Columns at End Position - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/08/06 06:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/06 06:26:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-38197) Data Errors Caused by Default Added Columns at End Position - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/08/06 06:28:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/06 06:32:00 UTC, 0 replies.
- [I] [Bug] [api][runtime] Call from_datastream and then to_table will cause exception. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/06 06:45:20 UTC, 0 replies.
- [PR] [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/08/06 06:47:14 UTC, 10 replies.
- [jira] [Updated] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 06:48:00 UTC, 0 replies.
- Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/06 07:43:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/06 08:08:00 UTC, 6 replies.
- [jira] [Created] (FLINK-38199) Add a benchmark for SinkUpsertMaterializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/08/06 08:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/06 08:15:00 UTC, 10 replies.
- [jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/06 08:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37844) Push down projections for StreamingMultiJoinOperator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/06 08:28:00 UTC, 0 replies.
- Re: [I] [Feature] [integration] Support built-in ollama chat model in python. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/06 08:48:15 UTC, 0 replies.
- [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents] - posted by "AmenAdem (via GitHub)" <gi...@apache.org> on 2025/08/06 09:05:24 UTC, 12 replies.
- Re: [D] Short-Term Memory Design [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/06 09:26:43 UTC, 2 replies.
- Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/06 09:40:58 UTC, 3 replies.
- Re: [D] Community Sync [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/06 11:01:37 UTC, 3 replies.
- [jira] [Commented] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/06 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 11:09:00 UTC, 0 replies.
- [PR] [FLINK-38200][table] Allow to use `FIRST_VALUE` and `LAST_VALUE` for other types [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/06 11:28:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 11:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37735) Replace class.newInstance with constructor.newInstance - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/08/06 11:30:00 UTC, 0 replies.
- Re: [PR] [FLINK-38200][table] Allow to use `FIRST_VALUE` and `LAST_VALUE` with other types [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/06 11:34:15 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37679) Improve the performance of Flink serialization - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/08/06 11:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37735) Replace class.newInstance with constructor.newInstance - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/08/06 11:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-36906] Optimize the logic for determining if a split is finished [flink-connector-kafka] - posted by "xiaochen-zhou (via GitHub)" <gi...@apache.org> on 2025/08/06 12:40:56 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37314) The watermark and lateness document has an error which may mislead users - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/06 13:08:00 UTC, 0 replies.
- [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/08/06 14:29:20 UTC, 11 replies.
- [jira] [Updated] (FLINK-38199) Add a benchmark for SinkUpsertMaterializer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 14:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/06 14:38:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/06 14:38:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 15:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 15:50:00 UTC, 0 replies.
- Re: [PR] [pipeline-connector/paimon] Support table specific table.properties configuration [flink-cdc] - posted by "tub (via GitHub)" <gi...@apache.org> on 2025/08/06 16:38:43 UTC, 4 replies.
- [PR] [FLINK-38199] Allow to specify output in AbstractStreamOperatorTestHarness [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/08/06 17:04:14 UTC, 3 replies.
- [jira] [Created] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 20:32:00 UTC, 0 replies.
- [PR] Flink38202 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/06 20:33:50 UTC, 0 replies.
- Re: [PR] [FLINK-38202][build] Allow to customize dynamic.max-pool-size-factor [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/06 20:39:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 20:40:00 UTC, 0 replies.
- [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements [flink] - posted by "achang52 (via GitHub)" <gi...@apache.org> on 2025/08/06 21:43:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/06 21:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38203) Failed case: FlussPipelineITCase.testInsertExistTableWithMoreColumns - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 02:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 02:05:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38203) Failed case: FlussPipelineITCase.testInsertExistTableWithMoreColumns - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38205) Discard unknown fields for Protobuf format - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/08/07 02:25:00 UTC, 0 replies.
- [I] [Feature] Support local execution in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/07 02:43:38 UTC, 0 replies.
- Re: [I] [Feature][api][java] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/07 02:46:34 UTC, 0 replies.
- Re: [I] [Feature][api] Support DataStream / Table as input / output of Flink Agents [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/07 02:46:46 UTC, 0 replies.
- Re: [PR] [FLINK-38044][runtime-web] update angular to v19 [flink] - posted by "Laffery (via GitHub)" <gi...@apache.org> on 2025/08/07 03:22:56 UTC, 0 replies.
- [I] [Tech Debt] Improve observability of ci [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/07 03:38:41 UTC, 0 replies.
- [I] [Feature] [api][python] Support add action and resource to Agent instance [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/07 03:53:53 UTC, 1 replies.
- [jira] [Created] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 03:54:00 UTC, 0 replies.
- [PR] [api][python] Support add action and resource to Agent instance. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/07 03:55:56 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 05:59:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 05:59:00 UTC, 5 replies.
- Re: [PR] [table] Add support for temporal join on rolling aggregates [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/07 06:26:05 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Fix typo in docker.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/07 06:26:08 UTC, 1 replies.
- Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/08/07 06:26:48 UTC, 3 replies.
- [jira] [Resolved] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 06:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 06:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-37905] Fix transform failure with non-ascii string literals [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/07 06:39:56 UTC, 1 replies.
- [PR] [hotfix] Rename input/output event name in EventUtil to keep consiste… [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/07 07:23:02 UTC, 1 replies.
- [PR] [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/07 07:53:51 UTC, 4 replies.
- [jira] [Updated] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 07:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 07:57:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/07 08:01:00 UTC, 0 replies.
- [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/08/07 08:04:30 UTC, 10 replies.
- [jira] [Commented] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:22:00 UTC, 0 replies.
- [PR] [FLINK-38207] Update Flink Operator to use JOSDK 5.1.2 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/07 08:23:19 UTC, 3 replies.
- [jira] [Commented] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 08:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:26:00 UTC, 0 replies.
- [PR] [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/08/07 08:31:24 UTC, 3 replies.
- [jira] [Updated] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:32:00 UTC, 0 replies.
- [PR] [FLINK-38208] Use new Fabric8 client CRD generator in Flink Operator [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/07 08:35:53 UTC, 1 replies.
- [jira] [Updated] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 08:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 08:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/08/07 09:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38164) MySQL connector support LONG and LONG VARCHAR type - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/07 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 11:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 12:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-38045] Build createTableEventCache using TableSchemas from split and Make transform operator stateless [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/07 12:12:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 12:13:00 UTC, 0 replies.
- [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/07 12:29:44 UTC, 0 replies.
- [jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/07 12:30:00 UTC, 2 replies.
- Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/07 12:33:29 UTC, 12 replies.
- [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc] - posted by "czy006 (via GitHub)" <gi...@apache.org> on 2025/08/07 12:42:00 UTC, 1 replies.
- Re: [PR] [FLINK-32695] [Tests] ReactiveModeITCase-NewSource-Migration [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/07 14:33:48 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrate CoGroupJoinITCase new Source/Sink V2 [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/07 14:36:08 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 14:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 14:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37700) SQL parse exception when creating a view with PTF - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 15:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37700) SQL parse exception when creating a view with PTF - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 15:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37700) SQL parse exception when creating a view with PTF - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/07 15:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/07 15:09:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 15:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 15:14:00 UTC, 12 replies.
- [jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 15:14:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/07 15:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/07 15:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38135) Non-existent method for RAW type hashing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 15:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38135) Non-existent method for RAW type hashing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/07 15:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/07 16:38:25 UTC, 2 replies.
- [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/08/08 00:36:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-38205) Discard unknown fields for Protobuf format - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/08 00:37:00 UTC, 0 replies.
- [PR] [hotfix][docs] README: fix variable name in Java Batch example [flink] - posted by "sa3047 (via GitHub)" <gi...@apache.org> on 2025/08/08 01:18:13 UTC, 2 replies.
- [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/08/08 01:44:50 UTC, 3 replies.
- [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/08/08 02:05:42 UTC, 3 replies.
- [jira] [Updated] (FLINK-35907) Inconsistent handling of bit and bit(n) types in Flink CDC PostgreSQL Connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/08 02:06:00 UTC, 0 replies.
- [PR] [FLINK-37959][postgres]Supported postgres sql 14 all field types. [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/08 02:35:08 UTC, 1 replies.
- [jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/08 02:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38213) Failed - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 02:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38213) Failed case: FlussE2eITCase.testMySqlToFluss - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 02:47:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/08 06:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/08/08 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/08 06:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/08 06:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38194) Iceberg connector supports auto-creating namespace - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 06:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/08/08 07:16:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/08/08 07:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2025/08/08 07:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 07:20:00 UTC, 1 replies.
- Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/08/08 08:55:32 UTC, 1 replies.
- [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/08 08:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 08:56:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/08 08:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2025/08/08 11:27:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service - posted by "yuan (Jira)" <ji...@apache.org> on 2025/08/08 12:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service - posted by "yuan (Jira)" <ji...@apache.org> on 2025/08/08 12:27:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/08 13:14:00 UTC, 0 replies.
- [PR] [hotfix][docs] Clarify Kryo behavior [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2025/08/08 13:19:25 UTC, 2 replies.
- [jira] [Closed] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/08 14:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38073) Add documentation for the MultiJoin Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/08 15:00:00 UTC, 0 replies.
- [PR] Fix watermark documentation [flink] - posted by "bivouak (via GitHub)" <gi...@apache.org> on 2025/08/08 15:03:23 UTC, 3 replies.
- [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/08 18:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/08 18:05:00 UTC, 3 replies.
- [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/08 19:17:33 UTC, 5 replies.
- [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/08/08 21:35:37 UTC, 1 replies.
- Re: [PR] [FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/09 00:05:02 UTC, 0 replies.
- Re: [I] [Feature][plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/09 06:05:42 UTC, 0 replies.
- Re: [I] [Feature][plan][runtime] Introduce Resource and Resource Provider [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/09 06:05:53 UTC, 0 replies.
- [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/08/09 06:07:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-38059) [docs] Add fluss pipeline connector documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/09 06:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38191) [Document] Add document for Fluss pipeline connector - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/08/09 06:12:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/09 08:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/09 08:22:00 UTC, 0 replies.
- [I] [Feature][Ollama] Add `extract_reasoning` flag to `OllamaChatModel` to capture `` blocks into extra_args [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/08/09 14:43:31 UTC, 1 replies.
- Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/09 14:49:37 UTC, 7 replies.
- [PR] [Integration][ChatModel] Add reasoning extraction in OllamaChatModel [flink-agents] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/08/09 15:13:30 UTC, 1 replies.
- Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/10 00:05:41 UTC, 0 replies.
- Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/10 06:25:36 UTC, 1 replies.
- [I] [Feature] [api] Support Event Logger and Event Listener in Java [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/08/10 08:50:41 UTC, 1 replies.
- Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] - posted by "tcerda95 (via GitHub)" <gi...@apache.org> on 2025/08/10 13:06:14 UTC, 1 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/10 14:34:08 UTC, 26 replies.
- Re: [PR] [FLINK-38159] Update commons-lang3 dependency to 3.18.0 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/10 14:36:29 UTC, 2 replies.
- Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/10 14:49:28 UTC, 7 replies.
- [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/10 21:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/10 21:14:00 UTC, 0 replies.
- Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] - posted by "mielientiev (via GitHub)" <gi...@apache.org> on 2025/08/10 21:17:04 UTC, 2 replies.
- [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/10 22:32:08 UTC, 8 replies.
- [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/10 22:33:00 UTC, 4 replies.
- [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/10 22:34:35 UTC, 4 replies.
- [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/10 22:35:00 UTC, 2 replies.
- Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/11 00:05:30 UTC, 1 replies.
- Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/11 00:05:38 UTC, 2 replies.
- Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] - posted by "yzeng1618 (via GitHub)" <gi...@apache.org> on 2025/08/11 03:52:39 UTC, 0 replies.
- [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/08/11 04:57:20 UTC, 14 replies.
- [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/11 05:44:00 UTC, 0 replies.
- [PR] Add .vscode into .gitignore [flink-kubernetes-operator] - posted by "kornys (via GitHub)" <gi...@apache.org> on 2025/08/11 05:45:25 UTC, 2 replies.
- [PR] [FLINK-38221][pipeline-connector][postgres] Fix critical partition table discovery bug causing CDC data loss [flink-cdc] - posted by "tchivs (via GitHub)" <gi...@apache.org> on 2025/08/11 05:57:31 UTC, 1 replies.
- [jira] [Updated] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/11 05:58:00 UTC, 0 replies.
- [PR] Fix usage of deprectaed method createOrUpdate from fabric8 [flink-kubernetes-operator] - posted by "kornys (via GitHub)" <gi...@apache.org> on 2025/08/11 06:08:20 UTC, 0 replies.
- Re: [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/11 06:26:10 UTC, 1 replies.
- [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/08/11 07:12:00 UTC, 0 replies.
- [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/11 07:15:11 UTC, 1 replies.
- [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/11 07:16:58 UTC, 0 replies.
- [PR] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/11 07:18:23 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/11 07:34:00 UTC, 0 replies.
- [PR] Remove redundant implementation of Namespaced [flink-kubernetes-operator] - posted by "kornys (via GitHub)" <gi...@apache.org> on 2025/08/11 08:11:40 UTC, 2 replies.
- [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/11 08:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/11 08:24:00 UTC, 2 replies.
- [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] - posted by "rkhachatryan (via GitHub)" <gi...@apache.org> on 2025/08/11 08:49:19 UTC, 3 replies.
- [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/11 08:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2025/08/11 08:53:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2025/08/11 08:54:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/11 09:14:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/11 09:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/11 09:44:00 UTC, 0 replies.
- Re: [PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/11 09:58:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-37802) files in directory job-result-store was incorrect - posted by "jackray wang (Jira)" <ji...@apache.org> on 2025/08/11 10:00:00 UTC, 1 replies.
- [PR] [FLINK-38219][table-runtime][FLINK-38220][table-planner] Fix row kind in StreamingMultiJoinOperator and Add Values and TableFunctionScan as source [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/11 10:43:10 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/08/11 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/08/11 11:06:00 UTC, 0 replies.
- [PR] [FLINK-38222] Bump HBase version from 2.2 to 2.6 [flink-connector-hbase] - posted by "mateczagany (via GitHub)" <gi...@apache.org> on 2025/08/11 11:32:57 UTC, 13 replies.
- [jira] [Updated] (FLINK-38222) Upgrade HBase client version to 2.6 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/11 11:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/11 11:34:00 UTC, 0 replies.
- [jira] (FLINK-37802) files in directory job-result-store was incorrect - posted by "jackray wang (Jira)" <ji...@apache.org> on 2025/08/11 11:58:00 UTC, 0 replies.
- [PR] [hotfix] [docs] Fix typo in state v2 docs [flink] - posted by "ndrake (via GitHub)" <gi...@apache.org> on 2025/08/11 12:07:56 UTC, 3 replies.
- [PR] [FLINK-37193] Ingress recreated after perform a change to CR FlinkDeployment [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/11 13:03:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/11 13:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/11 13:07:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38106) Job gets indefinitely stuck with "Job Not Found" events - posted by "Rasmus Bilgram (Jira)" <ji...@apache.org> on 2025/08/11 13:52:00 UTC, 0 replies.
- [PR] [hotfix][python] Use `uv run` to run Python lint/testing tools, rather than directly installing [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/08/11 14:21:37 UTC, 3 replies.
- [jira] [Updated] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/11 14:23:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/11 15:18:00 UTC, 0 replies.
- Re: [PR] Fix usage of deprecated method createOrUpdate from fabric8 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/11 15:24:52 UTC, 3 replies.
- [jira] [Assigned] (FLINK-38222) Upgrade HBase client version to 2.6 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/08/11 16:10:00 UTC, 0 replies.
- [PR] Fix redundant implementation of interfaces and clean deprecated fabric8 methods [flink-kubernetes-operator] - posted by "kornys (via GitHub)" <gi...@apache.org> on 2025/08/11 17:41:24 UTC, 4 replies.
- [jira] [Created] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xi Zhang (Jira)" <ji...@apache.org> on 2025/08/11 22:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xi Zhang (Jira)" <ji...@apache.org> on 2025/08/11 22:22:00 UTC, 0 replies.
- [PR] Mcp def [flink-agents] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/08/12 01:10:28 UTC, 12 replies.
- [PR] [FLINK-36377] [table-planner] Add LAST_VALUE support for ROW, ARRAY, MAP, and RAW types [flink] - posted by "liyang1206 (via GitHub)" <gi...@apache.org> on 2025/08/12 01:40:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/12 02:05:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/12 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavio - posted by "Ejaskhan (Jira)" <ji...@apache.org> on 2025/08/12 04:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavio - posted by "Ejaskhan (Jira)" <ji...@apache.org> on 2025/08/12 04:19:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavior - posted by "Ejaskhan (Jira)" <ji...@apache.org> on 2025/08/12 04:25:00 UTC, 4 replies.
- [jira] [Created] (FLINK-38227) Flink-CDC Postgres with Incremental Change does not work - posted by "Harish Sharma (Jira)" <ji...@apache.org> on 2025/08/12 04:52:00 UTC, 0 replies.
- [D] WIP: Replay-based Per Action State Consistency [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/12 04:56:11 UTC, 10 replies.
- Re: [PR] [FLINK-38111] [oceanbase]：Migrate OceanBase CDC Connector from LogProxy to Binlog Service. [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2025/08/12 05:58:38 UTC, 12 replies.
- Re: [PR] [BP-2.1][FLINK-38219][table-runtime][FLINK-38220][table-planner] Fix row kind in StreamingMultiJoinOperator and Add Values and TableFunctionScan as source [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/08/12 06:42:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/12 06:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/12 06:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33481) Why were checkpoints stored on zookeeper deleted when JobManager failures with Flink High Availability on yarn - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2025/08/12 06:49:00 UTC, 0 replies.
- [PR] [FLINK-37835] Fix NoPointException when start with latest-offset. [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/08/12 07:13:17 UTC, 1 replies.
- [jira] [Closed] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/12 08:22:00 UTC, 0 replies.
- [jira] [Created] (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. - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/08/12 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/12 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 10:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/12 11:15:00 UTC, 0 replies.
- [PR] [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/12 11:17:42 UTC, 23 replies.
- [jira] [Updated] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/12 11:18:00 UTC, 0 replies.
- [PR] [FLINK-38230][table-planner] Add visitMultiJoin to StreamNDUPlanVisitor [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/12 11:21:08 UTC, 13 replies.
- [jira] [Updated] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/12 11:22:00 UTC, 2 replies.
- [PR] [FLINK-35856] [table] Upgrade Calcite version to 1.37.0 [flink] - posted by "michalstutzmann (via GitHub)" <gi...@apache.org> on 2025/08/12 11:47:57 UTC, 15 replies.
- [jira] [Updated] (FLINK-35856) Upgrade Calcite version to 1.37.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/12 11:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35856) Upgrade Calcite version to 1.37.0 - posted by "Michal Stutzmann (Jira)" <ji...@apache.org> on 2025/08/12 12:00:00 UTC, 0 replies.
- [I] [Feature] [api][runtime]Introduce Memory Reference [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/12 12:48:31 UTC, 1 replies.
- [PR] Introduce Memory Reference [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/12 12:50:34 UTC, 0 replies.
- Re: [PR] [FLINK-38123] Upgrade flink version in the autoscaling example [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/12 12:50:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/12 12:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/12 12:52:00 UTC, 0 replies.
- [PR] [FLINK-38228][table] Respect state TTL in window operator; prevent do… [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/08/12 12:58:22 UTC, 3 replies.
- [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. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/12 12:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/12 13:03:00 UTC, 0 replies.
- Re: [I] [Feature] Optimize PythonFunction instantiation in `call_python_function` [flink-agents] - posted by "Kavishankarks (via GitHub)" <gi...@apache.org> on 2025/08/12 13:03:51 UTC, 1 replies.
- Re: [PR] docs: update overview.md [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/12 13:03:55 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/08/12 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/08/12 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/12 13:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/12 13:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/12 13:49:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:19:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:20:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/12 14:37:00 UTC, 0 replies.
- [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/08/12 16:16:57 UTC, 9 replies.
- [jira] [Updated] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/12 16:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2025/08/12 17:45:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC - posted by "Max Feng (Jira)" <ji...@apache.org> on 2025/08/12 20:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC - posted by "Max Feng (Jira)" <ji...@apache.org> on 2025/08/12 20:31:00 UTC, 0 replies.
- Re: [PR] [hotfix][docs] `WITH` in `CREATE DATABASE` is optional [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/12 20:33:44 UTC, 1 replies.
- [jira] [Created] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field - posted by "Fabrizzio Chavez (Jira)" <ji...@apache.org> on 2025/08/12 22:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-37293][pipeline-connector][oceanbase] Fix type converting and refactoring test cases [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/13 00:05:00 UTC, 1 replies.
- Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/13 00:05:10 UTC, 1 replies.
- [I] [Feature] Support MCP integration [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/13 01:26:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/08/13 01:48:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 03:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 03:19:00 UTC, 0 replies.
- [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] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/08/13 04:45:02 UTC, 1 replies.
- 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] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/08/13 04:45:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 05:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/13 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38237) MongoDB CDC - row_kind virtual column is returning incorrect operation Type - posted by "Fabrizzio Chavez (Jira)" <ji...@apache.org> on 2025/08/13 06:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/13 07:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35888) Add e2e test for paimon DataSink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 07:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38058) Add e2e test for fluss pipeline connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 07:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38191) [Document] Add document for Fluss pipeline connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38238) Failed to process MySQL table with varchar(0) column - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 07:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38238) Failed to process MySQL table with varchar(0) column - posted by "wuzexian (Jira)" <ji...@apache.org> on 2025/08/13 08:06:00 UTC, 1 replies.
- [PR] [FLINK-38234][tests] Enable ndu strategy for semantic tests by default [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/13 08:06:33 UTC, 4 replies.
- [jira] [Assigned] (FLINK-38238) Failed to process MySQL table with varchar(0) column - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI - posted by "yuan (Jira)" <ji...@apache.org> on 2025/08/13 09:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/08/13 11:47:00 UTC, 1 replies.
- [I] [Feature] [api][python] Separate the abstraction of ChatModel to connection and settings. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/13 12:22:29 UTC, 1 replies.
- [PR] Seperate chat model abstraction [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/13 12:24:26 UTC, 0 replies.
- Re: [PR] [FLINK-35141][Connectors/Pulsar] Update flink-connector-pulsar v4.2.0 for Flink 1.19 [flink-connector-pulsar] - posted by "thinker0 (via GitHub)" <gi...@apache.org> on 2025/08/13 13:43:19 UTC, 0 replies.
- [PR] [FLINK-38216][checkpoint][refactor] Split EndOfChannelStateEvent into EndOfInputChannelStateEvent and EndOfOutputChannelStateEvent [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/08/13 14:18:37 UTC, 1 replies.
- [jira] [Updated] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/13 14:19:00 UTC, 0 replies.
- Re: [PR] Update japicmp configuration for 2.1.0 [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:21:45 UTC, 0 replies.
- Re: [PR] publish wheel for apache-flink-libraries [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:24:49 UTC, 12 replies.
- Re: [PR] [client] optimise JobStatusPollingUtils of pollJobResultAsync [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:25:21 UTC, 0 replies.
- Re: [PR] Add Kafka-to-Kafka SQL Example to Documentation [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:25:54 UTC, 0 replies.
- Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:37:44 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/13 15:41:02 UTC, 1 replies.
- [PR] [model] Support Deepseek Function [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/08/13 15:59:37 UTC, 40 replies.
- Re: [PR] [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation [flink] - posted by "Ashfaqbs (via GitHub)" <gi...@apache.org> on 2025/08/13 17:11:21 UTC, 0 replies.
- Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws] - posted by "aws-nageshvh (via GitHub)" <gi...@apache.org> on 2025/08/13 21:43:59 UTC, 3 replies.
- Re: [PR] [FLINK-33306] Use observed source throughput as true processing rate [flink-kubernetes-operator] - posted by "sharath1709 (via GitHub)" <gi...@apache.org> on 2025/08/13 22:56:26 UTC, 9 replies.
- [jira] [Commented] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field - posted by "Fabrizzio Chavez (Jira)" <ji...@apache.org> on 2025/08/13 23:47:00 UTC, 0 replies.
- [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/14 00:07:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/14 00:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38240) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 01:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 01:57:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 01:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 02:00:00 UTC, 0 replies.
- [PR] [hotfix][doc] Update uses of Upload documentation in build_docs.yml. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/14 03:26:36 UTC, 3 replies.
- [PR] [FLINK-38204]use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/08/14 03:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-38204] Use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/14 04:51:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/14 04:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-27491] Support env replacement in flink-kubernetes-operator [flink-kubernetes-operator] - posted by "vbabenkoru (via GitHub)" <gi...@apache.org> on 2025/08/14 05:06:40 UTC, 0 replies.
- [jira] [Created] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/08/14 05:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/08/14 05:51:00 UTC, 1 replies.
- [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] - posted by "weiqingy (via GitHub)" <gi...@apache.org> on 2025/08/14 06:00:52 UTC, 3 replies.
- [jira] [Created] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/14 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38244) When the table name of mysql supports size sensitive, fix the error that column name not being found - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/14 06:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/14 06:03:00 UTC, 1 replies.
- Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/14 06:25:57 UTC, 0 replies.
- Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/14 06:25:59 UTC, 0 replies.
- [PR] [FLINK-38244] When the column name of mysql supports case-insensitive, fix the error that column name not being found. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/08/14 06:31:44 UTC, 2 replies.
- [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/14 07:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/14 07:14:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/14 07:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/14 08:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38222) Upgrade HBase client version to 2.6 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/08/14 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/14 12:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/14 12:41:00 UTC, 5 replies.
- [jira] [Created] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "morvenhuang (Jira)" <ji...@apache.org> on 2025/08/14 12:45:00 UTC, 0 replies.
- [PR] [FLINK-38246][table-planner]Remove unreachable code in CodeGenUtils [flink] - posted by "morvenhuang (via GitHub)" <gi...@apache.org> on 2025/08/14 13:01:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/14 13:02:00 UTC, 0 replies.
- [PR] [hotfix][tests] Enable restore tests again [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/14 14:09:20 UTC, 0 replies.
- Re: [PR] [hotfix][tests] Enable multi join restore tests again [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/14 14:16:44 UTC, 0 replies.
- [jira] [Created] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/14 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/14 16:49:00 UTC, 0 replies.
- [PR] [hotfix][Docs]fix typo and format in state.md & state_v2.md [flink] - posted by "Jackeyzhe (via GitHub)" <gi...@apache.org> on 2025/08/14 17:22:28 UTC, 2 replies.
- Re: [D] Replay-based Per Action State Consistency [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/14 22:58:45 UTC, 7 replies.
- Re: [PR] [hotfix] remove test scope dependency commons-codec in parent pom [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/15 00:04:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI - posted by "yuan (Jira)" <ji...@apache.org> on 2025/08/15 02:57:00 UTC, 1 replies.
- Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/08/15 03:12:04 UTC, 0 replies.
- Re: [PR] [api][python] Separate the abstraction of ChatModel to connection and settings [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/15 03:20:41 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/15 03:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/15 03:38:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/15 03:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24215) Timeout exception in submitting a job by RemoteStreamEnvironment/RemoteEnvironment - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/15 03:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-25666) Remove LegacyTypeInfoDataTypeConverter - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/15 03:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24931) Remove deprecated/unused class files in flink-scala module. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/15 03:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-37959][postgres]Supports all pgsql field types like debezium [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/15 03:53:21 UTC, 8 replies.
- [PR] [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/08/15 03:57:56 UTC, 4 replies.
- [jira] [Updated] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/15 03:58:00 UTC, 0 replies.
- [PR] [FLINK-38248] The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2025/08/15 05:06:35 UTC, 12 replies.
- [jira] [Updated] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/15 05:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/15 05:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-37672] Bump protobuf-maven-plugin [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/15 06:25:55 UTC, 1 replies.
- [PR] [Flink-38238] Support varchar(0) and map to cdc string type [flink-cdc] - posted by "proletarians (via GitHub)" <gi...@apache.org> on 2025/08/15 06:26:57 UTC, 1 replies.
- [jira] [Created] (FLINK-38249) Flink CDC should let users configure Debezium’s 'skipped.operations' parameter to filter out unwanted binlog operations. - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2025/08/15 07:21:00 UTC, 0 replies.
- [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] - posted by "danzhewuju (via GitHub)" <gi...@apache.org> on 2025/08/15 07:29:19 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/15 07:45:00 UTC, 2 replies.
- Re: [PR] [API][Runtime]Introduce Memory Reference [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/15 07:48:34 UTC, 2 replies.
- [jira] [Created] (FLINK-38250) The Flink CDC type supports the timeTZ field type. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/15 08:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] - posted by "liubao68 (via GitHub)" <gi...@apache.org> on 2025/08/15 08:51:08 UTC, 0 replies.
- [jira] [Created] (FLINK-38251) Fix recompilation of restore tests for MultiJoinTestPrograms - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/15 09:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-38251][table-planner] Enable multi join restore tests again [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/08/15 09:36:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-38251) Fix recompilation of restore tests for MultiJoinTestPrograms - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/15 09:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38251) Fix recompilation of restore tests for MultiJoinTestPrograms - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/15 09:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38238) Failed to process MySQL table with varchar(0) column - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/15 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/08/15 09:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/08/15 09:50:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/08/15 10:00:01 UTC, 2 replies.
- [PR] Feature migrate to flink 2.0.0 no legacy [flink-training] - posted by "XenoAmess (via GitHub)" <gi...@apache.org> on 2025/08/15 10:00:32 UTC, 0 replies.
- [jira] [Created] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/15 11:40:00 UTC, 0 replies.
- [PR] [FLINK-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink] - posted by "Frawless (via GitHub)" <gi...@apache.org> on 2025/08/15 11:54:03 UTC, 2 replies.
- [jira] [Updated] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/15 11:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/15 11:59:00 UTC, 1 replies.
- [PR] [FLINK-37406] Add support for structured YAML config in FlinkDeployment CRD [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/15 12:36:10 UTC, 3 replies.
- [jira] [Updated] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/15 12:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/15 12:45:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38115) Synchronous the Python JDBC connector with the Java implementation - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/08/15 13:06:00 UTC, 0 replies.
- [PR] [DOCS] List 3rd Party connector for NATS [flink] - posted by "scottf (via GitHub)" <gi...@apache.org> on 2025/08/15 16:25:58 UTC, 5 replies.
- [PR] [FLINK-32695] [test-utils] Add flink-test-utils-source module for Source V2 tests. [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/15 18:54:51 UTC, 2 replies.
- Re: [PR] [FLINK-37331][tests] Add comprehensive data type coverage tests for new MysqlSource implementation [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/16 00:04:42 UTC, 1 replies.
- Re: [PR] [FLINK-37968] Bump Netty version to v4.1.122.Final [flink-connector-aws] - posted by "Neo2308 (via GitHub)" <gi...@apache.org> on 2025/08/16 05:18:05 UTC, 1 replies.
- Re: [PR] [FLINK-35704] Use ForkJoinPool in NonSplittingRecursiveEnumerator [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/16 06:25:26 UTC, 1 replies.
- [jira] [Created] (FLINK-38254) Hidding sensitive information - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/16 14:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/16 14:22:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/16 14:37:00 UTC, 7 replies.
- [jira] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/16 14:38:00 UTC, 0 replies.
- [PR] Flink model support deepseek [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/08/16 18:40:38 UTC, 2 replies.
- Re: [PR] [FLINK-36465] Bump okhttp3 to 4.12.0 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/17 06:25:38 UTC, 1 replies.
- [PR] [hotfix] fix examples can't execute [flink-agents] - posted by "zhaomin1423 (via GitHub)" <gi...@apache.org> on 2025/08/17 10:39:54 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/17 10:47:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/17 11:27:00 UTC, 0 replies.
- [PR] [FLINK-38254][table] Add ITCase to verify sensitive table option reda… [flink] - posted by "liyang1206 (via GitHub)" <gi...@apache.org> on 2025/08/17 12:56:54 UTC, 1 replies.
- [PR] [hotfix] fix hashCode don't override when equals override [flink-agents] - posted by "zhaomin1423 (via GitHub)" <gi...@apache.org> on 2025/08/17 14:00:49 UTC, 1 replies.
- Re: [PR] [improvement] adding runtime converter array [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/17 14:54:52 UTC, 2 replies.
- Re: [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/17 15:15:14 UTC, 1 replies.
- [jira] [Closed] (FLINK-38254) Hide sensitive information in the exception message when performing table validation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/17 15:53:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrate Common Test cases away from legacy Source/Sink [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/17 17:05:05 UTC, 6 replies.
- [jira] [Created] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/18 01:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/18 01:59:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/18 02:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL [flink] - posted by "cshuo (via GitHub)" <gi...@apache.org> on 2025/08/18 03:28:14 UTC, 3 replies.
- [PR] [FLINK-33387][runtime] Introduce the abstraction and the interface about loading [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/18 06:35:22 UTC, 4 replies.
- [PR] [hotfix][runtime] Modify with more appropriate variable name for defer slots allocation logic. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/18 06:36:27 UTC, 2 replies.
- [jira] [Assigned] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/18 06:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-38255][table] Add ITCase to verify sensitive table option reda… [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/08/18 06:41:37 UTC, 11 replies.
- [PR] [hotfix] fix parameter name inconsistency in ollama example [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/18 08:06:29 UTC, 1 replies.
- Re: [PR] [FLINK-32695] [Tests] Add flink-test-utils-source module for Source V2 tests. [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/18 08:50:19 UTC, 4 replies.
- Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink] - posted by "raphaelauv (via GitHub)" <gi...@apache.org> on 2025/08/18 09:21:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38244) When the column name of mysql supports case insensitive, fix the error that column name not being found - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/18 09:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/18 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 10:04:00 UTC, 0 replies.
- [PR] [FLINK-38256][table] Sync unparse for `TABLE` and `SHOW CREATE TABLE` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/18 10:17:25 UTC, 2 replies.
- Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/18 10:17:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/18 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/18 10:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/18 10:50:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/18 10:51:00 UTC, 0 replies.
- [PR] [FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/08/18 11:45:01 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/18 11:52:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/18 11:55:00 UTC, 0 replies.
- [PR] Flink 38211 [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/18 12:15:54 UTC, 0 replies.
- Re: [PR] [FLINK-38211][table-planner] Refactor explain for MultiJoin [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/08/18 12:20:34 UTC, 3 replies.
- Re: [PR] [hotfix] Set version to 3.4-SNAPSHOT [flink-connector-kafka] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/18 12:31:10 UTC, 0 replies.
- Re: [PR] [FLINK-38147] Add Flink 2.1 support [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/18 13:05:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-38147) Add Flink 2.1 support to operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/18 13:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38147) Add Flink 2.1 support to operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/18 13:06:00 UTC, 0 replies.
- [PR] Add support for structured YAML config in FlinkDeployment CRD [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/18 14:47:23 UTC, 0 replies.
- Re: [PR] [WIP][FLINK-37406] Add support for structured YAML config in FlinkDeployment CRD [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/18 14:48:00 UTC, 12 replies.
- [jira] [Commented] (FLINK-37827) Failed to use `SHOW CREATE TABLE` for MATERIALIZED_TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 15:52:00 UTC, 0 replies.
- [PR] [FLINK-37827][table] Add support for `SHOW CREATE MATERIZLIED TABLE` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/08/18 16:01:34 UTC, 0 replies.
- Re: [PR] [FLINK-37827][table] Add support for `SHOW CREATE MATERIALIZED TABLE` [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/18 16:08:39 UTC, 9 replies.
- [jira] [Created] (FLINK-38258) Enable model param for PTF - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 16:53:00 UTC, 0 replies.
- [PR] [FLINK-38258][model] support model args in ptf and add ml_predict builtin ptf [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/08/18 17:06:43 UTC, 4 replies.
- [jira] [Updated] (FLINK-38258) Enable model param for PTF - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/18 17:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 18:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 20:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38260) Connection sql syntax - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38261) Connection catalog object and manager changes - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38264) Connection table api - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38263) Connection and secret factory - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38262) Convert connection sqlnode to operations - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/19 01:34:27 UTC, 1 replies.
- [PR] [FLINK-38131][flink-runtime] fix that JM still redistributes broadcas… [flink] - posted by "xiangforever2014 (via GitHub)" <gi...@apache.org> on 2025/08/19 06:29:30 UTC, 8 replies.
- [jira] [Updated] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/19 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/19 06:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/19 06:45:00 UTC, 4 replies.
- [PR] [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/08/19 07:16:29 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Add flink-test-utils-connectors module for Source V2 tests. [flink] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/19 07:25:10 UTC, 6 replies.
- Re: [PR] [FLINK-38255][table][tests] Add ITCase to verify sensitive table option redaction [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/08/19 07:34:50 UTC, 0 replies.
- [I] [Feature] Introduce Configuration Mechanism for Event Logger System [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/19 07:45:34 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/19 07:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/19 07:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/19 08:15:17 UTC, 0 replies.
- [I] [Feature][api][runtime] Introduce configuration mechanism [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/19 08:49:16 UTC, 0 replies.
- Re: [I] [Feature] Support Configuring Event Logger via Configuration System [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/19 09:01:13 UTC, 1 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/08/19 09:52:54 UTC, 1 replies.
- [jira] [Created] (FLINK-38266) SQL Gateway - mask sensitive table and catalog options - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2025/08/19 10:01:00 UTC, 0 replies.
- [PR] [FLINK-38266][flink-sql-gateway] SQL Gateway - mask sensitive table and catalog options [flink] - posted by "maciejmaciejko-gid (via GitHub)" <gi...@apache.org> on 2025/08/19 11:21:46 UTC, 3 replies.
- [jira] [Updated] (FLINK-38266) SQL Gateway - mask sensitive table and catalog options - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/19 11:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38266) SQL Gateway - mask sensitive table and catalog options - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/08/19 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/19 12:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/19 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/19 12:03:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/19 12:37:00 UTC, 4 replies.
- [PR] [FLINK-37391][docs] Improve documentation for dynamic namespace watching configuration [flink-kubernetes-operator] - posted by "kumar-mallikarjuna (via GitHub)" <gi...@apache.org> on 2025/08/19 12:44:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-37391) Change watchNamespace config in operator is not respected while running - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/19 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/19 13:14:00 UTC, 0 replies.
- [PR] [model] TEst [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/08/19 15:07:31 UTC, 2 replies.
- [PR] [models] support deepseek、qwen [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/08/19 16:48:55 UTC, 31 replies.
- [jira] [Created] (FLINK-38269) Make Job Manager's REST endpoint advertised address configurable - posted by "Yaroslav (Jira)" <ji...@apache.org> on 2025/08/19 20:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38269) Make Job Manager's REST endpoint advertised address configurable - posted by "Yaroslav (Jira)" <ji...@apache.org> on 2025/08/19 20:33:00 UTC, 0 replies.
- Re: [PR] [api][python] mcp definition and interfaces [flink-agents] - posted by "istavrak (via GitHub)" <gi...@apache.org> on 2025/08/19 20:58:55 UTC, 7 replies.
- Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/20 00:04:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/20 00:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/20 00:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/20 00:20:00 UTC, 1 replies.
- [I] [Feature] [integration][python] Integrate built-in tongyi chatmodel. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/20 01:55:27 UTC, 2 replies.
- [I] [Feature] [integration][python] Integrate built-in openai chat model. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/20 01:56:29 UTC, 0 replies.
- [jira] [Created] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/20 02:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/20 02:09:00 UTC, 2 replies.
- [PR] [Integration][ChatModel]Add built-in tongyi chat model in python [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/20 02:32:52 UTC, 6 replies.
- [jira] [Assigned] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/20 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/20 03:32:00 UTC, 0 replies.
- [PR] Feature: [api][runtime][python] Introduce configuration mechanism [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/20 03:36:10 UTC, 8 replies.
- [jira] [Assigned] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/20 05:39:00 UTC, 0 replies.
- Re: [PR] Fix CVE-2022-25168 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/20 06:25:57 UTC, 0 replies.
- Re: [PR] [FLINK-37817] Adds bundled aggregates for group by (FLIP-491) [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/20 06:25:59 UTC, 0 replies.
- [I] [Tech Debt][Java] Enrich test cases of MemoryObject in java [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/20 06:29:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-38250) The Flink CDC type supports the timeTZ/Time field type. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/20 06:40:00 UTC, 1 replies.
- [PR] [hotfix]Enrich test cases of MemoryObject in java [flink-agents] - posted by "KeGu-069 (via GitHub)" <gi...@apache.org> on 2025/08/20 06:46:33 UTC, 0 replies.
- Re: [PR] [FLINK-38079] Add Pipeline support for DateType and TimeType [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/08/20 07:36:00 UTC, 11 replies.
- [jira] [Closed] (FLINK-37887) Watched namespaces not picked up automatically by the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/20 08:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37391) Change watchNamespace config in operator is not respected while running - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/20 08:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-32695] Moved TestSource in TypeFillTest to SourceV2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/20 09:13:04 UTC, 1 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/20 10:12:06 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37959) supported All postgres sql 14 field types. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/20 11:48:00 UTC, 0 replies.
- [PR] [FLINK-38232] [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss [flink-cdc] - posted by "suhwan-cheon (via GitHub)" <gi...@apache.org> on 2025/08/20 12:36:56 UTC, 0 replies.
- [jira] [Updated] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/20 12:38:00 UTC, 0 replies.
- [PR] [FLINK-38267] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/08/20 12:53:10 UTC, 34 replies.
- [PR] Update examples to use yaml based configs [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/20 13:54:41 UTC, 0 replies.
- [PR] Check for GNU tar [flink-connector-shared-utils] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/08/20 14:04:12 UTC, 1 replies.
- Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/21 00:03:58 UTC, 0 replies.
- Re: [PR] [FLINK-37710] Use schemas from the state in SchemaOperator [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/21 00:03:58 UTC, 0 replies.
- Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/21 00:04:04 UTC, 0 replies.
- [I] [Tech Debt] Remove legacy requirements folder [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/21 05:47:04 UTC, 0 replies.
- Re: [PR] [hotfix]Enrich test cases of Short-Term Memory in java [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/21 06:07:23 UTC, 0 replies.
- [PR] WIP: [api][python] Introduce built-in ReAct Agent. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/21 06:12:54 UTC, 2 replies.
- Re: [PR] [FLINK-18590][json] Support json array explode to multi messages (#26… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/21 06:26:59 UTC, 0 replies.
- [PR] [FLINK-38157][postgres-pipeline] supported chunk first options [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/21 08:12:54 UTC, 2 replies.
- [jira] [Updated] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/21 08:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/21 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38273) Flink SQL Client Embedded Mode Configuration Regression in 1.19 - Connection fails when rest.bind-port is configured - posted by "shml (Jira)" <ji...@apache.org> on 2025/08/21 08:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38273) SQL Client Embedded Mode Fails to Connect When rest.bind-port is Set - posted by "shml (Jira)" <ji...@apache.org> on 2025/08/21 08:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38124) The autoscaling example misses README - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/08/21 09:40:00 UTC, 0 replies.
- [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/21 12:58:15 UTC, 1 replies.
- [jira] [Created] (FLINK-38274) Improve kubernetes operator config options for better yaml structure - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/21 13:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/21 13:16:00 UTC, 0 replies.
- Re: [PR] Add hostNetwork for operator pod, default false [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/21 13:17:44 UTC, 1 replies.
- Re: [PR] [FLINK-36932][metrics] Added resource-level metrics for different states/statuses [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/21 13:18:41 UTC, 1 replies.
- Re: [PR] [FLINK-37126] Add Validator for Autoscaler [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/21 13:32:30 UTC, 1 replies.
- Re: [PR] [FLINK-35397] Translate controller-flow documents into Chinese [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/21 13:32:39 UTC, 1 replies.
- Re: [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2025/08/21 20:31:29 UTC, 3 replies.
- Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/22 00:04:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-38088) If source config "scan.startup.mode:snapshot",not create replicatedconnect. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 01:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/08/22 02:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/08/22 02:31:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38275) Doris Pipeline Sink cannot create a table when the upstream has no primary key and the first column is String - posted by "Di Wu (Jira)" <ji...@apache.org> on 2025/08/22 02:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38275) Cannot create a table when the upstream has no primary key and the first column is String - posted by "Di Wu (Jira)" <ji...@apache.org> on 2025/08/22 02:36:00 UTC, 1 replies.
- [PR] [FLINK-38275][Pipeline-connectors][doris]Cannot create a table when the upstream has no primary key and the first column is String [flink-cdc] - posted by "JNSimba (via GitHub)" <gi...@apache.org> on 2025/08/22 02:36:58 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37868][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/08/22 02:39:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/22 02:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/22 02:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.4.0 [flink-cdc] - posted by "ThorneANN (via GitHub)" <gi...@apache.org> on 2025/08/22 03:16:40 UTC, 2 replies.
- [jira] [Created] (FLINK-38276) PaimonWriter does not invalidate cache when schema changes - posted by "yangyu (Jira)" <ji...@apache.org> on 2025/08/22 03:53:00 UTC, 0 replies.
- [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc] - posted by "tbpure (via GitHub)" <gi...@apache.org> on 2025/08/22 04:04:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-38276) PaimonWriter does not invalidate cache when schema changes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/22 04:05:00 UTC, 0 replies.
- [PR] [FLINK-37669][HELM] Add Helm chart unit tests to flink kubernetes operator [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/22 05:33:28 UTC, 4 replies.
- Re: [PR] [FLINK-37406] Update examples to use yaml based configs [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/22 05:59:54 UTC, 0 replies.
- [PR] [FLINK-38250] The Flink CDC type supports the timeTZ field type. [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/22 06:04:02 UTC, 0 replies.
- [jira] [Created] (FLINK-38277) Enhance postgresSQL slot management capabilities - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 06:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38273) SQL Client Embedded Mode Fails to Connect When rest.bind-port is Set - posted by "shml (Jira)" <ji...@apache.org> on 2025/08/22 07:47:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-38273) SQL Client Embedded Mode Fails to Connect When rest.bind-port is Set - posted by "shml (Jira)" <ji...@apache.org> on 2025/08/22 07:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-32695] [Tests] Migrate ProcessingTimeServiceSource from Source Function to Source V2 API in StreamSourceOperatorLatencyMetricsTest [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/22 08:46:25 UTC, 4 replies.
- [I] [Tech Debt] PEMJA Fails to Print Error Messages When Java Throw Exceptions [flink-agents] - posted by "GreatEugenius (via GitHub)" <gi...@apache.org> on 2025/08/22 09:05:07 UTC, 1 replies.
- [PR] [FLINK-37406] Fix config array serialization [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/22 09:24:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-38277) Enhance postgresSQL slot management capabilities - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/22 09:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/22 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38278) PostgresSQL supported array field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 10:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38278) PostgresSQL pipeline supported array field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 10:22:00 UTC, 1 replies.
- [PR] [FLINK-38278][postgres-pipeline] supported array type field. [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/22 10:27:02 UTC, 10 replies.
- [PR] [FLINK-37193] Feature flag if operator should manage ingress [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/22 11:07:42 UTC, 8 replies.
- Re: [PR] [FLINK-38176] Add Flink kafka connector 4.0.1 [flink-web] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/08/22 12:05:23 UTC, 0 replies.
- [PR] [FLINK-38257][SQL] Add module dynamic function loading possibility [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/08/22 12:05:46 UTC, 17 replies.
- [jira] [Resolved] (FLINK-38176) Release kafka connector 4.0.1 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/08/22 12:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-37799][model] support deepseek、qwen [flink] - posted by "qining-mj (via GitHub)" <gi...@apache.org> on 2025/08/22 12:21:22 UTC, 36 replies.
- [jira] [Assigned] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/08/22 14:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-37369] Add OceanBaseValueConverters to fix table schema valida… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/23 00:04:49 UTC, 1 replies.
- Re: [PR] Flink 36798 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/23 00:04:56 UTC, 2 replies.
- Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] - posted by "cnauroth (via GitHub)" <gi...@apache.org> on 2025/08/23 01:06:43 UTC, 0 replies.
- [jira] [Created] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/23 03:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/23 04:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/23 06:25:25 UTC, 5 replies.
- [jira] [Created] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/08/24 05:22:00 UTC, 0 replies.
- [PR] [FLINK-38148] [FlinkService] Support Flink v1.17 when listing job exceptions [flink-kubernetes-operator] - posted by "fijolekProjects (via GitHub)" <gi...@apache.org> on 2025/08/24 09:46:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/24 09:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-38148][FlinkService] Support Flink v1.17 when listing job exceptions [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/08/24 14:06:28 UTC, 5 replies.
- [PR] scala 3 benchmark addition [flink-benchmarks] - posted by "novakov-alexey (via GitHub)" <gi...@apache.org> on 2025/08/24 18:16:10 UTC, 1 replies.
- [jira] [Closed] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/24 19:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/25 02:01:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/25 02:03:00 UTC, 3 replies.
- [jira] [Created] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/08/25 02:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled(pt-osc,gh-ost) - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/08/25 02:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38131) Repartition BroadcastState with finished operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/08/25 02:29:00 UTC, 0 replies.
- Re: [PR] [FLINK-34015][checkpoint] fix that passing ignore-unclaimed-state through dynamic props does not take effect [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/25 06:26:12 UTC, 1 replies.
- Re: [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/25 06:26:17 UTC, 1 replies.
- [jira] [Resolved] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2025/08/25 11:28:00 UTC, 0 replies.
- [PR] [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/08/25 15:58:05 UTC, 6 replies.
- [jira] [Created] (FLINK-38282) K8S operator : S3 jarURI - posted by "raphaelauv (Jira)" <ji...@apache.org> on 2025/08/25 16:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38282) K8S operator : S3 jarURI - posted by "raphaelauv (Jira)" <ji...@apache.org> on 2025/08/25 16:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38282) K8S operator : S3 jarURI - posted by "raphaelauv (Jira)" <ji...@apache.org> on 2025/08/25 17:24:00 UTC, 2 replies.
- [jira] [Created] (FLINK-38283) Support customized autoscaling algorithm - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/08/25 18:18:00 UTC, 0 replies.
- [PR] support autoscaling scaling realizer [flink-kubernetes-operator] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2025/08/25 18:25:33 UTC, 3 replies.
- Re: [PR] [Draft] support autoscaling scaling realizer [flink-kubernetes-operator] - posted by "ctrlaltdilj (via GitHub)" <gi...@apache.org> on 2025/08/25 18:39:53 UTC, 1 replies.
- [PR] [FLINK-37181][2.0][build] Fix MacOS sha256sum tool compile error [flink] - posted by "mohsenrezaeithe (via GitHub)" <gi...@apache.org> on 2025/08/25 19:08:46 UTC, 2 replies.
- [PR] [FLINK-37181][1.20][build] Fix MacOS sha256sum tool compile error [flink] - posted by "mohsenrezaeithe (via GitHub)" <gi...@apache.org> on 2025/08/25 19:20:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/08/25 19:23:00 UTC, 1 replies.
- [PR] Flink parallel checkpoint deletion cherrypick [flink] - posted by "maheepm-lyft (via GitHub)" <gi...@apache.org> on 2025/08/25 21:02:47 UTC, 1 replies.
- Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/26 00:04:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/08/26 01:52:00 UTC, 0 replies.
- [PR] [FLINK-37738][postgres-cdc] Fix the corresponding Chinese and English of the append only document [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2025/08/26 02:18:29 UTC, 1 replies.
- [jira] [Created] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Jaehyun Kim (Jira)" <ji...@apache.org> on 2025/08/26 05:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Jaehyun Kim (Jira)" <ji...@apache.org> on 2025/08/26 05:46:00 UTC, 3 replies.
- Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/26 06:25:43 UTC, 1 replies.
- [jira] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/08/26 06:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/26 07:26:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38285) Allow to overrride config options with environment variables - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/26 07:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38285) Allow to overrride config options with environment variables - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/26 07:50:00 UTC, 8 replies.
- Re: [PR] [FLINK-37682] Upgrade Jackson Lib to Address CVE-2023-35116 [flink-kubernetes-operator] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/08/26 07:50:24 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38285) Allow to overrride config options with environment variables - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/26 07:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/26 08:24:00 UTC, 0 replies.
- Re: [PR] Feature: [api][runtime] Introduce configuration mechanism [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/26 08:25:06 UTC, 4 replies.
- Re: [PR] [api][python] Introduce built-in ReAct Agent. [flink-agents] - posted by "xintongsong (via GitHub)" <gi...@apache.org> on 2025/08/26 08:25:56 UTC, 4 replies.
- [jira] [Commented] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/26 08:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/26 08:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/26 08:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Jaehyun Kim (Jira)" <ji...@apache.org> on 2025/08/26 08:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Jaehyun Kim (Jira)" <ji...@apache.org> on 2025/08/26 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/08/26 10:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38285) Allow to override config options with environment variables - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/26 10:39:00 UTC, 1 replies.
- [PR] [FLINK-38285] Allow to override config options with environment variables [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/26 10:39:53 UTC, 0 replies.
- [PR] [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/08/26 10:45:37 UTC, 4 replies.
- [jira] [Updated] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/26 10:46:00 UTC, 3 replies.
- [PR] [integration][python] Integrate OpenAI chat model. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/26 11:06:27 UTC, 14 replies.
- [jira] [Created] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2025/08/26 13:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2025/08/26 13:47:00 UTC, 0 replies.
- [PR] [FLINK-32695] [Tests] Migrated ChangelogStateBackendLoadingTest to Source V2 [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/26 16:57:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37588) Flink Kubernetes Operator Parameter `jm-deployment.shutdown-ttl` does not take effect - posted by "chaoran.su (Jira)" <ji...@apache.org> on 2025/08/26 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38288) Improve BlobWriter logging to include TaskRestore offloading duration - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/08/26 17:48:00 UTC, 0 replies.
- [PR] [FLINK-36694][Filesystems] Update Azure FS to Hadoop 3.4.1 with versioned Hadoop modules for 3.3 and 3.4 [flink] - posted by "mohsenrezaeithe (via GitHub)" <gi...@apache.org> on 2025/08/26 21:16:42 UTC, 3 replies.
- [jira] [Commented] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/08/26 21:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1 - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2025/08/26 21:19:00 UTC, 1 replies.
- Re: [PR] [FLINK-37585] [cdc-connector][mysql] Fixed the data of the newly added table cannot be read [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/27 00:04:52 UTC, 0 replies.
- Re: [PR] [api][java] react agent api [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/27 03:05:19 UTC, 0 replies.
- [PR] [hotfix] [docs] Optimize Chinese translation on page /zh/dev/table/streaming/overview [flink] - posted by "hayden520 (via GitHub)" <gi...@apache.org> on 2025/08/27 05:44:13 UTC, 4 replies.
- Re: [PR] [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/08/27 07:49:51 UTC, 6 replies.
- [jira] [Commented] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/27 08:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/27 08:52:00 UTC, 0 replies.
- [I] [Feature] [integration][python] Integrate built-in Anthropic chat model. [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/08/27 09:06:14 UTC, 0 replies.
- [I] [Feature] support VectorStore [flink-agents] - posted by "alnzng (via GitHub)" <gi...@apache.org> on 2025/08/27 09:14:21 UTC, 0 replies.
- [PR] [backport][2.0][FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results [flink] - posted by "raminqaf (via GitHub)" <gi...@apache.org> on 2025/08/27 09:46:53 UTC, 0 replies.
- Re: [PR] [backport 2.1][FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/27 09:50:16 UTC, 1 replies.
- Re: [PR] [backport 2.0][FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/08/27 09:50:23 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/27 13:54:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/27 13:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/08/27 14:43:37 UTC, 2 replies.
- [jira] [Created] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/08/27 16:37:00 UTC, 0 replies.
- [PR] [FLINK-38289] Update to Flink 2.1 [flink-connector-kafka] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2025/08/27 16:37:04 UTC, 6 replies.
- [jira] [Updated] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/27 16:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-29731) Protobuf-confluent format - posted by "Le Phong Vu (Jira)" <ji...@apache.org> on 2025/08/27 16:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-29731) Protobuf-confluent format - posted by "Le Phong Vu (Jira)" <ji...@apache.org> on 2025/08/27 16:52:00 UTC, 1 replies.
- [jira] [Created] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM restarts - posted by "Urs Schoenenberger (Jira)" <ji...@apache.org> on 2025/08/27 19:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM restarts - posted by "Urs Schoenenberger (Jira)" <ji...@apache.org> on 2025/08/27 20:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated - posted by "Urs Schoenenberger (Jira)" <ji...@apache.org> on 2025/08/27 20:56:00 UTC, 0 replies.
- [I] [Improvement] MVP user experience check [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/28 01:48:23 UTC, 0 replies.
- [PR] [hotfix] [docs] Refine Chinese translation for page /zh/dev/table/dat… [flink] - posted by "hayden520 (via GitHub)" <gi...@apache.org> on 2025/08/28 03:21:17 UTC, 5 replies.
- [jira] [Resolved] (FLINK-38278) PostgresSQL pipeline supported array field types. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/28 05:40:00 UTC, 0 replies.
- Re: [PR] [FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/28 06:25:44 UTC, 1 replies.
- [PR] [FLINK-38288] Enhance BlobWriter logging with blob size and duration [flink] - posted by "Izeren (via GitHub)" <gi...@apache.org> on 2025/08/28 06:58:33 UTC, 5 replies.
- [jira] [Updated] (FLINK-38288) Improve BlobWriter logging to include TaskRestore offloading duration - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/28 06:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38288) Improve BlobWriter logging to include offloaded value size and offloading duration - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/08/28 07:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38288) Improve BlobWriter logging to include offloaded value size and offloading duration - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/08/28 07:00:00 UTC, 0 replies.
- [I] [Feature] Support OpenAI latest Response API [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/28 07:11:47 UTC, 0 replies.
- [jira] [Created] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/08/28 07:24:00 UTC, 0 replies.
- [PR] [hotfix] Fix coredump when close async thread pool. [flink-agents] - posted by "wenjin272 (via GitHub)" <gi...@apache.org> on 2025/08/28 07:50:53 UTC, 1 replies.
- [PR] [FLINK-38291][REST] Reduce thread lock overhead for REST handlers [flink] - posted by "yunfengzhou-hub (via GitHub)" <gi...@apache.org> on 2025/08/28 07:52:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/08/28 07:53:00 UTC, 0 replies.
- [I] [Feature] Improve the docstring of public facing API [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/28 08:48:27 UTC, 0 replies.
- [I] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/28 08:53:02 UTC, 0 replies.
- [I] [Feature] README should stick with the recommended way to build the project [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/28 08:57:41 UTC, 0 replies.
- [PR] DO NOT COMMIT - test commit to drive license checker failure [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/08/28 09:04:36 UTC, 1 replies.
- [PR] [FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2025/08/28 09:24:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-38292) Flink CDC doesn't support altering table properties for Paimon Sinks - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/08/28 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38292) Flink CDC doesn't support altering table properties for Paimon Sinks - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/08/28 10:21:00 UTC, 0 replies.
- [PR] Express is values.yaml that config.yaml can be used [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/28 12:35:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37827) Failed to use `SHOW CREATE TABLE` for MATERIALIZED_TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/28 12:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37827) `SHOW CREATE TABLE` should fail in for MATERIALIZED_TABLE, add `SHOW CREATE MATERIALIZED TABLE` - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/28 12:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37827) `SHOW CREATE TABLE` should fail in for MATERIALIZED_TABLE, add `SHOW CREATE MATERIALIZED TABLE` - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/28 12:54:00 UTC, 0 replies.
- [PR] Update checkstyle [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/08/28 13:48:32 UTC, 0 replies.
- [jira] [Created] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/28 13:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/28 14:45:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37669) [HELM] Add Helm chart unit tests to flink kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/28 14:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37669) [HELM] Add Helm chart unit tests to flink kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/28 14:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38288) Improve BlobWriter logging to include offloaded value size and offloading duration - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/28 17:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/28 20:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/28 20:10:00 UTC, 0 replies.
- [PR] Add Postgresql UUID catalog support [flink-connector-jdbc] - posted by "kcolford (via GitHub)" <gi...@apache.org> on 2025/08/29 00:14:29 UTC, 1 replies.
- [PR] [hotfix] Fix incorrect import path of flink_agents [flink-agents] - posted by "Sxnan (via GitHub)" <gi...@apache.org> on 2025/08/29 02:48:38 UTC, 1 replies.
- [jira] [Created] (FLINK-38294) Hbase connector misclassifies failed task as successful - posted by "Chu Xue (Jira)" <ji...@apache.org> on 2025/08/29 05:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38294) Hbase connector misclassifies failed task as successful - posted by "Chu Xue (Jira)" <ji...@apache.org> on 2025/08/29 05:51:00 UTC, 1 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "j4k4 (via GitHub)" <gi...@apache.org> on 2025/08/29 10:25:43 UTC, 0 replies.
- Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] - posted by "nishita-09 (via GitHub)" <gi...@apache.org> on 2025/08/29 10:28:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/29 12:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37583) Upgrade Kafka Client version to 4.0.0 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/08/29 15:12:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37583) Upgrade Kafka Client version to 4.0.0 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/08/29 15:12:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37583) Upgrade Kafka Client version to 4.0.0 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/08/29 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38295) Amend parent connector pom version to 1.1.0 - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38296) Do documentation - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38297) wiremock version is very old - migrate to a later level - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38298) Remove mockito dependancy so we do not need to exclude from banned checklist - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38299) amend push github action to go against v1 snapsort - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38300) work out Flink v2 support (should work) - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38301) confirm Maven snapshot is working - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38302) change the config to use Flink config parameter names and gid fallback keys - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38303) default to use query-creator generic-json-url - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38304) Re write README - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38305) amend the prefix to not include gid and move to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38306) knit in the http connector docs into the Flink docs - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:24:00 UTC, 0 replies.
- [PR] FLINK-32695 Migrated SavepointReaderITTestBase to SourceV2. [flink] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/08/29 17:23:08 UTC, 2 replies.
- Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc] - posted by "cobolbaby (via GitHub)" <gi...@apache.org> on 2025/08/29 22:42:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/30 04:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/30 04:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/30 04:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/08/30 06:25:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager - posted by "Kim Gräsman (Jira)" <ji...@apache.org> on 2025/08/30 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38307) Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend - posted by "Naci Simsek (Jira)" <ji...@apache.org> on 2025/08/30 12:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-38307) Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend - posted by "Naci Simsek (Jira)" <ji...@apache.org> on 2025/08/30 12:12:00 UTC, 1 replies.
- [PR] [api] feat: Introduce ActionState related APIs [flink-agents] - posted by "letaoj (via GitHub)" <gi...@apache.org> on 2025/08/31 05:40:03 UTC, 0 replies.