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

---

- [PR] [hotfix] [docs] Edit Docs link location [flink] - posted by "ha2hi (via GitHub)" <gi...@apache.org> on 2025/02/01 07:23:10 UTC, 2 replies.
- [jira] [Created] (FLINK-37244) ScyllaDB support in Cassandra connector. - posted by "Maxim Korolyov (Jira)" <ji...@apache.org> on 2025/02/01 09:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37244) ScyllaDB support in Cassandra connector. - posted by "Maxim Korolyov (Jira)" <ji...@apache.org> on 2025/02/01 09:32:00 UTC, 1 replies.
- Re: [PR] [WIP] [FLINK-37244] mention scylladb in docs [flink-connector-cassandra] - posted by "mkorolyov (via GitHub)" <gi...@apache.org> on 2025/02/01 09:32:35 UTC, 0 replies.
- [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] - posted by "Lzgpom (via GitHub)" <gi...@apache.org> on 2025/02/01 15:35:39 UTC, 9 replies.
- [jira] [Updated] (FLINK-32097) Implement support for Kinesis deaggregation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/01 15:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/02/02 05:11:04 UTC, 1 replies.
- Re: [PR] FLINK-37154: Adding SimpleByteSchema for PyFlink [flink] - posted by "christeoh (via GitHub)" <gi...@apache.org> on 2025/02/02 09:29:26 UTC, 4 replies.
- [PR] [hotfix] Do not use `org.jetbrains.annotations.Nullable` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/02 19:00:41 UTC, 3 replies.
- [jira] [Created] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/02 19:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/02 19:57:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Anirudh Prabhakaran (Jira)" <ji...@apache.org> on 2025/02/03 02:50:00 UTC, 1 replies.
- Re: [PR] [FLINK-37222][Test] Introduce simple test submitting nexmark sql via sql client [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/03 09:25:02 UTC, 3 replies.
- Re: [PR] [FLINK-36929][table] Add SQL connector for keyed savepoint data [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/03 09:53:01 UTC, 2 replies.
- Re: [PR] [FLINK-36898][Table] Support SQL FLOOR and CEIL functions with NanoSecond and MicroSecond for TIMESTAMP_TLZ [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/03 10:08:02 UTC, 22 replies.
- Re: [PR] [FLINK-37175][table] Support JSON built-in function for JSON_OBJECT [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/03 10:32:50 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37175) Support JSON built-in function for JSON_OBJECT - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/03 10:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/03 10:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-37177][Doc] Update chinese documentation of json function [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/02/03 10:46:35 UTC, 8 replies.
- [PR] [FLINK-37239][docs][backport] Add examples for unhex, btrim, translate, elt and percentile [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/02/03 10:55:05 UTC, 2 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/02/03 13:35:32 UTC, 0 replies.
- Re: [PR] [FLINK-37213][table-runtime] Improve performance of unbounded OVER aggregations [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/02/03 14:23:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/03 14:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/03 14:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/03 14:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/03 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/03 18:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/03 18:44:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37179) [ArgoCD] App Out Of Sync after update to v1.7.0 - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2025/02/03 18:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2025/02/03 18:48:00 UTC, 1 replies.
- [PR] Jb/updated [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/02/03 18:50:28 UTC, 1 replies.
- [PR] Update to Flink 1.20 and Pulsar 3.0.2 [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/02/03 18:59:21 UTC, 0 replies.
- [PR] [FLINK-37245] Prevent masking null values in BinaryRowData [flink] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/02/03 20:25:05 UTC, 6 replies.
- [jira] [Updated] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/03 20:26:00 UTC, 0 replies.
- [PR] [FLINK-37246] add tokens acquired by current user for token refresh [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2025/02/03 21:20:10 UTC, 11 replies.
- [PR] Update to Flink 1.20 and Pulsar 3.0.2 with callbacks [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/02/03 21:38:17 UTC, 1 replies.
- [jira] [Created] (FLINK-37247) Implement common Hadoop file system integration tests for GCS. - posted by "Chris Nauroth (Jira)" <ji...@apache.org> on 2025/02/03 22:52:00 UTC, 0 replies.
- [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/02/03 22:58:11 UTC, 4 replies.
- [jira] [Updated] (FLINK-37247) Implement common Hadoop file system integration tests for GCS. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/03 22:59:00 UTC, 0 replies.
- Re: [PR] [ FLINK-33603][FileSystems] shade guava in gs-fs filesystem [flink] - posted by "cnauroth (via GitHub)" <gi...@apache.org> on 2025/02/03 22:59:30 UTC, 0 replies.
- Re: [PR] [FLINK-19059]: Support non-time retract mode for OverAggregate operator [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2025/02/04 01:19:38 UTC, 14 replies.
- [jira] [Created] (FLINK-37248) Scala was removed in flink 2.0 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/04 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/02/04 05:53:00 UTC, 0 replies.
- [PR] [FLINK-37249] Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/02/04 06:02:26 UTC, 2 replies.
- [jira] [Updated] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/04 06:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-36904][BP-1.20] Fix document error on how to programmatically configure serialization [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/02/04 06:10:14 UTC, 0 replies.
- Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/02/04 06:44:20 UTC, 4 replies.
- Re: [PR] Add Hive 3.0.0 connector [flink-web] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/04 07:05:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 07:22:00 UTC, 8 replies.
- [jira] [Created] (FLINK-37250) The flink application does not start because of an error in the configs - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2025/02/04 07:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37250) The flink application does not start because of an error in the configs - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2025/02/04 07:30:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/02/04 07:37:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37060) Cross-team verification for FLIP-398 - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/02/04 07:38:00 UTC, 2 replies.
- Re: [PR] [minor][docs] add Download Page in overview.md for Pipeline connectors. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/04 08:29:59 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/04 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37251) Add download link for pipeline connector. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 09:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37251) Add download link for pipeline connector. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 09:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-37232][runtime] Fix for broken synchronization assumption on the AdaptiveScheduler's side introduced by FLIP-272 [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2025/02/04 10:01:21 UTC, 4 replies.
- [PR] [FLINK-34729][docs] Translate "Core Concept" Pages of Flink CDC into Chinese Documentation. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/04 10:10:42 UTC, 1 replies.
- [jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/04 10:11:00 UTC, 2 replies.
- Re: [PR] [FLINK-37086] Clean up should remove all autoscaler state [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/02/04 10:21:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 11:53:00 UTC, 0 replies.
- Re: [PR] Add Flink 1.20.1 release [flink-web] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/02/04 13:20:01 UTC, 6 replies.
- [jira] [Updated] (FLINK-37248) Scala was removed in flink 2.0 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/04 13:29:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 13:35:00 UTC, 0 replies.
- [jira] (FLINK-37248) Scala was removed in flink 2.0 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/04 13:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37248) Scala was removed in flink 2.0 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/04 13:38:00 UTC, 2 replies.
- [PR] FLINK-37179 - remove priority: 0 from CRDs [flink-kubernetes-operator] - posted by "luismacosta (via GitHub)" <gi...@apache.org> on 2025/02/04 13:38:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-37179) [ArgoCD] App Out Of Sync after update to v1.7.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/04 13:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37179) [ArgoCD] App Out Of Sync after update to v1.7.0 - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2025/02/04 13:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 13:41:00 UTC, 0 replies.
- [PR] [FLINK-37191][mysql] Avoid back filling if the lowWatermark of BinlogSplit is equal to highWatermark. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/04 13:43:20 UTC, 10 replies.
- [jira] [Updated] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/04 13:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-34227][runtime] Ensure that the scheduler close call doesn't leak IO threads into the JobMaster [flink] - posted by "zentol (via GitHub)" <gi...@apache.org> on 2025/02/04 13:44:32 UTC, 5 replies.
- Re: [PR] [FLINK-34227][runtime] Fixes concurrency issue in JobMaster shutdown [flink] - posted by "zentol (via GitHub)" <gi...@apache.org> on 2025/02/04 13:46:51 UTC, 2 replies.
- [jira] [Closed] (FLINK-37213) Improve performance of unbounded OVER aggregations - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/04 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/04 14:05:00 UTC, 0 replies.
- [PR] [FLINK-37252][doc] Align Chinese document of Postgres CDC Connector with English document. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/04 14:09:51 UTC, 1 replies.
- [jira] [Updated] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/04 14:10:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37222] Do not reuse views across TableEnvironments in SQL client [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/04 15:49:49 UTC, 2 replies.
- [jira] [Created] (FLINK-37253) Display state size in application status and deployment metrics - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/04 15:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37253) Add state size in application status and deployment metrics - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/04 15:56:00 UTC, 2 replies.
- [PR] [FLINK-37253] Add state size in application status and deployment metrics [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2025/02/04 16:04:41 UTC, 11 replies.
- [jira] [Commented] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/04 16:23:00 UTC, 0 replies.
- [PR] Flink 37232 2.0 [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2025/02/04 18:31:38 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/04 18:33:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-35775) README.md changes - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/05 00:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-35139][Connectors/MongoDB] Drop support for Flink 1.18 and update development version to 2.0-SNAPSHOT [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2025/02/05 01:29:55 UTC, 0 replies.
- Re: [PR] [FLINK-37222] Do not reuse views across TableEnvironments in SQL client [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/05 01:30:26 UTC, 2 replies.
- [PR] [FLINK-36061][iceberg] Add Iceberg Sink. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/05 01:40:02 UTC, 1 replies.
- [PR] [hotfix] Correct commit message from FLINK-35139 to FLINK-37197 [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2025/02/05 02:02:30 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37060) Cross-team verification for FLIP-398 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/05 02:10:00 UTC, 1 replies.
- Re: [PR] [BP-2.0][FLINK-37206][Runtime] Fix initialization of batching timer service in async state operators [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/05 02:17:28 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37206) Initialization issue of batching timer service in async state operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 02:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37206) Initialization issue of batching timer service in async state operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 02:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34866) [Bug] Meet NoClassDefFoundError when add new table in mysql cdc source - posted by "Yohei Yoshimuta (Jira)" <ji...@apache.org> on 2025/02/05 02:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37009][table] Migrate PruneAggregateCallRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/02/05 02:27:47 UTC, 0 replies.
- Re: [PR] [FLINK-36992][table] Migrate DecomposeGroupingSetsRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/02/05 02:28:29 UTC, 0 replies.
- Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/02/05 02:28:59 UTC, 1 replies.
- [PR] [hotfix] Set copyright year to 2025 [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2025/02/05 02:49:59 UTC, 1 replies.
- [jira] [Created] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常 - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/05 03:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes - posted by "Yohei Yoshimuta (Jira)" <ji...@apache.org> on 2025/02/05 03:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-37021][state/forst] Fix incorrect paths when reusing files for checkpoints. [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2025/02/05 03:26:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常 - posted by "He Wang (Jira)" <ji...@apache.org> on 2025/02/05 04:05:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2025/02/05 04:09:00 UTC, 3 replies.
- Re: [PR] [FLINK-37233] Update flink cdc document for flink-cdc 3.3 and flink-cdc master [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/02/05 04:25:37 UTC, 1 replies.
- [jira] [Updated] (FLINK-37233) Flink-CDC Documentation change request - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 04:26:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37233) Flink-CDC Documentation change request - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/02/05 05:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37233) Flink-CDC Documentation change request - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/02/05 06:00:00 UTC, 0 replies.
- [PR] [FLINK-37233][docs] Update supported flink versions and sinks (#3899) [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2025/02/05 06:01:32 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37233) Flink-CDC Documentation change request - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/02/05 06:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37233) Flink-CDC Documentation change request - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/02/05 06:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-37212] When hbase region move, throw "Unable to load exception received from server: XXX" [flink-connector-hbase] - posted by "chunji96 (via GitHub)" <gi...@apache.org> on 2025/02/05 06:15:33 UTC, 1 replies.
- Re: [PR] [BP-2.0][FLINK-37232][runtime] Fix for broken synchronization assumption on the AdaptiveScheduler's side introduced by FLIP-272 [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2025/02/05 07:06:03 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/05 07:26:00 UTC, 0 replies.
- [PR] Adding MongoDB Connector v2.0.0 [flink-web] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2025/02/05 07:40:23 UTC, 0 replies.
- Re: [PR] [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly [flink-cdc] - posted by "huyuanfeng2018 (via GitHub)" <gi...@apache.org> on 2025/02/05 07:48:57 UTC, 0 replies.
- [jira] [Created] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/02/05 07:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/02/05 08:03:00 UTC, 2 replies.
- [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] - posted by "qyfftf (via GitHub)" <gi...@apache.org> on 2025/02/05 08:03:50 UTC, 1 replies.
- [jira] [Updated] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 08:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/05 08:12:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/02/05 08:13:00 UTC, 0 replies.
- [PR] [FLINK-37255] Fix unable to configure `SCAN_PARTITION_RECORD_SIZE` option [flink-connector-mongodb] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/05 08:28:04 UTC, 1 replies.
- [PR] [FLINK-37021][state/forst] Fix incorrect paths when reusing and creating files. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/02/05 08:34:37 UTC, 0 replies.
- [jira] [Created] (FLINK-37256) Firing timers can block recovery process - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/05 08:43:00 UTC, 0 replies.
- [PR] [FLINK-37254] Add OceanBaseDefaultValueConverter to fix table schema validation [flink-cdc] - posted by "whhe (via GitHub)" <gi...@apache.org> on 2025/02/05 08:45:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 08:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 08:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-36648] Bump Flink version to Flink 2.0-preview1 [flink-connector-kafka] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/05 08:48:37 UTC, 4 replies.
- Re: [PR] [FLINK-37144] Update version to 4.0-SNAPSHOT. [flink-connector-kafka] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/05 08:51:56 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37021][state/forst] Fix incorrect paths when reusing and creating files. [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/05 08:52:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’ - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/05 08:53:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-37256) Firing timers can block recovery process - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/05 08:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37256) Firing timers can block recovery process - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/05 08:57:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-36929) SQL connector for keyed savepoint data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/05 09:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36929) SQL connector for keyed savepoint data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/05 09:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-37236] Flink 2.0 preview support [flink-kubernetes-operator] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/05 09:31:44 UTC, 2 replies.
- [PR] [FLINK-36439][docs] Documents for Disaggregate State and new State APIs [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/05 09:36:09 UTC, 90 replies.
- [jira] [Updated] (FLINK-36439) Documentation for Disaggregated State Storage and Management - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 09:37:00 UTC, 0 replies.
- [PR] [hotfix][table-planner] Use equals instead of '==' to compare digests in FlinkCalcMergeRule [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/02/05 09:39:31 UTC, 12 replies.
- Re: [PR] [FLINK-37255] Fix unable to configure scan.partition.record-size option [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2025/02/05 09:46:16 UTC, 1 replies.
- Re: [PR] [hotfix] Update copyright NOTICE year to 2025 [flink] - posted by "yangjf2019 (via GitHub)" <gi...@apache.org> on 2025/02/05 09:46:19 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37255] Fix unable to configure scan.partition.record-size option [flink-connector-mongodb] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/05 09:52:44 UTC, 1 replies.
- [PR] [hotfix][Connector/JDBC] Remove unnecessary update fields of PostgreSQL upsert statement [flink-connector-jdbc] - posted by "roseduan (via GitHub)" <gi...@apache.org> on 2025/02/05 09:56:21 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/02/05 11:12:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37255) Unsupported options: scan.partition.record-size - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/02/05 11:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink] - posted by "RanJinh (via GitHub)" <gi...@apache.org> on 2025/02/05 11:13:40 UTC, 0 replies.
- [PR] [FLINK-36660] Bump to 2.0-preview1. [flink-connector-elasticsearch] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/05 11:36:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 11:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 11:39:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37222) Table planner exception when sql client submit job - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 11:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/05 11:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/05 12:02:00 UTC, 1 replies.
- [PR] [FLINK-35687] JSON_QUERY should return a well formatted nested objects/arrays for ARRAY (#24976) [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/05 12:05:55 UTC, 2 replies.
- [jira] [Created] (FLINK-37257) Add an API on keyedStream to allow users to customize the hash method from key to parallelism. - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/02/05 12:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37257) Add an API on keyedStream to allow users to customize the hash method from key to parallelism. - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/02/05 12:14:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37258) Order Flink Job list in Flink UI with start time - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2025/02/05 12:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37236) Make Flink operator compatible with 2.0 preview - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/05 13:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37236) Make Flink operator compatible with 2.0 preview - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/05 13:59:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/05 14:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/05 14:00:00 UTC, 0 replies.
- [PR] [FLINK-37258][Runtime/Dispatcher] Return Ordered Job list on Disptacher#requestMultipleJobDetails [flink] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2025/02/05 15:11:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-37258) Order Flink Job list in Flink UI with start time - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/05 15:12:00 UTC, 3 replies.
- Re: [PR] [FLINK-37258][runtime] Return Ordered Job list on Disptacher#requestMultipleJobDetails [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/05 15:33:06 UTC, 11 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/02/05 15:45:14 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37258) Order Flink Job list in Flink UI with start time - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/05 15:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-37242] Add labels for flink-operator-webhook-service [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/05 16:06:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-37242) Enable setting custom labels for flink-operator-webhook-service - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/05 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37259) StreamCheckpointingITCase times out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/05 16:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/02/05 16:59:44 UTC, 16 replies.
- Re: [PR] [FLINK-37192] [pyflink] Replace deprecated avro-python3 with avro [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/02/06 01:34:23 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37192) [pyflink] Replace deprecated avro-python3 with avro - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/06 01:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37192) [pyflink] Replace deprecated avro-python3 with avro - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/06 01:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37192) Replace deprecated avro-python3 with avro - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/06 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37260) Change MySQL Connector address - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/06 01:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37260) Change MySQL Connector address - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/06 01:44:00 UTC, 1 replies.
- [PR] [hotfix][license] Update legacy license [flink-cdc] - posted by "Shawn-Hx (via GitHub)" <gi...@apache.org> on 2025/02/06 01:49:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’ - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 01:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-37087][doc] Add docs for alter materialized table as query [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/02/06 02:12:43 UTC, 3 replies.
- [jira] [Created] (FLINK-37261) Provide JSON series functions in YAML pipeline - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/02/06 02:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37163] Add documents for recently merged PRs in FlinkCDC 3.3. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/06 02:30:52 UTC, 2 replies.
- [jira] [Resolved] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 02:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37261) Provide JSON series functions in YAML pipeline - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/02/06 02:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 02:38:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 02:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-36997] Add Log4j JSONTemplateLayout to flink-dist [flink] - posted by "ryanvanhuuksloot (via GitHub)" <gi...@apache.org> on 2025/02/06 02:40:31 UTC, 9 replies.
- [jira] [Assigned] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 02:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-37224] Add the missing documents and parameters of MongoDB CDC. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/06 02:46:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 02:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-37231] Add doc for Source metrics. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/06 02:50:21 UTC, 3 replies.
- [jira] [Updated] (FLINK-37231) Add doc for newly added source metric statistics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 02:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-37187][doc] Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/02/06 02:55:16 UTC, 4 replies.
- [jira] [Closed] (FLINK-35495) The native metrics for column family are not reported - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/02/06 03:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 03:15:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37218][network] Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/06 03:23:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-37218) Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/06 03:26:00 UTC, 0 replies.
- Re: [PR] [FLINK-37251][docs] add Download Page in overview.md for Pipeline connectors. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/06 03:30:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-37251) Add download link for pipeline connector. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 03:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37251) Add download link for pipeline connector. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 03:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37251) Add download link for pipeline connector. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 03:32:00 UTC, 0 replies.
- [PR] [hotfix][ci] Use raise to fix uncaught throw [flink-cdc] - posted by "whhe (via GitHub)" <gi...@apache.org> on 2025/02/06 04:39:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/06 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/06 05:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37231) Add doc for newly added source metric statistics - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 06:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37231) Add doc for newly added source metric statistics - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 06:09:00 UTC, 0 replies.
- [PR] [FLINK-37262][connect/mysql] Fix missing `PARSE_ONLINE_SCHEMA_CHANGES` option in the config manifest [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/06 06:12:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 06:13:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory: - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/06 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37263) AggregateITCase.testConstantGroupKeyWithUpsertSink failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/06 06:28:00 UTC, 0 replies.
- [PR] [tests][ci] Miscellaneous improvements on CI robustness [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/06 06:28:53 UTC, 12 replies.
- Re: [PR] [FLINK-37234] Add test timeout to avoid infinite waiting. [flink-connector-jdbc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/06 06:30:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-37234) Add timeout for test case to avoid Infinite waiting - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 06:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37234) Add timeout for test case to avoid Infinite waiting - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 06:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37234) Add timeout for test case to avoid Infinite waiting - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/06 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37264) two bugs of DSv2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/06 06:33:00 UTC, 0 replies.
- [PR] [FLINK-37264] Fix two bugs of DataStream V2 [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/06 07:02:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-37264) two bugs of DSv2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 07:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37205][python] Correct the state cache behavior during bump beam version [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/02/06 07:21:31 UTC, 0 replies.
- Re: [PR] [FLINK-37205][python] Correct the state cache behavior during bump be… [flink] - posted by "dianfu (via GitHub)" <gi...@apache.org> on 2025/02/06 07:23:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-37205) Correct the state cache behavior during bump beam version - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/06 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37265) document of python elasticsearch connector exeample has a mistake - posted by "Zhang Hechuan (Jira)" <ji...@apache.org> on 2025/02/06 07:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37265) document of python elasticsearch connector exeample has a mistake - posted by "Zhang Hechuan (Jira)" <ji...@apache.org> on 2025/02/06 07:38:00 UTC, 6 replies.
- [PR] for test [flink-docker] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/06 07:52:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/06 08:29:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37266) Python CLI arguments doesn't work in session mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/06 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37267) Support WITH ORDINALITY for UNNEST - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/02/06 08:44:00 UTC, 0 replies.
- [PR] [FLINK-37267][table] Add support for UNNEST WITH ORDINALITY [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/02/06 09:13:22 UTC, 38 replies.
- [jira] [Updated] (FLINK-37267) Support WITH ORDINALITY for UNNEST - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 09:14:00 UTC, 2 replies.
- Re: [PR] [hotfix][Connector/JDBC] Remove unnecessary unique fields of PostgreSQL upsert statement [flink-connector-jdbc] - posted by "roseduan (via GitHub)" <gi...@apache.org> on 2025/02/06 10:03:16 UTC, 4 replies.
- Re: [PR] [FLINK-37180][table] Support running stateless PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/02/06 10:08:49 UTC, 7 replies.
- [PR] [FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2025/02/06 11:03:25 UTC, 3 replies.
- [jira] [Closed] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/06 11:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/06 11:12:00 UTC, 2 replies.
- Re: [PR] [BP-2.0][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/06 11:49:48 UTC, 4 replies.
- Re: [PR] [FLINK-36549]Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss [flink] - posted by "xiaoyu19950911 (via GitHub)" <gi...@apache.org> on 2025/02/06 12:02:49 UTC, 3 replies.
- Re: [PR] [BP-1.20][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/06 12:03:13 UTC, 2 replies.
- Re: [PR] [BP-1.19][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/06 12:03:20 UTC, 2 replies.
- [jira] [Created] (FLINK-37268) Add async state word count example - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/02/06 12:21:00 UTC, 0 replies.
- [PR] [FLINK-37268][example] Add async state word count example [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2025/02/06 12:26:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-37268) Add async state word count example - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/06 12:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37267) Support WITH ORDINALITY for UNNEST - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/02/06 12:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-36945] MySQL CDC supports parsing RENAME TABLE Statement with multiple tables [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/06 12:41:33 UTC, 11 replies.
- Re: [PR] [FLINK-37125] [conf] fixed env.log.max java.lang.NumberFormatException [flink] - posted by "sehajsandhu123 (via GitHub)" <gi...@apache.org> on 2025/02/06 13:22:06 UTC, 2 replies.
- [jira] [Updated] (FLINK-36703) FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/06 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37269) Add new DESCRIPTOR data type - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/06 14:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "sehaj pal singh sandhu (Jira)" <ji...@apache.org> on 2025/02/06 15:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37180) Implement StreamOperator for PTF - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/06 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37270) Flink Support to SSL enabled MongoDb/DocumentDB source connector - posted by "vijaya lakshmi chanumolu (Jira)" <ji...@apache.org> on 2025/02/06 19:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33051) Unify the GlobalFailureHandler and LabeledGlobalFailureHandler interface - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2025/02/06 19:19:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31508) FLIP-304: Pluggable failure handling for Apache Flink - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2025/02/06 19:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "Tommy Schnabel (Jira)" <ji...@apache.org> on 2025/02/06 20:45:00 UTC, 5 replies.
- [jira] [Created] (FLINK-37271) Add network channel reconnect capability - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/06 22:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37271) Add network channel reconnect capability - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/06 23:09:00 UTC, 0 replies.
- Re: [PR] [FLINK-37264][datastream] Fix bugs of DataStream V2 [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/07 01:59:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-37264) two bugs of DSv2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 02:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37264) two bugs of DSv2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 02:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37264) two bugs of DSv2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 02:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37154) Support reading binary data from Kafka in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/07 02:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 02:12:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner - posted by "tartarus (Jira)" <ji...@apache.org> on 2025/02/07 03:09:00 UTC, 0 replies.
- Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/02/07 03:32:06 UTC, 3 replies.
- Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/02/07 03:47:13 UTC, 12 replies.
- [jira] [Updated] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/07 03:56:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/07 03:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-37268][example] Use async state in flink-examples-streaming [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2025/02/07 03:59:52 UTC, 4 replies.
- [jira] [Created] (FLINK-37273) Dynamodb Streams getRecords call adaptive delay - posted by "Pranav Wadekar (Jira)" <ji...@apache.org> on 2025/02/07 05:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37212) When hbase region move, throw "Unable to load exception received from server: XXX" - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/07 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37274) Add examples for datastream api v2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/07 06:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37113) Introduce documentation for datastream api v2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 06:10:00 UTC, 0 replies.
- [PR] [FLINK-37274] Add examples for DataStream V2 [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/07 06:14:21 UTC, 15 replies.
- [jira] [Updated] (FLINK-37274) Add examples for datastream api v2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/07 06:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-37194][tests] Fix NPE issue in WatermarkITCase [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/07 06:18:32 UTC, 2 replies.
- Re: [PR] [docs] Translate "Table ID" Page for Flink CDC Chinese Documentation [flink-cdc] - posted by "Kevin-Caesar (via GitHub)" <gi...@apache.org> on 2025/02/07 06:33:29 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37274) Add examples for datastream api v2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/07 06:53:00 UTC, 0 replies.
- [PR] [FLINK-36336] Remove deprecated DataSet API related contents in documentations [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/07 07:20:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/07 07:24:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36167) testSinkDisorderChangeLog failed on AZP - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/07 07:25:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37275) MySQL source connector supports using the base module's source metric statistics - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/02/07 07:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37047) Cross-team verification for "Remove DataSet API" - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/07 07:41:00 UTC, 1 replies.
- Re: [PR] [FLINK-36336][doc] Remove deprecated DataSet API related contents in documentations [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/07 07:59:40 UTC, 6 replies.
- [jira] [Created] (FLINK-37276) Missing interfaces in `RuntimeContext` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/07 08:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37276) Missing state v2 access interfaces in `RuntimeContext` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/07 08:30:00 UTC, 1 replies.
- Re: [PR] [FLINK-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. [flink] - posted by "xing1mo (via GitHub)" <gi...@apache.org> on 2025/02/07 09:03:10 UTC, 1 replies.
- Re: [PR] [FLINK-37035][release] Update dev-master point to 2.1 [flink-docker] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/07 09:03:40 UTC, 2 replies.
- Re: [PR] [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark. [flink] - posted by "xing1mo (via GitHub)" <gi...@apache.org> on 2025/02/07 09:03:55 UTC, 3 replies.
- [jira] [Updated] (FLINK-37265) Document of python elasticsearch connector exeample has a mistake - posted by "Zhang Hechuan (Jira)" <ji...@apache.org> on 2025/02/07 09:21:00 UTC, 0 replies.
- [PR] [FLINK-37276] Add missing state v2 access interfaces in `RuntimeContext` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/07 09:24:06 UTC, 15 replies.
- [jira] [Commented] (FLINK-37265) Document of python elasticsearch connector exeample has a mistake - posted by "Zhang Hechuan (Jira)" <ji...@apache.org> on 2025/02/07 09:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-36998][table-planner] Keep same behavior about the RowKind of data in globalUpsertResult for KeyedUpsertingSinkFunction while being inserted or being restored [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/02/07 09:28:31 UTC, 3 replies.
- [jira] [Updated] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/07 09:29:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/07 09:35:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37253) Add state size in application status and deployment metrics - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/07 09:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34227) Job doesn't disconnect from ResourceManager - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/07 10:43:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34227) Job doesn't disconnect from ResourceManager - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/07 10:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-36352][doc] Remove Scala DataStream API related doc [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2025/02/07 11:38:33 UTC, 3 replies.
- [jira] [Updated] (FLINK-34227) Job doesn't disconnect from ResourceManager - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/07 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/07 12:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/07 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/07 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37279) Add Flink CDC Pipeline Clickhouse connector - posted by "qinghuan wang (Jira)" <ji...@apache.org> on 2025/02/07 13:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-21584) Support UNNEST in LEFT JOINs - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/02/07 14:31:00 UTC, 1 replies.
- Re: [PR] [FLINK-37225] Remove remaining test resources of Gelly [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/02/07 16:19:17 UTC, 3 replies.
- [jira] [Created] (FLINK-37280) Inconsistent content of TableConfig in planner when mini batch is enabled - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/07 16:47:00 UTC, 0 replies.
- [PR] [FLINK-21912] Introduce ResolvedSchema in Python Table API [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/07 16:54:30 UTC, 1 replies.
- [jira] [Updated] (FLINK-21912) Introduce Schema and ResolvedSchema in Python API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/07 16:55:00 UTC, 0 replies.
- [PR] Main thread callback async wait op [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/02/07 17:40:49 UTC, 1 replies.
- [jira] [Created] (FLINK-37281) Refactor KafkaSinkITCase - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/07 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37282) Add backchannel for producer recycling - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/07 21:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] - posted by "JoeryH (via GitHub)" <gi...@apache.org> on 2025/02/07 23:04:20 UTC, 0 replies.
- Re: [PR] FLINK-25029: Hadoop Caller Context Setting in Flink [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2025/02/07 23:25:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/07 23:29:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/08 01:56:00 UTC, 0 replies.
- [PR] [hotfix] Remove inappropriate annotation in `flink-statebackend-forst` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/08 02:33:54 UTC, 3 replies.
- [jira] [Created] (FLINK-37283) Improved ability to split ‘db./.*./.*.’ - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/02/08 02:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37283) Improved ability to split ‘db.\.*.\.*.’ - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/02/08 03:00:00 UTC, 1 replies.
- [PR] [BP-2.0][hotfix] Remove inappropriate annotation in `flink-statebackend-forst` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/08 03:06:29 UTC, 2 replies.
- [PR] [hotfix][state/rocksdb] Use try-with-resources to close RocksStateKeysIterator and fix some typos. [flink] - posted by "littleeleventhwolf (via GitHub)" <gi...@apache.org> on 2025/02/08 03:19:27 UTC, 8 replies.
- [PR] [FLINK-37278] Optimize regular schema evolution topology's performance [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/08 03:44:59 UTC, 5 replies.
- [jira] [Updated] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/08 03:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37283) Improved ability to split ‘db.\.*.\.*.’ - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/08 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/08 05:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/02/08 06:03:10 UTC, 6 replies.
- Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/02/08 06:05:02 UTC, 1 replies.
- [jira] [Created] (FLINK-37285) Adapt DataSinkTranslator to support new Sink API of FLIP-372 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/08 06:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37285) Adapt DataSinkTranslator to support new Sink API of FLIP-372 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/08 06:43:00 UTC, 0 replies.
- [PR] [FLINK-37284][runtime] Fix ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/08 07:29:52 UTC, 3 replies.
- [jira] [Updated] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/08 07:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/08 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37286) Introduce ClickHouseDialect And ClickHouseCatalog - posted by "Chaojian Fu (Jira)" <ji...@apache.org> on 2025/02/08 10:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37286) Introduce ClickHouseDialect And ClickHouseCatalog - posted by "Chaojian Fu (Jira)" <ji...@apache.org> on 2025/02/08 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/08 14:54:00 UTC, 0 replies.
- [PR] [FLINK-37287][docs] Adding Apache Paimon 0.9 [flink-cdc] - posted by "911432 (via GitHub)" <gi...@apache.org> on 2025/02/08 15:21:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/08 15:22:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/08 15:22:00 UTC, 6 replies.
- [jira] [Resolved] (FLINK-37108) Source/Sink test suites test invalid recovery - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/08 16:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37108) Source/Sink test suites test invalid recovery - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/08 16:25:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24252) HybridSource should return TypeInformation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/08 16:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/08 16:28:00 UTC, 4 replies.
- [PR] [FLINK-37281] Improve sink tests [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/02/08 17:53:30 UTC, 4 replies.
- [jira] [Updated] (FLINK-37281) Refactor KafkaSinkITCase - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/08 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37288) Add Google Cloud Spanner dialect and catalog - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2025/02/09 06:44:00 UTC, 0 replies.
- [PR] [FLINK-37288] Add flink-connector-jdbc-spnner [flink-connector-jdbc] - posted by "laughingman7743 (via GitHub)" <gi...@apache.org> on 2025/02/09 06:44:47 UTC, 1 replies.
- [jira] [Updated] (FLINK-37288) Add Google Cloud Spanner dialect and catalog - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/09 06:45:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37288) Add Google Cloud Spanner dialect and catalog - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2025/02/09 06:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] - posted by "laughingman7743 (via GitHub)" <gi...@apache.org> on 2025/02/09 06:48:49 UTC, 4 replies.
- [jira] [Created] (FLINK-37289) Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2025/02/09 07:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37289) Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2025/02/09 07:57:00 UTC, 1 replies.
- [PR] [FLINK-37289][table] Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job [flink] - posted by "littleeleventhwolf (via GitHub)" <gi...@apache.org> on 2025/02/09 11:58:04 UTC, 4 replies.
- [PR] [FLINK-37109][State Processor API] Improve state processor API performance when reading keyed rocksdb state by allowing duplicates [flink] - posted by "lamgary (via GitHub)" <gi...@apache.org> on 2025/02/09 19:51:41 UTC, 7 replies.
- [jira] [Updated] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/09 19:52:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates - posted by "Gary Lam (Jira)" <ji...@apache.org> on 2025/02/09 20:22:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37087) Add docs for alter materialized table as query - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/10 01:54:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37087][doc] Add docs for alter materialized table as query [flink] - posted by "hackergin (via GitHub)" <gi...@apache.org> on 2025/02/10 02:22:34 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/10 02:36:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37276] Add missing state v2 access interfaces in `RuntimeContext` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/10 03:07:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-37276) Missing state v2 access interfaces in `RuntimeContext` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/10 03:10:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37276) Missing state v2 access interfaces in `RuntimeContext` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/10 03:10:00 UTC, 0 replies.
- Re: [PR] [hotfix][configuration] Remove the deprecated test class TaskManagerLoadBalanceModeTest. [flink] - posted by "GOODBOY008 (via GitHub)" <gi...@apache.org> on 2025/02/10 03:36:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/10 03:51:00 UTC, 1 replies.
- Re: [PR] [FLINK-35599][cdc-connector][jdbc-mysql]Flink cdc pipeline sink jdbc mysql [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/10 05:08:38 UTC, 0 replies.
- [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/02/10 07:08:44 UTC, 5 replies.
- [jira] [Updated] (FLINK-37275) MySQL source connector supports using the base module's source metric statistics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/10 07:09:00 UTC, 0 replies.
- [PR] [FLINK-37265][docs] Document of python elasticsearch connector exeample has a little mistake [flink-connector-elasticsearch] - posted by "Milesian111 (via GitHub)" <gi...@apache.org> on 2025/02/10 07:29:54 UTC, 1 replies.
- [jira] [Created] (FLINK-37290) Introduce endPartition to DataStream V2 ProcessFunction - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/10 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37291) Weekly Kafka CI detects producer leaks - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/02/10 07:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37291) Weekly Kafka CI detects producer leaks - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/02/10 07:41:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Yutong Han (Jira)" <ji...@apache.org> on 2025/02/10 07:42:00 UTC, 9 replies.
- [jira] [Assigned] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/10 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/02/10 09:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/10 09:24:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37284][runtime] Fix ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/10 09:24:46 UTC, 3 replies.
- [jira] [Updated] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/02/10 09:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-21912][pyflink] Introduce ResolvedSchema in Python Table API [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/10 09:36:05 UTC, 15 replies.
- [jira] [Created] (FLINK-37293) Length of Binary type is missing in OceanBase pipeline connector - posted by "He Wang (Jira)" <ji...@apache.org> on 2025/02/10 09:43:00 UTC, 0 replies.
- [PR] [FLINK-37293] Fix BinaryType converting in OceanBase pipeline and refactoring test cases [flink-cdc] - posted by "whhe (via GitHub)" <gi...@apache.org> on 2025/02/10 09:46:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-37293) Length of Binary type is missing in OceanBase pipeline connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/10 09:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-34558][state] Support tracking state size [flink] - posted by "hejufang (via GitHub)" <gi...@apache.org> on 2025/02/10 09:51:27 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37258) Order Flink Job list in Flink UI with start time - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/10 09:56:00 UTC, 0 replies.
- [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/10 10:06:53 UTC, 2 replies.
- [jira] [Assigned] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/10 10:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-25029) Hadoop Caller Context Setting In Flink - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/10 10:35:00 UTC, 1 replies.
- Re: [PR] [FLINK-35780] Support state migration between disabling and enabling State TTL in RocksDBKeyedStateBackend [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/10 10:43:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/10 10:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/10 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/02/10 10:56:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-36439][docs] Documents for Disaggregate State and new State APIs [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/10 10:57:36 UTC, 2 replies.
- [jira] [Created] (FLINK-37295) Update state ttl migration compatibility in docs - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/02/10 10:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment - posted by "Alberto Lago (Jira)" <ji...@apache.org> on 2025/02/10 11:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup [flink-connector-kafka] - posted by "trompa (via GitHub)" <gi...@apache.org> on 2025/02/10 11:35:43 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/10 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/10 11:50:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/10 11:50:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/10 11:51:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/02/10 11:54:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/02/10 11:55:00 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-37087) Add docs for alter materialized table as query - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/10 12:05:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37087) Add docs for alter materialized table as query - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/10 12:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-36682][mysql][mongodb] Add scan.chunk.assign.strategy to avoid OOM exception. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/10 12:24:08 UTC, 2 replies.
- [PR] [FLINK-37219][table] Support value state in PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/02/10 12:35:57 UTC, 6 replies.
- [jira] [Updated] (FLINK-37219) Support value state in PTFs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/10 12:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-37201] [cdc] [transform] FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/10 12:57:40 UTC, 5 replies.
- Re: [PR] [FLINK-37287][docs] Adding Apache Paimon 0.9 and Fixing typo on overview.md [flink-cdc] - posted by "911432 (via GitHub)" <gi...@apache.org> on 2025/02/10 13:20:18 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/10 14:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/10 14:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-35937] RBAC cleanup [flink-kubernetes-operator] - posted by "timsn (via GitHub)" <gi...@apache.org> on 2025/02/10 14:38:00 UTC, 1 replies.
- [PR] [FLINK-37109][state] Improve state processor API key iteration speed [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/10 15:05:16 UTC, 26 replies.
- [jira] [Created] (FLINK-37296) Add ability to add File Level Header in the File Sink forRowFormat - posted by "kyle n (Jira)" <ji...@apache.org> on 2025/02/10 15:19:00 UTC, 0 replies.
- [PR] [FLINK-37282] Add Backchannel and ProducerPool [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/02/10 16:00:08 UTC, 19 replies.
- [jira] [Updated] (FLINK-37282) Add backchannel for producer recycling - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/10 16:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37297) Either type Pojo deserialization fails with NPE - posted by "Daniel Lopes (Jira)" <ji...@apache.org> on 2025/02/10 16:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35937) Helm RBAC cleanup - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/10 16:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "sehaj pal singh sandhu (Jira)" <ji...@apache.org> on 2025/02/10 18:17:00 UTC, 1 replies.
- [PR] [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml [flink-connector-hive] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/10 20:42:50 UTC, 1 replies.
- [PR] [hotfix] Integrate hive connector docs [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/10 22:01:08 UTC, 4 replies.
- Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/02/10 23:06:59 UTC, 17 replies.
- [jira] [Closed] (FLINK-37074) Cross-team verification for FLINK-31362 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/10 23:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37075) Cross-team verification for FLINK-31836 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/10 23:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/11 01:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37054) Cross-team verification for FLINK-33750 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/02/11 01:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values" - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/02/11 01:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/02/11 01:25:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/02/11 01:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/02/11 01:26:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37058) Cross-team verification for FLINK-35573 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 01:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37058) Cross-team verification for FLINK-35573 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 01:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 01:27:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/11 02:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:08:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:08:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:08:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37056) Cross-team verification for FLINK-23620 - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:10:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 02:13:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37268][example] Use async state in flink-examples-streaming [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2025/02/11 02:13:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37268) Add async state word count example - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/02/11 02:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37268) Add async state word count example - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/02/11 02:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37268) Add async state word count example - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/02/11 02:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 03:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37120) MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager OOM - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 03:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 03:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/11 03:56:00 UTC, 0 replies.
- [PR] [FLINK-37187][doc] Add doc for submitting Materialized Table refresh job to Yarn/K8s [flink] - posted by "hackergin (via GitHub)" <gi...@apache.org> on 2025/02/11 03:56:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/11 04:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/02/11 04:04:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37187][doc] Add doc for submitting Materialized Table refresh job to Yarn/K8s [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/11 04:29:20 UTC, 1 replies.
- Re: [PR] [FLINK-36976] Upgrade jackson from 2.15.3 to 2.18.2 [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/11 05:46:31 UTC, 0 replies.
- [jira] [Created] (FLINK-37298) Custom Batch Handling in AsyncSink - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/02/11 05:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37298) Custom Batch Handling in AsyncSink - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/02/11 05:47:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36976) Bump jackson to 2.18.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/11 05:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36976) Bump jackson to 2.18.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/11 05:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36976) Bump jackson to 2.18.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/11 05:48:00 UTC, 1 replies.
- [PR] [BP-1.20][FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink] - posted by "jiefei30 (via GitHub)" <gi...@apache.org> on 2025/02/11 06:40:20 UTC, 3 replies.
- [PR] [BP-2.0][FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink] - posted by "jiefei30 (via GitHub)" <gi...@apache.org> on 2025/02/11 06:44:39 UTC, 4 replies.
- [jira] [Resolved] (FLINK-36439) Documentation for Disaggregated State Storage and Management - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 06:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36439) Documentation for Disaggregated State Storage and Management - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 06:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/11 07:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/02/11 07:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc] - posted by "wangqinghuan (via GitHub)" <gi...@apache.org> on 2025/02/11 07:35:25 UTC, 3 replies.
- [jira] [Updated] (FLINK-37200) Add e2e test for ElasticSearch Sink. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/11 07:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/11 07:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/11 07:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/11 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37299) flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Quan Limin (Jira)" <ji...@apache.org> on 2025/02/11 07:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37299) flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Quan Limin (Jira)" <ji...@apache.org> on 2025/02/11 07:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37299) Flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Quan Limin (Jira)" <ji...@apache.org> on 2025/02/11 07:58:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37281) Refactor KafkaSinkITCase - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/11 07:58:00 UTC, 0 replies.
- [PR] [FLINK-37299][Connector/Pulsar] Flink stateless startup cannot contin… [flink-connector-pulsar] - posted by "yebai1105 (via GitHub)" <gi...@apache.org> on 2025/02/11 08:14:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-37299) Flink stateless startup cannot continue consuming from the current location of the consumer group - posted by "Quan Limin (Jira)" <ji...@apache.org> on 2025/02/11 08:29:00 UTC, 0 replies.
- [PR] [FLINK-37150][doc] Update flink configuration file documentation. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/11 09:22:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-37150) Adjust the documentation of the configuration file to remove the support for the old configuration file. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/11 09:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37271) Add network channel reconnect capability - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/11 09:34:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/11 10:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/11 10:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/11 10:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly - posted by "He Wang (Jira)" <ji...@apache.org> on 2025/02/11 10:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37298) Custom Batch Handling in AsyncSink - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2025/02/11 10:24:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-35508) Use OceanBase LTS version Docker image in testing - posted by "He Wang (Jira)" <ji...@apache.org> on 2025/02/11 10:27:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19 - posted by "Simon Frei (Jira)" <ji...@apache.org> on 2025/02/11 10:33:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37053) Cross-team verification for FLINK-14068 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/11 10:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37061) Cross-team verification for FLINK-32688 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/11 10:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37070) Cross-team verification for FLIP-461 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/11 10:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37072) Cross-team verification for FLIP-472 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/02/11 10:43:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37150][doc] Update flink configuration file documentation. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/11 11:21:06 UTC, 2 replies.
- Re: [PR] [FLINK-37162] Add sinks.md to describe Flink's Data Sink API. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/11 11:30:49 UTC, 2 replies.
- [PR] [FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/02/11 11:54:33 UTC, 3 replies.
- [jira] [Created] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/11 12:09:00 UTC, 0 replies.
- Re: [PR] [FLINK-37119] Bump the version of Paimon flink to 1.0.0. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/11 12:15:21 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs. [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/11 12:26:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36564) Running CI in random timezone to expose more time related bugs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36564) Running CI in random timezone to expose more time related bugs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:28:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-36564) Running CI in random timezone to expose more time related bugs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36564) Running CI in random timezone to expose more time related bugs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:28:00 UTC, 0 replies.
- [PR] [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/11 12:30:34 UTC, 2 replies.
- [jira] [Updated] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:31:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/11 12:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/11 12:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS - posted by "Boris Litvak (Jira)" <ji...@apache.org> on 2025/02/11 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37302) Support timers in PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/11 14:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37150) Adjust the documentation of the configuration file to remove the support for the old configuration file. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/11 14:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37219) Support value state in PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/11 15:08:00 UTC, 0 replies.
- [PR] [FLINK-37269][table] Add new DESCRIPTOR type [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/02/11 15:36:01 UTC, 8 replies.
- [jira] [Updated] (FLINK-37269) Add new DESCRIPTOR data type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/11 15:37:00 UTC, 0 replies.
- Re: [PR] Add Flink 1.19.2 release [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/02/11 15:52:40 UTC, 4 replies.
- Re: [PR] [FLINK-36900][python] Migrate from conda to uv for managing Python environments for PyFlink [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/02/11 16:27:27 UTC, 1 replies.
- [jira] [Created] (FLINK-37303) Bump guava to 33.4.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/11 21:32:00 UTC, 0 replies.
- [PR] [FLINK-37303] Bump guava from 32.1.3 to 33.4.0 [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/11 21:33:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-37303) Bump guava to 33.4.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/11 21:34:00 UTC, 1 replies.
- [PR] Lc.finished state batch issue 1.10 [flink-kubernetes-operator] - posted by "luca-p-castelli (via GitHub)" <gi...@apache.org> on 2025/02/12 00:58:21 UTC, 1 replies.
- [PR] [hotfix][tests] Fix MySQLSourceITCase failure in non-UTC timezone [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/12 01:46:02 UTC, 2 replies.
- Re: [PR] [MINOR] Rename PunctuatedWatermarkStrategyWrapper with PunctuatedWatermarkAssignerWrapper [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/02/12 01:55:02 UTC, 1 replies.
- [PR] [BP-2.0][FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/12 02:29:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-35134) Release flink-connector-elasticsearch v3.2.0 for Flink 1.19 and Flink 1.20 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/12 02:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/12 02:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/12 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 02:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 02:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/12 02:52:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 03:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 03:04:00 UTC, 0 replies.
- [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/02/12 03:04:04 UTC, 5 replies.
- [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/12 03:05:00 UTC, 0 replies.
- [PR] [hotfix][state/forst] Make file cache options recognize size type [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/12 03:15:22 UTC, 2 replies.
- [jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 03:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37306) Flink CDC CI failed due to timezone shift - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 03:21:00 UTC, 0 replies.
- Re: [PR] [BP-2.0][FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/12 03:27:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/02/12 03:36:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/02/12 03:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37305) JDBC Connector CI failed due to network issue - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/12 03:41:00 UTC, 0 replies.
- Re: [PR] [MINOR] Deprecated StreamSink and SinkOperator [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/02/12 03:57:59 UTC, 2 replies.
- [jira] [Commented] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/02/12 04:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37305) JDBC Connector CI failed due to network issue - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 06:19:00 UTC, 0 replies.
- [PR] [hotfix] Make tests passing for jdk 17+ [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/12 06:35:37 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36167) testSinkDisorderChangeLog failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/12 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2025/02/12 06:51:00 UTC, 0 replies.
- Re: [PR] [hotfix] Make nightly tests passing for jdk 17+ [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/12 07:04:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/02/12 07:48:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/02/12 07:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unncessary information in plaintext under INFO - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 08:39:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unnecessary information in plaintext under INFO - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/12 08:39:00 UTC, 1 replies.
- [PR] [hotfix][table-planner] Skewed join optimization not working as expected [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/12 09:02:14 UTC, 0 replies.
- [PR] CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP fix [flink-connector-cassandra] - posted by "maciejbak85 (via GitHub)" <gi...@apache.org> on 2025/02/12 09:12:08 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/12 09:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/12 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37309) Skewed join optimization not working as expected - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/12 09:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37309) Skewed join optimization not working as expected - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/12 09:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-37309][table-planner] Fix skewed join optimization not working as expected [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/12 09:28:15 UTC, 5 replies.
- [jira] [Updated] (FLINK-37309) Skewed join optimization not working as expected - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/12 09:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37271) Add network channel reconnect capability - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/12 09:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/12 09:34:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37303) Bump guava to 33.4.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/12 09:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37303) Bump guava to 33.4.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/12 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37310) SQL connector for keyed savepoint data documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 12:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37310) SQL connector for keyed savepoint data documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 12:48:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 13:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 13:55:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version - posted by "Nick Nezis (Jira)" <ji...@apache.org> on 2025/02/12 14:12:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version - posted by "Nick Nezis (Jira)" <ji...@apache.org> on 2025/02/12 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37312) Missing closing tab in state_v2.md - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 14:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37312) Missing closing tab in state_v2.md - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 14:16:00 UTC, 0 replies.
- [PR] [FLINK-37312][doc] Add missing closing tab in state_v2.md [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/12 14:23:29 UTC, 5 replies.
- [jira] [Updated] (FLINK-37312) Missing closing tab in state_v2.md - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/12 14:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 15:37:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37312) Missing closing tab in state_v2.md - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 15:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37312) Missing closing tab in state_v2.md - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/12 15:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Mingcan Wang (Jira)" <ji...@apache.org> on 2025/02/13 03:04:00 UTC, 6 replies.
- [PR] [BP-2.0][hotfix][state/forst] Make file cache options recognize size type [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/13 03:06:53 UTC, 2 replies.
- [jira] [Updated] (FLINK-35134) Release flink-connector-elasticsearch v3.1.0 for Flink 1.19 and Flink 1.20 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/13 03:34:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37309][table-planner] Fix skewed join optimization not working as expected [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/13 03:35:29 UTC, 3 replies.
- [jira] [Created] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/13 04:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/13 04:22:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/13 04:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/13 06:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-35360] support Flink cdc pipeline Yarn application mode [flink-cdc] - posted by "joyCurry30 (via GitHub)" <gi...@apache.org> on 2025/02/13 06:02:50 UTC, 4 replies.
- Re: [PR] Fix docker compose configuration [flink-playgrounds] - posted by "LebranceBW (via GitHub)" <gi...@apache.org> on 2025/02/13 06:27:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/13 06:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37052) Cross-team verification for FLINK-36245 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/13 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37314) The watermark and lateness document has an error which may mislead users - posted by "Liu (Jira)" <ji...@apache.org> on 2025/02/13 07:14: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/02/13 07:15:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/13 07:29:00 UTC, 3 replies.
- [PR] Just for testing. [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/13 07:31:16 UTC, 2 replies.
- [jira] [Created] (FLINK-37315) Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2025/02/13 07:42:00 UTC, 0 replies.
- [PR] [FLINK-37314][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2025/02/13 07:56:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-37314) The watermark and lateness document has an error which may mislead users - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/13 07:57:00 UTC, 0 replies.
- [PR] add our own metric for flink-connect-aws connector [flink-connector-aws] - posted by "Sunninsky (via GitHub)" <gi...@apache.org> on 2025/02/13 08:13:16 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37309) Skewed join optimization not working as expected - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/13 08:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37309) Skewed join optimization not working as expected - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/13 08:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37309) Skewed join optimization not working as expected - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/13 08:36:00 UTC, 0 replies.
- [PR] [FLINK-37310][doc] SQL connector for keyed savepoint data documentation [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/13 09:09:31 UTC, 52 replies.
- [jira] [Created] (FLINK-37316) Add StateManager#getStateOptional and StateManager#getState methods for DataStream V2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/13 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running - posted by "Jufang He (Jira)" <ji...@apache.org> on 2025/02/13 09:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running - posted by "Jufang He (Jira)" <ji...@apache.org> on 2025/02/13 09:31:00 UTC, 3 replies.
- [PR] [FLINK-37236] Bump the flink version from 1.20.0 to 1.20.1 [flink-kubernetes-operator] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/02/13 09:46:59 UTC, 4 replies.
- [jira] [Created] (FLINK-37318) RocksDBKeyedStateBackend disposed before task exit - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2025/02/13 10:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2025/02/13 10:06:21 UTC, 5 replies.
- [jira] [Updated] (FLINK-37315) Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/13 10:07:00 UTC, 0 replies.
- [PR] [FLINK-37313] Fix the problem of reading binlog before the high and low watermarks during the snapshot process [flink-cdc] - posted by "gongzexin (via GitHub)" <gi...@apache.org> on 2025/02/13 10:24:29 UTC, 3 replies.
- [jira] [Updated] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/13 10:25:00 UTC, 0 replies.
- [PR] Add GPG key for 1.19.2 release [flink-docker] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/13 10:39:16 UTC, 1 replies.
- [PR] Update Dockerfiles for 1.19.2 release [flink-docker] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/13 10:57:10 UTC, 1 replies.
- Re: [PR] [BP-1.20][FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase. [flink] - posted by "dmvk (via GitHub)" <gi...@apache.org> on 2025/02/13 10:58:15 UTC, 1 replies.
- Re: [PR] [FLINK-36581][FLINK-35360] support Flink cdc pipeline Yarn application mode [flink-cdc] - posted by "joyCurry30 (via GitHub)" <gi...@apache.org> on 2025/02/13 11:18:20 UTC, 0 replies.
- Re: [PR] [FLINK-36086] [Sqlserver] Fix Sqlserver restart during one transaction [flink-cdc] - posted by "GOODBOY008 (via GitHub)" <gi...@apache.org> on 2025/02/13 11:21:59 UTC, 6 replies.
- Re: [PR] [FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase. [flink] - posted by "dmvk (via GitHub)" <gi...@apache.org> on 2025/02/13 11:28:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/02/13 11:30:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase. [flink] - posted by "dmvk (via GitHub)" <gi...@apache.org> on 2025/02/13 11:40:23 UTC, 2 replies.
- [PR] Update Dockerfiles for 1.20.1 release [flink-docker] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/13 12:15:44 UTC, 1 replies.
- [PR] Add GPG key for 1.20.1 release [flink-docker] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/13 12:22:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/13 12:42:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/02/13 13:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/02/13 13:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists - posted by "Anton Solovev (Jira)" <ji...@apache.org> on 2025/02/13 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/13 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37320) FINISHED jobs incorrectly being set to RECONCILING - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/13 19:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37320) FINISHED jobs incorrectly being set to RECONCILING - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/13 19:44:00 UTC, 24 replies.
- [jira] [Created] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/13 20:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/13 20:37:00 UTC, 2 replies.
- [PR] [FLINK37321][table] Make window functions with descriptors fail during planning rather than runtime [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/13 20:45:54 UTC, 0 replies.
- Re: [PR] [FLINK-37321][table] Make window functions with wrong descriptors fail during planning rather than runtime [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/13 20:55:07 UTC, 11 replies.
- [jira] [Commented] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/13 22:43:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/13 22:44:00 UTC, 1 replies.
- [PR] Align entrypoint with what was used for 1.19.1 [flink-docker] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/13 23:24:15 UTC, 3 replies.
- [jira] [Created] (FLINK-37322) surport eval groovy scripts udf for flink sql - posted by "tianyuan (Jira)" <ji...@apache.org> on 2025/02/14 02:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36936) Introduce UpdatableTopNFunction in Rank with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2025/02/14 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37323) Checkpoint Growth & Akka FrameSize Exception when Migrating from FlinkKafkaProducer to KafkaSink - posted by "Zimehr Abbasi (Jira)" <ji...@apache.org> on 2025/02/14 03:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37323) Checkpoint Growth & Akka FrameSize Exception when Migrating from FlinkKafkaProducer to KafkaSink - posted by "Zimehr Abbasi (Jira)" <ji...@apache.org> on 2025/02/14 03:16:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running - posted by "Jufang He (Jira)" <ji...@apache.org> on 2025/02/14 03:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/14 08:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/14 08:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36795) postgres cdc supports pipeline configuration connector - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/02/14 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37324) RocksDB keys iterator performance improvement - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 08:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37325) SQL connector for keyed savepoint data Chinese documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 09:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/02/14 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37326) The transform module reports an error when column is a Java keyword - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/14 10:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37326) The transform module reports an error when column is a Java keyword - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/14 10:28:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37326) The transform module reports an error when column is a Java keyword - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/14 10:28:00 UTC, 0 replies.
- Re: [PR] [hotfix] Bump io.netty:netty-common from 4.1.17.Final to 4.1.115.Final [flink-connector-hive] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/02/14 15:07:11 UTC, 0 replies.
- [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/02/14 15:07:24 UTC, 6 replies.
- Re: [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.115.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/02/14 15:07:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 15:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 15:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37310) SQL connector for keyed savepoint data documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 15:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37310) SQL connector for keyed savepoint data documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/14 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows - posted by "Kevin Lam (Jira)" <ji...@apache.org> on 2025/02/14 20:12:00 UTC, 0 replies.
- [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] - posted by "klam-shop (via GitHub)" <gi...@apache.org> on 2025/02/14 20:43:24 UTC, 4 replies.
- [jira] [Updated] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/14 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37328) Upgrade GCS Connector to 2.2.26. - posted by "Chris Nauroth (Jira)" <ji...@apache.org> on 2025/02/15 00:15:00 UTC, 0 replies.
- [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] - posted by "cnauroth (via GitHub)" <gi...@apache.org> on 2025/02/15 00:22:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-37328) Upgrade GCS Connector to 2.2.26. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/15 00:23:00 UTC, 0 replies.
- [PR] [FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readTextFile method in documentation [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/15 07:36:28 UTC, 2 replies.
- [jira] [Updated] (FLINK-37329) Skip Source Stats Collection When "table.optimizer.source.report-statistics-enabled" is False - posted by "Syed Shameerur Rahman (Jira)" <ji...@apache.org> on 2025/02/15 08:23:00 UTC, 6 replies.
- [jira] [Created] (FLINK-37329) Skip Source Stats Collection When "table.optimizer.source.report-statistics-enabled - posted by "Syed Shameerur Rahman (Jira)" <ji...@apache.org> on 2025/02/15 08:23:00 UTC, 0 replies.
- [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] - posted by "shameersss1 (via GitHub)" <gi...@apache.org> on 2025/02/15 08:36:54 UTC, 11 replies.
- [jira] [Updated] (FLINK-37329) Skip Source Stats Collection When "table.optimizer.source.report-statistics-enabled" is false - posted by "Syed Shameerur Rahman (Jira)" <ji...@apache.org> on 2025/02/15 08:39:00 UTC, 2 replies.
- Re: [PR] [FLINK-36832] Remove Deprecated classes and relevant tests. [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/02/15 08:59:32 UTC, 5 replies.
- [jira] [Created] (FLINK-37330) Add state migration test for Flink 2.0 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/15 09:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37330) Add state migration test for Flink 2.0 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/15 09:02:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation - posted by "ronghangye (Jira)" <ji...@apache.org> on 2025/02/15 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation - posted by "ronghangye (Jira)" <ji...@apache.org> on 2025/02/15 11:48:00 UTC, 0 replies.
- [PR] [FLINK-37331][tests] Add comprehensive data type coverage tests for new MysqlSource implementation [flink-cdc] - posted by "ranko-aha (via GitHub)" <gi...@apache.org> on 2025/02/15 11:52:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/15 11:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] - posted by "Shawnsuun (via GitHub)" <gi...@apache.org> on 2025/02/15 16:51:43 UTC, 2 replies.
- Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink] - posted by "nicknezis (via GitHub)" <gi...@apache.org> on 2025/02/16 03:21:33 UTC, 21 replies.
- [jira] [Created] (FLINK-37332) Support any columns as chunk key column (postgres, orcale, db2, sqlserver) - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2025/02/16 07:58:00 UTC, 0 replies.
- [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) [flink-cdc] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2025/02/16 08:00:35 UTC, 5 replies.
- [jira] [Updated] (FLINK-37332) Support any columns as chunk key column (postgres, orcale, db2, sqlserver) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/16 08:01:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese - posted by "Jinkun Liu (Jira)" <ji...@apache.org> on 2025/02/16 10:01:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2025/02/16 14:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37097) Remove Hive connector from core Flink - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/16 16:55:00 UTC, 1 replies.
- Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink] - posted by "juanvisoler (via GitHub)" <gi...@apache.org> on 2025/02/16 19:50:52 UTC, 0 replies.
- Re: [PR] [FLINK-33786][Connectors / Hive] Remove Hive connector from master branch [flink] - posted by "lincoln-lil (via GitHub)" <gi...@apache.org> on 2025/02/17 02:05:12 UTC, 3 replies.
- [jira] [Assigned] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 03:51:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 03:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 04:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37047) Cross-team verification for "Remove DataSet API" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 04:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 04:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37052) Cross-team verification for FLINK-36245 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 04:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37062) Cross-team verification for FLINK-36147 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 06:07:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-31960) SQL OverBy. Error on a code that does not exist - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2025/02/17 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect - posted by "xingbe (Jira)" <ji...@apache.org> on 2025/02/17 06:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/02/17 06:54:00 UTC, 0 replies.
- [PR] [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect. [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2025/02/17 07:15:10 UTC, 3 replies.
- [jira] [Updated] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/17 07:16:00 UTC, 1 replies.
- [PR] [FLINK-37304] Reduce the log level about metadataUpdateEvent in DynamicKafkaSourceEnumerator. [flink-connector-kafka] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/17 07:31:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-37044) Support connectors and formats as plugins - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2025/02/17 07:53:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 07:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/17 08:05:00 UTC, 4 replies.
- [jira] [Created] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/17 08:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/17 08:07:00 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readTextFile method in documentation [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/17 08:11:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 08:12:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 08:12:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/17 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. - posted by "Han Yin (Jira)" <ji...@apache.org> on 2025/02/17 08:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly - posted by "He Wang (Jira)" <ji...@apache.org> on 2025/02/17 08:55:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. - posted by "Han Yin (Jira)" <ji...@apache.org> on 2025/02/17 08:55:00 UTC, 5 replies.
- [PR] [FLINK-37335][state/forst] Handle the first full checkpoint for ForSt IncrementalSnapshotStrategy. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/02/17 09:31:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/17 09:33:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37336) Introduce TablePipeline to Python API - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/17 10:15:00 UTC, 0 replies.
- [PR] [FLINK-26089][python] Introduce TablePipeline descriptor to Python Table API [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/17 10:55:41 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37326) The transform module reports an error when column is a Java keyword - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/17 11:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/17 14:56:52 UTC, 35 replies.
- [jira] [Updated] (FLINK-37336) Introduce TablePipeline to Python API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/17 14:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/17 18:32:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-33786) Remove Hive connector from master branch - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/17 19:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-33786) Remove Hive connector from master branch - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/17 19:59:00 UTC, 0 replies.
- Re: [PR] Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10 [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/02/17 20:08:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-37177) Update chinese documentation of json function - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/17 20:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37177) Update chinese documentation of json function - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/17 20:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37177) Update chinese documentation of json function - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/17 20:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-37306][tests] Fix MySQLSourceITCase failure in non-UTC timezone [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/18 01:40:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-37306) Flink CDC CI failed due to timezone shift - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 01:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37306) Flink CDC CI failed due to timezone shift - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/18 01:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37306) Flink CDC CI failed due to timezone shift - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/18 01:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/02/18 01:59:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/02/18 02:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2025/02/18 02:01:00 UTC, 1 replies.
- Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/18 02:06:15 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/18 03:46:00 UTC, 1 replies.
- [jira] (FLINK-36290) OutOfMemoryError in connect test run - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 03:47:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 03:47:00 UTC, 2 replies.
- [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] - posted by "whhe (via GitHub)" <gi...@apache.org> on 2025/02/18 03:47:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-34979) Implement State Future and related utilities - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2025/02/18 03:51:00 UTC, 5 replies.
- [PR] [FLINK-37149][doc] Add documents for adaptive batch execution. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/18 04:11:42 UTC, 3 replies.
- [jira] [Updated] (FLINK-37149) Add Adaptive Batch Execution Documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/18 04:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/18 04:26:00 UTC, 1 replies.
- [PR] [FLINK-34961] Use dedicated CI name for Hive connector to differentiate it in infra-reports [flink-connector-hive] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/18 06:06:16 UTC, 2 replies.
- [jira] [Closed] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/18 06:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/18 06:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37063) Cross-team verification for "Drop support for Java 8" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37063) Cross-team verification for "Drop support for Java 8" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37063) Cross-team verification for "Drop support for Java 8" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33463) Support the implementation of dynamic source tables based on the new source - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/18 06:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:26:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:28:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36290) OutOfMemoryError in connect test run - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 06:31:00 UTC, 0 replies.
- [PR] Migrate to SinkV2 impl [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/18 06:31:42 UTC, 0 replies.
- Re: [PR] [WIP] Migrate to SinkV2 impl [flink-connector-elasticsearch] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/18 06:43:44 UTC, 0 replies.
- [jira] [Closed] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or being restored - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/18 07:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 07:10:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 07:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 07:11:00 UTC, 0 replies.
- [PR] [FLINK-36998][table-planner] Keep same behavior about the RowKind of data in globalUpsertResult for KeyedUpsertingSinkFunction while being inserted or being restore [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/02/18 07:22:08 UTC, 3 replies.
- [jira] [Created] (FLINK-37339) Add documentation about JDK21 support - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37340) Flink Flink supports pushing metrics immediately at the end of the task. - posted by "lizhiqiang (Jira)" <ji...@apache.org> on 2025/02/18 07:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37339) Add documentation about JDK21 support - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/18 07:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. - posted by "lizhiqiang (Jira)" <ji...@apache.org> on 2025/02/18 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37342) Add support for smile format in flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 07:49:00 UTC, 0 replies.
- [PR] [FLINK-37341][table] Add `smile` format [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/18 07:53:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 07:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37068) Cross-team verification for FLIP-473 - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/02/18 07:56:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-37068) Cross-team verification for FLIP-473 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/18 08:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2025/02/18 08:35:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37311) Fix doc generation issues with new version of hugo - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 08:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34979) Implement State Future and related utilities - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2025/02/18 08:55:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:16:00 UTC, 0 replies.
- Re: [PR] draft: [FLINK-17971] [Runtime/StateBackends] Add RocksDB SST ingestion for batch writes [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/18 09:17:28 UTC, 1 replies.
- [jira] [Created] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector - posted by "Alex Aranovsky (Jira)" <ji...@apache.org> on 2025/02/18 09:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-19303) Disable WAL in RocksDB recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:38:00 UTC, 0 replies.
- Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/18 09:38:25 UTC, 10 replies.
- [jira] [Closed] (FLINK-19303) Disable WAL in RocksDB recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 09:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-35490] Migrate tests to JUnit 5 and AssertJ [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/18 09:53:54 UTC, 1 replies.
- Re: [PR] [FLINK-37120][cdc-connector] Add ending split chunk first to avoid TaskManager oom [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/02/18 09:59:23 UTC, 17 replies.
- [jira] [Created] (FLINK-37344) setup_hugo.sh should install the hugo binary only - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 10:07:00 UTC, 0 replies.
- [PR] [FLINK-37344][doc] setup_hugo.sh now installs the binary only [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/18 10:08:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-37344) setup_hugo.sh should install the hugo binary only - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 10:09:00 UTC, 0 replies.
- [PR] Bump org.apache.hive:hive-exec from 3.1.3 to 4.0.1 in /flink-sql-connector-hive-3.1.3 [flink-connector-hive] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/02/18 10:15:29 UTC, 0 replies.
- [jira] [Created] (FLINK-37345) [BUG] ClassCastException - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/18 10:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 10:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 11:00:00 UTC, 0 replies.
- Re: [PR] [FLINK-30371] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc] - posted by "fapaul (via GitHub)" <gi...@apache.org> on 2025/02/18 11:29:41 UTC, 6 replies.
- [jira] [Assigned] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2025/02/18 11:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2025/02/18 11:53:00 UTC, 2 replies.
- Re: [PR] [FLINK-37342][table] Add `smile` format [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/18 12:05:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-37342) Add support for smile format in flink-shaded - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 12:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37342) Add support for smile format in flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 12:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37342) Add support for smile format in flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 12:07:00 UTC, 0 replies.
- [PR] [FLINK-35622][runtime] Filter out noisy 'Coordinator of operator xxx does not exist' exceptions in CollectResultFetcher [flink] - posted by "bgeng777 (via GitHub)" <gi...@apache.org> on 2025/02/18 12:07:42 UTC, 2 replies.
- [jira] [Updated] (FLINK-35622) Filter out noisy "Coordinator of operator xxxx does not exist" exceptions in batch mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 12:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector - posted by "Alex Aranovsky (Jira)" <ji...@apache.org> on 2025/02/18 12:16:00 UTC, 0 replies.
- [PR] [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss [flink] - posted by "xiaoyu19950911 (via GitHub)" <gi...@apache.org> on 2025/02/18 12:18:27 UTC, 7 replies.
- [jira] [Commented] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2025/02/18 14:32:00 UTC, 0 replies.
- Re: [PR] [BP-1.19][FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2025/02/18 16:12:41 UTC, 0 replies.
- Re: [PR] [BP-1.19][FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18 [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2025/02/18 16:12:47 UTC, 0 replies.
- Re: [PR] [BP-1.19][FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2025/02/18 16:12:53 UTC, 0 replies.
- Re: [PR] [BP-1.19][FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2025/02/18 16:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37320) FINISHED finite streaming jobs incorrectly being set to RECONCILING - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/18 16:30:00 UTC, 2 replies.
- Re: [PR] [FLINK-33703] Use maven 3.8.6 for release profile [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/18 16:39:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 16:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 16:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/18 16:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37344) setup_hugo.sh should install the hugo binary only - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/02/18 17:01:00 UTC, 0 replies.
- [PR] [FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING [flink-kubernetes-operator] - posted by "luca-p-castelli (via GitHub)" <gi...@apache.org> on 2025/02/18 17:04:40 UTC, 4 replies.
- [jira] [Updated] (FLINK-37320) [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/18 17:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37344) setup_hugo.sh should install the hugo binary only - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/18 17:10:00 UTC, 0 replies.
- [PR] Release flink-shaded 20.0 [flink-web] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/18 17:39:16 UTC, 1 replies.
- Re: [PR] [FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2025/02/18 18:29:33 UTC, 3 replies.
- Re: [PR] [FLINK-36009] Architecture tests fixes [flink-connector-jdbc] - posted by "eskabetxe (via GitHub)" <gi...@apache.org> on 2025/02/18 21:01:21 UTC, 0 replies.
- [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] - posted by "morhidi (via GitHub)" <gi...@apache.org> on 2025/02/18 22:25:34 UTC, 15 replies.
- [jira] [Updated] (FLINK-36409) Publish some autoscaler metrics during stabilisation period - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/18 22:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or being restored - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/02/19 01:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/19 02:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/19 02:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 03:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/19 03:25:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/19 03:37:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/19 03:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/19 03:38:00 UTC, 3 replies.
- [PR] [FLINK-35810][test] increase unittest Xmx to debug FLINK-35810 [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/19 03:41:04 UTC, 2 replies.
- [jira] [Created] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver) - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2025/02/19 03:46:00 UTC, 0 replies.
- [PR] [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/02/19 03:54:53 UTC, 2 replies.
- [PR] [FLINK-37347][DOCS] Support any column as chunk key column (postgres, orcale, db2, sqlserver) [flink-cdc] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2025/02/19 04:05:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/19 04:06:00 UTC, 0 replies.
- [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between empty polls in getRecords calls [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/02/19 04:37:50 UTC, 0 replies.
- [jira] [Updated] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/19 04:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/19 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/19 06:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36867) flink on k8s operator could not create TM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/19 06:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35900) PyFlink: update version of Apache Beam dependency - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/02/19 06:24:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’ - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/19 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/19 06:39:00 UTC, 0 replies.
- [PR] [FLINK-37348][pipeline-paimon] fix paimon ArrayIndexOutOfBoundsException when add column first [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/02/19 06:45:44 UTC, 7 replies.
- [jira] [Updated] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/19 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 06:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36253) Wordcount on Docker test failed due to mismatch output hash - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/19 06:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-37204] Add missing StarRocks connector options for 1.2.10. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/19 07:04:10 UTC, 1 replies.
- [PR] [BP-2.0][FLINK-37335][state/forst] Handle the first full checkpoint for ForSt IncrementalSnapshotStrategy. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/02/19 07:12:29 UTC, 2 replies.
- [jira] [Created] (FLINK-37350) Memory leak caused by skewed join optimization strategy - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/19 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37351) Ensure writer and committer are colocated - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/19 08:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/19 09:43:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/19 10:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/19 10:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/02/19 11:48:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37352) Write full changelog to Paimon Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 12:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/19 12:13:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/19 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility - posted by "Anton Solovev (Jira)" <ji...@apache.org> on 2025/02/19 13:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37354) Kubernetes Operator HealthCheck compatibility - posted by "Anton Solovev (Jira)" <ji...@apache.org> on 2025/02/19 13:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37282) Add backchannel for producer recycling - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/19 14:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows - posted by "David Radley (Jira)" <ji...@apache.org> on 2025/02/19 14:36:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows - posted by "David Radley (Jira)" <ji...@apache.org> on 2025/02/19 14:36:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/02/19 16:21:00 UTC, 1 replies.
- [PR] [FLINK-36900] Migrate from conda to uv for managing Python environments [flink-connector-shared-utils] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/19 16:35:19 UTC, 4 replies.
- [jira] [Assigned] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/19 16:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/19 16:37:00 UTC, 0 replies.
- [PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/02/19 17:06:04 UTC, 5 replies.
- [jira] [Updated] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/19 17:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-36579][cdc] Fix mysql cdc charset collation sort not equals ja… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/02/20 00:04:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/02/20 00:40:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. - posted by "longwang0616 (Jira)" <ji...@apache.org> on 2025/02/20 01:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. - posted by "longwang0616 (Jira)" <ji...@apache.org> on 2025/02/20 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/20 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/20 02:20:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/20 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) may send data without AddPartitionsToTxnRequest - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/20 02:20:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/20 02:42:00 UTC, 0 replies.
- [jira] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/20 02:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2025/02/20 02:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/20 03:02:42 UTC, 5 replies.
- [jira] [Resolved] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/20 03:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/20 03:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/20 03:26:00 UTC, 0 replies.
- [PR] [FLINK-35724][oss] Bump OSS SDK to 3.17.4 [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/20 03:31:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/20 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37357) Migrating conversion logic to SqlNodeConverters - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/20 03:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/20 03:49:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37357) Migrating conversion logic to SqlNodeConverters - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/20 03:54:00 UTC, 0 replies.
- Re: [PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/02/20 04:05:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/20 05:22:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/20 05:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/20 05:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/20 05:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/20 05:34:00 UTC, 0 replies.
- [PR] [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2025/02/20 06:07:56 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-37274] Add examples for DataStream V2 [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/20 06:10:53 UTC, 2 replies.
- [jira] [Created] (FLINK-37358) Support pass format options to kafka pipeline sink - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2025/02/20 06:58:00 UTC, 0 replies.
- [PR] [FLINK-37358][kafka] Support to pass format options [flink-cdc] - posted by "Shawn-Hx (via GitHub)" <gi...@apache.org> on 2025/02/20 07:11:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-37358) Support pass format options to kafka pipeline sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/20 07:12:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37334) Fix mysql's add column after event becomes add column last - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/02/20 07:35:00 UTC, 0 replies.
- [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/20 08:03:23 UTC, 8 replies.
- [jira] [Updated] (FLINK-37350) Memory leak caused by skewed join optimization strategy - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/20 08:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/02/20 08:08:00 UTC, 7 replies.
- [PR] [BP-2.0][FLINK-37149][doc] Add documents for adaptive batch execution. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/20 09:03:51 UTC, 2 replies.
- Re: [PR] [FLINK-36659] Bump to 2.0-preview1. [flink-connector-jdbc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/20 09:13:52 UTC, 0 replies.
- [jira] [Created] (FLINK-37359) Docker build fails for Kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/20 11:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2025/02/20 11:30:00 UTC, 0 replies.
- [PR] [hotfix] Fix post-release japicmp updates script for macOS [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/20 11:37:01 UTC, 0 replies.
- Re: [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/20 11:53:14 UTC, 8 replies.
- [PR] [FLINK-37359] Use pinned qemu image [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/20 11:54:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-37359) Docker build fails for Kubernetes operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/20 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37360) Update japicmp configuration post 1.20.1 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/20 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37361) Update japicmp configuration post 1.19.2 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/20 12:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37360) Update japicmp configuration post 1.20.1 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/20 12:26:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37361) Update japicmp configuration post 1.19.2 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/20 12:26:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/20 12:28:00 UTC, 10 replies.
- [PR] [FLINK-37361][release] Update japicmp configuration post 1.19.2 [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/20 12:28:47 UTC, 2 replies.
- [PR] [FLINK-37360][release] Update japicmp configuration post 1.20.1 [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/20 12:31:27 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37152) Update Flink version to 1.20 in Flink CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/20 13:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/20 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37362) PolardbxCharsetITCase test has timed out after 60 minutes - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/20 13:21:00 UTC, 0 replies.
- Re: [PR] [FLINK-37359] Pin qemu image to 7.0.0 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/20 13:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/20 13:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37359) Docker build fails for Kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/20 13:26:00 UTC, 0 replies.
- [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink-connector-hive] - posted by "slankka (via GitHub)" <gi...@apache.org> on 2025/02/20 13:39:40 UTC, 0 replies.
- Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink] - posted by "slankka (via GitHub)" <gi...@apache.org> on 2025/02/20 13:40:53 UTC, 1 replies.
- [jira] [Created] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/20 13:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/20 13:59:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/20 13:59:00 UTC, 0 replies.
- [PR] [FLINK-37364][build] Bump Flink 1.19 and 1.20 patch versions [flink-cdc] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/02/20 14:14:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/20 14:15:00 UTC, 0 replies.
- [PR] [FLINK-37363][state] Removed confusing and duplicated state.backend.type config from state SQL connector [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/20 14:18:44 UTC, 7 replies.
- Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] - posted by "sn-12-3 (via GitHub)" <gi...@apache.org> on 2025/02/20 17:03:21 UTC, 0 replies.
- [jira] [Created] (FLINK-37365) Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/20 17:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/20 17:51:00 UTC, 1 replies.
- [PR] [FLINK-36585][hotfix] Fix the flaky unit test. [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2025/02/20 18:35:09 UTC, 9 replies.
- [jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/20 19:28:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/02/20 19:30:00 UTC, 0 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/02/21 00:04:17 UTC, 1 replies.
- Re: [PR] [FLINK-34467] add lineage integration for jdbc connector [flink-connector-jdbc] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2025/02/21 01:27:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-37322) surport eval groovy scripts udf for flink sql - posted by "tianyuan (Jira)" <ji...@apache.org> on 2025/02/21 01:55:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37149) Add Adaptive Batch Execution Documentation - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/21 02:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/21 02:29:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-35724][oss] Bump OSS SDK to 3.17.4 [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/21 02:32:03 UTC, 2 replies.
- [jira] [Closed] (FLINK-35622) Filter out noisy "Coordinator of operator xxxx does not exist" exceptions in batch mode - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/21 02:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35622) Filter out noisy "Coordinator of operator xxxx does not exist" exceptions in batch mode - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/21 02:55:00 UTC, 0 replies.
- [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) #3922 [flink-cdc] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2025/02/21 05:32:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" - posted by "xingbe (Jira)" <ji...@apache.org> on 2025/02/21 05:51:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-37320) [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/02/21 06:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/02/21 06:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37357) Migrating SqlNode conversion logic from to SqlNodeConverters - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/21 06:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37357) Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters - posted by "Hirson Zhang (Jira)" <ji...@apache.org> on 2025/02/21 06:45:00 UTC, 1 replies.
- Re: [PR] [FLINK-35397] Translate controller-flow documents into Chinese [flink-kubernetes-operator] - posted by "caicancai (via GitHub)" <gi...@apache.org> on 2025/02/21 08:13:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-35397) Translate Controller Flow documentation into Chinese - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/21 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37367) Properly inherit uploaded SST files after ForSt restore - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/21 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37368) MySQL Pipeline job failed to checkpoint after closing idle readers - posted by "yux (Jira)" <ji...@apache.org> on 2025/02/21 08:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-33265] Support source parallelism setting for Kafka connector [flink-connector-kafka] - posted by "libenchao (via GitHub)" <gi...@apache.org> on 2025/02/21 09:12:31 UTC, 1 replies.
- [jira] [Closed] (FLINK-33265) Support source parallelism setting for Kafka connector - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2025/02/21 09:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-33265) Support source parallelism setting for Kafka connector - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2025/02/21 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37369) Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE CURRENT_TIMESTAMP - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/21 09:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37369) Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE CURRENT_TIMESTAMP - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/21 09:58:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-37365) Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs - posted by "Stefan Richter (Jira)" <ji...@apache.org> on 2025/02/21 10:30:00 UTC, 0 replies.
- Re: [PR] [FLINK-36821] Update to Kafka 3.9.0 [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/02/21 10:46:44 UTC, 0 replies.
- [PR] [FLINK-36324] Harden runtime error cases for table builtin functions [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/21 11:13:26 UTC, 5 replies.
- [jira] [Updated] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/21 11:14:00 UTC, 0 replies.
- [PR] [hotfix][docs] Update docs to the latest 1.20 version [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/21 11:41:05 UTC, 2 replies.
- [PR] [hotfix][docs] Update docs to the latest 1.19 version [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2025/02/21 11:44:43 UTC, 2 replies.
- [jira] [Closed] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/21 11:46:00 UTC, 0 replies.
- [PR] Kudu continuous source initial commit. [flink-connector-kudu] - posted by "martongreber (via GitHub)" <gi...@apache.org> on 2025/02/21 13:30:00 UTC, 13 replies.
- [jira] [Assigned] (FLINK-37336) Introduce TablePipeline to Python API - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/21 13:31:00 UTC, 0 replies.
- [PR] [release] Main branch updates after release cut [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/21 14:59:50 UTC, 1 replies.
- [jira] [Closed] (FLINK-37267) Support WITH ORDINALITY for UNNEST - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/21 15:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-37363][state] Make state.backend.type config optional for state SQL connector [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/21 15:15:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-37361) Update japicmp configuration post 1.19.2 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/21 16:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37360) Update japicmp configuration post 1.20.1 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/21 16:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37361) Update japicmp configuration post 1.19.2 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/21 16:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37360) Update japicmp configuration post 1.20.1 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2025/02/21 16:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33773) Add fairness to scaling decisions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34151) Integrate Karpenter resource limits into cluster capacity check - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34539) Tune JobManager memory - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35746) Add logic to override observed config based on settings observed through REST API - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35818) Flink operator unable to be installed if ResourceQuota's are defined on cluster - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34540) Tune number of task slots - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33789) Expose restart time as a metric - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36528) Update org.apache.avro : avro dependency - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34907) jobRunningTs should be the timestamp that all tasks are running - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36583) Add Slow Request Kube Client Metrics - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36583) Add Slow Request Kube Client Metrics - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:15:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-33673) SizeLimits not being set on emptyDir - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33799) Add e2e's for tls enabled operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36527) Introduce a parameter to support the autoscaler to adopt a more aggressive strategy when Source or upstream shuffle is keyBy - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/21 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/21 17:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/21 17:27:00 UTC, 2 replies.
- [PR] [FLINK-37370] [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR [flink-kubernetes-operator] - posted by "luca-p-castelli (via GitHub)" <gi...@apache.org> on 2025/02/21 17:49:23 UTC, 6 replies.
- Re: [PR] Fix an exception:java.lang.NoClassDefFoundError: [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/02/22 00:04:06 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37368) MySQL Pipeline job failed to checkpoint after closing idle readers - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/22 02:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/22 04:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36086) SQL Server source connector skips changes if restarted mid transaction - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2025/02/22 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37371) Postgres CDC incremental source fails to handle upper-case table and column names - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/02/22 08:12:00 UTC, 0 replies.
- [PR] [FLINK-37371] Postgres CDC incremental source fails to handle upper-case table and column names [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/02/22 08:21:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-37371) Postgres CDC incremental source fails to handle upper-case table and column names - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/22 08:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/02/22 08:32:24 UTC, 1 replies.
- [PR] [hotfix][tests] Use Junit5 import. [flink] - posted by "slfan1989 (via GitHub)" <gi...@apache.org> on 2025/02/22 10:12:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-37369) Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE CURRENT_TIMESTAMP - posted by "caixiaowei (Jira)" <ji...@apache.org> on 2025/02/22 10:24:00 UTC, 0 replies.
- [PR] [FLINK-37369] Add OceanBaseValueConverters to fix table schema valida… [flink-cdc] - posted by "weigphf (via GitHub)" <gi...@apache.org> on 2025/02/22 11:04:39 UTC, 0 replies.
- [PR] Kubernetes Operator 1.11.0 release [flink-web] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/22 15:28:01 UTC, 2 replies.
- Re: [PR] [FLINK-36881][table] Introduce GroupTableAggFunction in GroupTableAggregate with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2025/02/23 07:30:36 UTC, 1 replies.
- [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink] - posted by "dyccode (via GitHub)" <gi...@apache.org> on 2025/02/23 11:01:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-36652) Upgrade Apache ORC to 1.9.4 - posted by "Yuchi Duan (Jira)" <ji...@apache.org> on 2025/02/23 12:51:00 UTC, 0 replies.
- [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "J-kk911 (via GitHub)" <gi...@apache.org> on 2025/02/23 13:00:44 UTC, 21 replies.
- [jira] [Closed] (FLINK-36857) Bump scala version to 2.12.20 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/23 22:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36948) Drop deprecated FlinkMatchers - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/23 22:39:00 UTC, 0 replies.
- [PR] [FLINK-30719] Update frontend-maven-plugin from 1.12.1 to 1.15.1 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/23 22:56:50 UTC, 4 replies.
- [jira] [Updated] (FLINK-30719) flink-runtime-web failed due to a corrupted nodejs dependency - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/23 22:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/24 02:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36086) SQL Server source connector skips changes if restarted mid transaction - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/24 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37372) Savepoint error can cause operator to hang - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/24 08:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37372) Savepoint error can cause operator to hang - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/24 08:37:00 UTC, 1 replies.
- [PR] [FLINK-37372] Fix infinite loop bug in savepoint error handling [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/24 08:48:53 UTC, 5 replies.
- [jira] [Created] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 09:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-30252) Publish flink-shaded pom - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/24 09:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 09:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37374) Support JSON built-in function for JSON_ARRAY - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/02/24 09:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 09:10:00 UTC, 13 replies.
- [jira] [Updated] (FLINK-37374) Support JSON built-in function for JSON_ARRAY - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/02/24 09:11:00 UTC, 0 replies.
- [PR] Revert "[FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/24 09:22:50 UTC, 2 replies.
- [PR] [FLINK-37374][table] Add the built-in function JSON for JSON_OBJECT [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/02/24 09:33:01 UTC, 1 replies.
- [PR] Rebuild site [flink-web] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/24 09:47:31 UTC, 1 replies.
- [jira] [Closed] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/24 10:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-37374][table] Add the built-in function JSON for JSON_ARRAY [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/24 10:38:59 UTC, 7 replies.
- [PR] [BP-2.0][FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/24 11:30:39 UTC, 4 replies.
- [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] - posted by "Milesian111 (via GitHub)" <gi...@apache.org> on 2025/02/24 11:46:33 UTC, 5 replies.
- [jira] [Created] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state - posted by "Jufang He (Jira)" <ji...@apache.org> on 2025/02/24 12:37:00 UTC, 0 replies.
- [PR] [FLINK-37367][state/forst] Make ForSt inherit unloaded SST files after restorations. [flink] - posted by "AlexYinHan (via GitHub)" <gi...@apache.org> on 2025/02/24 13:07:33 UTC, 3 replies.
- [jira] [Updated] (FLINK-37367) Properly inherit uploaded SST files after ForSt restore - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/24 13:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37372) Savepoint error can cause operator to hang - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/24 13:32:00 UTC, 0 replies.
- [PR] Correct throttling logic on ThrottledIterator [flink] - posted by "rafaelzimmermann (via GitHub)" <gi...@apache.org> on 2025/02/24 14:44:27 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:16:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:31:00 UTC, 0 replies.
- [PR] [FLINK-36172][runtime] Optimize transient metric cleanup [flink] - posted by "fdc91 (via GitHub)" <gi...@apache.org> on 2025/02/24 16:37:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/24 16:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2025/02/24 16:41:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted nodejs dependency - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-30719) flink-runtime-web failed due to a corrupted nodejs dependency - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 16:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-36172][metrics][rest] Optimize transient metric cleanup [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/24 17:12:09 UTC, 2 replies.
- [PR] [FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2025/02/24 18:02:29 UTC, 5 replies.
- [jira] [Created] (FLINK-37376) Bump flink-shaded to 20.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 18:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37376) Bump flink-shaded to 20.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 18:12:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37377) Sync guava with guava in flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/24 18:13:00 UTC, 0 replies.
- [PR] [FLINK-37376] Upgrade to flink-shaded 20.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/24 18:16:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-37363) Make state.backend.type config optional for state SQL connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/24 19:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37363) Make state.backend.type config optional for state SQL connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/24 19:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37363) Make state.backend.type config optional for state SQL connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/24 19:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "jeacott1 (via GitHub)" <gi...@apache.org> on 2025/02/24 23:17:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 01:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37047) Cross-team verification for "Remove DataSet API" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 02:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 02:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37062) Cross-team verification for FLINK-36147 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 02:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37062) Cross-team verification for FLINK-36147 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 02:23:00 UTC, 0 replies.
- [PR] [FLINK-37339][doc] Update java_compatibility doc [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/02/25 02:49:46 UTC, 3 replies.
- [jira] [Updated] (FLINK-37339) Add documentation about JDK21 support - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/25 02:50:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/25 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "slankka (Jira)" <ji...@apache.org> on 2025/02/25 03:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "slankka (Jira)" <ji...@apache.org> on 2025/02/25 03:39:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-37350) Memory leak caused by skewed join optimization strategy - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/25 03:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/02/25 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37379) Lack of state cache load for ForSt after recovery - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/25 05:03:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37339) Add documentation about JDK21 support - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:11:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37339) Add documentation about JDK21 support - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36336) Remove deprecated dataset API - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36336) Remove deprecated dataset API - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:15:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-36336) Remove deprecated dataset API - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36336) Remove deprecated dataset API - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 06:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37162) Add Data Sink Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/25 06:27:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37162) Add Data Sink Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/25 06:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/25 06:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/25 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/25 06:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/25 06:31:00 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-37162][docs] Add sinks.md to describe Flink's Data Sink API [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/25 06:43:17 UTC, 14 replies.
- [jira] [Resolved] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 07:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37379) Lack of state cache load for ForSt after recovery - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/25 07:06:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37060) Cross-team verification for FLIP-398 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/25 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37381) Typo in Join document - posted by "cnsky1103 (Jira)" <ji...@apache.org> on 2025/02/25 07:07:00 UTC, 0 replies.
- [PR] [FLINK-37381] [doc] Fix typo in Join document [flink] - posted by "cnsky1103 (via GitHub)" <gi...@apache.org> on 2025/02/25 07:11:03 UTC, 3 replies.
- [jira] [Updated] (FLINK-37381) Typo in Join document - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/25 07:12:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/25 07:18:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/25 07:39:00 UTC, 0 replies.
- [PR] Update version to 21.0 [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/25 07:54:54 UTC, 0 replies.
- [jira] [Created] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold - posted by "xingbe (Jira)" <ji...@apache.org> on 2025/02/25 08:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/25 08:52:00 UTC, 0 replies.
- [PR] FLINK-35350 [flink-connector-kudu] - posted by "dinchamion (via GitHub)" <gi...@apache.org> on 2025/02/25 10:56:10 UTC, 3 replies.
- [jira] [Updated] (FLINK-35350) Add documentation for Kudu - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/25 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37383) ThrottleIterator from examples/utils does not properly throttle on next window after throttle is applied - posted by "Rafael Zimmermann (Jira)" <ji...@apache.org> on 2025/02/25 11:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator [flink] - posted by "rafaelzimmermann (via GitHub)" <gi...@apache.org> on 2025/02/25 11:38:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-37383) ThrottleIterator from examples/utils does not properly throttle on next window after throttle is applied - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/25 11:39:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "slankka (Jira)" <ji...@apache.org> on 2025/02/25 12:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "slankka (Jira)" <ji...@apache.org> on 2025/02/25 12:58:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/25 13:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/02/25 13:20:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/25 13:23:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37376) Bump flink-shaded to 20.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/25 13:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37376) Bump flink-shaded to 20.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/25 13:31:00 UTC, 0 replies.
- [PR] [FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/25 13:31:11 UTC, 3 replies.
- [jira] [Resolved] (FLINK-37377) Sync guava with guava in flink-shaded - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/25 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37385) Add support for smile format in flink main repo - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/25 13:33:00 UTC, 0 replies.
- [PR] [FLINK-37382][runtime] Early optimization for adaptive join when either input is below broadcast threshold. [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2025/02/25 13:44:23 UTC, 8 replies.
- [jira] [Updated] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/25 13:45:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-33353) SQL fails because "TimestampType.kind" is not serialized - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/25 14:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33353) SQL fails because "TimestampType.kind" is not serialized - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/25 14:50:00 UTC, 1 replies.
- Re: [PR] [hotfix] Update version to 21.0 [flink-shaded] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/25 16:42:04 UTC, 0 replies.
- Re: [PR] [FLINK-37008] [runtime-web] Flink UI should show the type of checkpoint (full vs incremental) [flink] - posted by "ryanvanhuuksloot (via GitHub)" <gi...@apache.org> on 2025/02/25 21:49:28 UTC, 1 replies.
- Re: [PR] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/02/26 00:04:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/26 02:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37068) Cross-team verification for FLIP-473 - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/02/26 02:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31197) Unable to write Parquet files containing Arrays with complex types. - posted by "Brett Randall (Jira)" <ji...@apache.org> on 2025/02/26 05:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/26 06:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37274) Add examples for datastream api v2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/26 07:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37274) Add examples for datastream api v2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/26 07:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36402) Improper variable naming - posted by "Nil Madhab (Jira)" <ji...@apache.org> on 2025/02/26 07:14:00 UTC, 4 replies.
- [PR] [FLINK-37337][sql-client] No need to add sql-client jar [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/02/26 07:51:20 UTC, 0 replies.
- [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] - posted by "suez1224 (via GitHub)" <gi...@apache.org> on 2025/02/26 07:52:50 UTC, 2 replies.
- [jira] [Updated] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/26 07:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-37337][sql-client] No need to add sql-client jar as job dependencies [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/26 08:19:34 UTC, 1 replies.
- [jira] [Created] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/02/26 08:25:00 UTC, 0 replies.
- [PR] [FLINK-37278] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/26 08:28:32 UTC, 0 replies.
- [PR] [hotfix] Update failureaccess in order to fix java 11 license check [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/26 09:02:40 UTC, 3 replies.
- [jira] [Assigned] (FLINK-35350) Add documentation for Kudu - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37387) License check behaves differently for different jdk versions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/26 09:06:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2025/02/26 09:10:03 UTC, 3 replies.
- [jira] [Created] (FLINK-37388) [BUG] Field names must be unique. - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/26 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37389) Add "flink-sql-connector-kudu" module - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 09:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37390) Push filter into ChangelogNormalize - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/26 09:22:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/26 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37391) Change watchNamespace config in operator is not respected while running - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2025/02/26 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/02/26 10:44:00 UTC, 0 replies.
- [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/02/26 10:57:22 UTC, 5 replies.
- [PR] [FLINK-37385][table] Add support for smile format [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/26 11:54:05 UTC, 6 replies.
- [jira] [Updated] (FLINK-37385) Add support for smile format in flink main repo - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/26 11:55:00 UTC, 0 replies.
- Re: [PR] [DRAFT][FLINK-33734] Merge unaligned checkpoint state handle [flink] - posted by "zoltar9264 (via GitHub)" <gi...@apache.org> on 2025/02/26 12:05:07 UTC, 0 replies.
- [PR] [FLINK-37389] Add `flink-sql-connector-kudu` module [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/02/26 12:16:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-37389) Add "flink-sql-connector-kudu" module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/26 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion - posted by "Rafael Zimmermann (Jira)" <ji...@apache.org> on 2025/02/26 12:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion - posted by "Rafael Zimmermann (Jira)" <ji...@apache.org> on 2025/02/26 12:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37374) Support JSON built-in function for JSON_ARRAY - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/26 13:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 13:25:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37394) Update supported Flink versions to 1.19 and 1.20 in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 13:25:00 UTC, 0 replies.
- [PR] [FLINK-37394] Update CI Flink versions to 1.19 and 1.20 [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/02/26 13:26:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2025/02/26 14:03:00 UTC, 1 replies.
- [PR] [FLINK-37376] Upgrade flink-shaded to 20.0 [flink-benchmarks] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/26 14:03:38 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36855) Implement Source API in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 14:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/02/26 15:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/02/26 15:31:16 UTC, 12 replies.
- [jira] [Updated] (FLINK-36855) Implement Source API in Kudu connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/26 15:32:00 UTC, 0 replies.
- [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/02/26 15:59:19 UTC, 4 replies.
- [PR] [hotfix] fix data race in method in [flink] - posted by "raulpardo (via GitHub)" <gi...@apache.org> on 2025/02/26 16:17:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36402) Improper variable naming - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/02/26 16:33:00 UTC, 0 replies.
- Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/26 16:40:04 UTC, 3 replies.
- Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink] - posted by "zoltar9264 (via GitHub)" <gi...@apache.org> on 2025/02/26 16:48:53 UTC, 3 replies.
- Re: [PR] [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2025/02/26 16:59:30 UTC, 1 replies.
- [PR] edgeRemapings typo fixed to edgeRemappings [flink] - posted by "nilmadhab (via GitHub)" <gi...@apache.org> on 2025/02/26 19:28:13 UTC, 1 replies.
- [PR] FLINK-36402: edgeRemapings typo fixed to edgeRemappings [flink] - posted by "nilmadhab (via GitHub)" <gi...@apache.org> on 2025/02/26 21:11:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-36402) Improper variable naming - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/26 21:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/02/27 00:04:25 UTC, 1 replies.
- [PR] CP [FLINK-37337][sql-client] No need to add sql-client jar as job depend… [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/02/27 01:31:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/02/27 01:32:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/02/27 01:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-36061] Support Iceberg CDC Pipeline SinkV2 [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/27 01:44:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-37388) [BUG] Field names must be unique. - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/27 02:13:00 UTC, 1 replies.
- [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Ex… [flink-connector-kafka] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/02/27 03:12:31 UTC, 1 replies.
- [jira] [Created] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered - posted by "zexin gong (Jira)" <ji...@apache.org> on 2025/02/27 05:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Yutong Han (Jira)" <ji...@apache.org> on 2025/02/27 05:42:00 UTC, 2 replies.
- [PR] [minor][docs] Update some inaccurate descriptions. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/27 05:51:20 UTC, 4 replies.
- [jira] [Reopened] (FLINK-37162) Add Data Sink Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/27 05:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37162) Add Data Sink Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/27 05:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/02/27 06:08:00 UTC, 0 replies.
- [PR] [HOTFIX][DOCS] fix option name [flink-connector-mongodb] - posted by "xli1996 (via GitHub)" <gi...@apache.org> on 2025/02/27 07:49:42 UTC, 1 replies.
- [PR] Move ImpulseSource to new Source API [flink-kubernetes-operator] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/02/27 08:37:07 UTC, 0 replies.
- [jira] [Created] (FLINK-37396) Kafka connector python test fail - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/27 08:49:00 UTC, 0 replies.
- Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/02/27 08:49:37 UTC, 1 replies.
- [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/27 09:20:05 UTC, 4 replies.
- [jira] [Created] (FLINK-37397) Python wheel builds broken in nightly - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/27 09:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37397) Python wheel builds broken in nightly - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/27 09:53:00 UTC, 0 replies.
- [PR] [FLINK-37397][python] Fix deactivate error build-wheel.sh script [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/02/27 10:10:00 UTC, 6 replies.
- [jira] [Updated] (FLINK-37397) Python wheel builds broken in nightly - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/27 10:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-36857] Bump scala version to 2.12.20 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/02/27 10:45:06 UTC, 1 replies.
- [PR] [FLINK-37396] Fix setup.py: Multiple top-level packages discovered in a flat-layout [flink-connector-kafka] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/02/27 11:12:23 UTC, 1 replies.
- [jira] [Updated] (FLINK-37396) Kafka connector python test fail - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/27 11:13:00 UTC, 2 replies.
- Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/27 11:27:39 UTC, 0 replies.
- [jira] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/02/27 11:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/02/27 11:51:00 UTC, 1 replies.
- Re: [PR] [FLINK-37396] Fix setup.py: multiple top-level packages discovered in a flat-layout [flink-connector-kafka] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/02/27 11:53:23 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37396) Kafka connector python test fail - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/27 11:54:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37396) Kafka connector python test fail - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/27 11:55:00 UTC, 0 replies.
- [jira] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/02/27 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/02/27 12:04:00 UTC, 6 replies.
- [jira] [Resolved] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/02/27 13:06:00 UTC, 0 replies.
- Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2025/02/27 13:06:10 UTC, 8 replies.
- [jira] [Resolved] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/27 13:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/02/27 13:26:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37398) State processor API blows up with cryptic error when changelog used - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/27 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/27 14:16:00 UTC, 0 replies.
- [PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/02/27 14:43:41 UTC, 4 replies.
- [jira] [Updated] (FLINK-37398) State processor API blows up with cryptic error when changelog used - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/27 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/27 16:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/27 16:06:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/02/27 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/27 16:12:00 UTC, 0 replies.
- [PR] [FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/27 16:17:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/27 16:18:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-37269) Add new DESCRIPTOR data type - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/27 16:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37336) Introduce TablePipeline to Python API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/27 16:19:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/27 16:20:11 UTC, 3 replies.
- [jira] [Created] (FLINK-37401) Add Job ID to logging context of slotmanager classes - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2025/02/27 16:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37401) Add Job ID to logging context of slotmanager classes - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/02/27 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/02/27 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37403) Support retractions/updates for IntervalJoin operator - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/02/27 16:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37403) Support retractions/updates for IntervalJoin operator - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2025/02/27 16:55:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37397) Python wheel builds broken in nightly - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/27 17:54:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37397) Python wheel builds broken in nightly - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/27 17:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/02/27 18:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/02/27 18:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37398) State processor API blows up with cryptic error when changelog used - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/27 18:26:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37398) State processor API blows up with cryptic error when changelog used - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/02/27 18:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37381) Typo in Join document - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/02/27 20:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink] - posted by "kimgr (via GitHub)" <gi...@apache.org> on 2025/02/27 21:34:37 UTC, 0 replies.
- [jira] [Created] (FLINK-37404) Reenable Migration Tests for Filnk 2.x - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2025/02/27 21:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2025/02/27 21:59:00 UTC, 1 replies.
- Re: [PR] add updateBinlogStartPoint function [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/02/28 00:04:13 UTC, 1 replies.
- [jira] [Closed] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/02/28 02:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/28 03:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/02/28 03:03:00 UTC, 2 replies.
- [PR] [FLINK-25920] bump flink version to 1.20.1. [flink-connector-kafka] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/02/28 03:25:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/28 03:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/28 03:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37403) Support retractions/updates for IntervalJoin operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/02/28 04:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/28 04:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/02/28 04:30:00 UTC, 0 replies.
- Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/02/28 04:51:18 UTC, 5 replies.
- [jira] [Updated] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/28 04:52:00 UTC, 0 replies.
- [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink] - posted by "suez1224 (via GitHub)" <gi...@apache.org> on 2025/02/28 05:48:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/28 05:49:00 UTC, 0 replies.
- [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2025/02/28 06:08:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-37318) RocksDBKeyedStateBackend disposed before task exit - posted by "Nil Madhab (Jira)" <ji...@apache.org> on 2025/02/28 07:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36702) FLIP-480: Support to deploy SQL script in application mode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/28 07:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread - posted by "liting liu (Jira)" <ji...@apache.org> on 2025/02/28 07:36:00 UTC, 0 replies.
- [PR] [trigger-ci][FLINK-36172][runtime] Optimize transient metric cleanup [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/28 07:56:58 UTC, 1 replies.
- Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/02/28 08:22:06 UTC, 1 replies.
- [jira] [Closed] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/28 08:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/02/28 08:50:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-36172][runtime] Optimize transient metric cleanup [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/02/28 08:58:29 UTC, 1 replies.
- [PR] [FLINK-37148][docs] Update DataStream V2 documents for StateManager#getState and StateManager#getStateOptional methods [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/28 09:28:02 UTC, 1 replies.
- [PR] [BP-2.0][FLINK-37148][docs] Update DataStream V2 documents for StateManager#getState and StateManager#getStateOptional methods [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2025/02/28 09:33:15 UTC, 1 replies.
- [jira] [Created] (FLINK-37405) Perform upstream YAML config validation for Flink 2.x - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/28 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/28 10:22:00 UTC, 0 replies.
- [PR] Update table_api.md [flink] - posted by "nilmadhab (via GitHub)" <gi...@apache.org> on 2025/02/28 11:12:10 UTC, 0 replies.
- Re: [PR] Update table_api.md with modern Docker Compose syntax [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/28 11:29:32 UTC, 0 replies.
- [jira] [Updated] (FLINK-37405) Perform upfront YAML config validation for Flink 2.x - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/02/28 11:55:00 UTC, 1 replies.
- [PR] [FLINK-37405] Validate config prefixes for Flink 2.0 [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/02/28 11:57:30 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/28 12:13:00 UTC, 0 replies.
- [PR] [FLINK-37402][table] Emit watermarks after record in TestSourceFunction and TestValuesRuntimeFunctions [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/02/28 13:41:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-37402) SQL testing sources produce incorrect watermarks - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/28 13:42:00 UTC, 0 replies.
- Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] - posted by "Poorvankbhatia (via GitHub)" <gi...@apache.org> on 2025/02/28 14:31:55 UTC, 3 replies.
- [jira] [Updated] (FLINK-33525) Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/02/28 14:32:00 UTC, 0 replies.
- [PR] [FLINK-37379] Double list LRU in ForSt state and cache reload [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2025/02/28 15:59:13 UTC, 0 replies.
- Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/02/28 16:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37390) Push filter into ChangelogNormalize - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/02/28 17:32:00 UTC, 0 replies.