You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API - posted by Leonard Xu <xb...@gmail.com> on 2025/08/01 02:04:21 UTC, 3 replies.
- Re: [VOTE] FLIP-529: Connections in Flink SQL and TableAPI - posted by Leonard Xu <xb...@gmail.com> on 2025/08/01 02:06:02 UTC, 3 replies.
- [DISCUSS] Planning Flink 2.2 - posted by Hang Ruan <ru...@apache.org> on 2025/08/01 02:07:59 UTC, 9 replies.
- Re: [DISCUSS] State Schema Evolution for RowData - posted by Weiqing Yang <ya...@gmail.com> on 2025/08/01 05:05:15 UTC, 1 replies.
- Re: [ANNOUNCE] Apache Flink 2.1.0 released - posted by xiangyu feng <xi...@gmail.com> on 2025/08/01 05:18:40 UTC, 2 replies.
- Re: Re: [DISCUSS] Add UDF Metrics - posted by Weiqing Yang <ya...@gmail.com> on 2025/08/01 05:26:13 UTC, 6 replies.
- [jira] [Created] (FLINK-38178) [RISC-V Support] - Comprehensive Tracking of RISC-V Architecture Support in Apache Flink - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support - posted by "Gong Xiaofei (Jira)" <ji...@apache.org> on 2025/08/01 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/08/01 08:04:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by Gustavo de Morais <gu...@gmail.com> on 2025/08/01 09:00:50 UTC, 1 replies.
- Re: [RESULT] [VOTE] Release 2.1.0, release candidate #1 - posted by Maximilian Michels <mx...@apache.org> on 2025/08/01 09:45:34 UTC, 0 replies.
- [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by Dawid Wysakowicz <dw...@apache.org> on 2025/08/01 14:17:53 UTC, 7 replies.
- [jira] [Created] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/08/01 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38182) lastCheckpointDuration is not right. - posted by "richard_zhulh (Jira)" <ji...@apache.org> on 2025/08/02 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2025/08/03 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/04 03:09:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source - posted by Zexian WU <wz...@gmail.com> on 2025/08/04 06:34:24 UTC, 10 replies.
- Update `flink-connector-hive` for 2.0 and 2.1 version - posted by Xiaolong Wang <xi...@smartnews.com.INVALID> on 2025/08/04 07:01:23 UTC, 4 replies.
- [jira] [Created] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38186) Failed case: NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/04 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38187) Add metrics to KuduSource - posted by "Marton Greber (Jira)" <ji...@apache.org> on 2025/08/04 19:36:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment - posted by Hongshun Wang <lo...@gmail.com> on 2025/08/05 03:39:05 UTC, 6 replies.
- [jira] [Created] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/05 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38190) Support async function in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/05 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38191) [Document] Add document for Fluss pipeline connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/05 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38192) Improve DynamicSourceUtils exception msg - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2025/08/05 11:23:00 UTC, 0 replies.
- Re: Updating HBase connector - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2025/08/05 14:36:59 UTC, 1 replies.
- [jira] [Created] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/05 15:01:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI - posted by Hao Li <hl...@confluent.io.INVALID> on 2025/08/05 17:21:25 UTC, 2 replies.
- 回复：[RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI - posted by 魏宪党 <12...@qq.com.INVALID> on 2025/08/06 01:08:43 UTC, 0 replies.
- [jira] [Created] (FLINK-38194) Iceberg connector supports auto-creating namespace - posted by "ZhangChao (Jira)" <ji...@apache.org> on 2025/08/06 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38195) Some markdown syntax errors in tableApi page - posted by "cuiyanxiang (Jira)" <ji...@apache.org> on 2025/08/06 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/06 05:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38197) Data Errors Caused by Default Added Columns at End Position - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/08/06 06:26:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by Dawid Wysakowicz <wy...@gmail.com> on 2025/08/06 06:30:03 UTC, 0 replies.
- [jira] [Created] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/06 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38199) Add a benchmark for SinkUpsertMaterializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/08/06 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 11:09:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 - posted by Arvid Heise <ar...@apache.org> on 2025/08/06 13:20:43 UTC, 11 replies.
- [jira] [Created] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/06 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/06 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38203) Failed case: FlussPipelineITCase.testInsertExistTableWithMoreColumns - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38205) Discard unknown fields for Protobuf format - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/08/07 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/07 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/07 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/07 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/07 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2025/08/07 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38213) Failed - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/08 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/08/08 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/08 06:43:00 UTC, 0 replies.
- [KINDLY REMINDER] Flink CDC 3.5.0 Feature Freeze - posted by Yanquan Lv <de...@gmail.com> on 2025/08/08 08:44:26 UTC, 1 replies.
- [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/08 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/08/08 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/08 18:04:00 UTC, 0 replies.
- Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project - posted by João Boto <es...@apache.org> on 2025/08/08 18:25:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history - posted by Matthias Pohl <ma...@apache.org> on 2025/08/10 15:54:37 UTC, 6 replies.
- [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/10 21:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/10 21:14:00 UTC, 0 replies.
- 退订 - posted by 赵一帆 <jf...@gmail.com> on 2025/08/11 03:24:25 UTC, 1 replies.
- [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer - posted by Yuepeng Pan <pa...@apache.org> on 2025/08/11 03:49:27 UTC, 16 replies.
- [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names - posted by "tchivs (Jira)" <ji...@apache.org> on 2025/08/11 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/08/11 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/11 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/08/11 11:06:00 UTC, 0 replies.
- Re: Flink Connector Kafka Releases - posted by Tom Cooper <co...@tomcooper.dev> on 2025/08/11 14:40:46 UTC, 5 replies.
- [jira] [Created] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable - posted by "Xi Zhang (Jira)" <ji...@apache.org> on 2025/08/11 22:18:00 UTC, 0 replies.
- [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/08/12 03:30:00 UTC, 8 replies.
- Proposal: Add failOnError option in KafkaSinkBuilder to suppress job restarts when DeliveryGuarantee.NONE is used - posted by Ejaskhan S <ia...@gmail.com> on 2025/08/12 04:08:56 UTC, 5 replies.
- [jira] [Created] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavio - posted by "Ejaskhan (Jira)" <ji...@apache.org> on 2025/08/12 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38227) Flink-CDC Postgres with Incremental Change does not work - posted by "Harish Sharma (Jira)" <ji...@apache.org> on 2025/08/12 04:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/08/12 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/08/12 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/08/12 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss - posted by "suhwan (Jira)" <ji...@apache.org> on 2025/08/12 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/08/12 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC - posted by "Max Feng (Jira)" <ji...@apache.org> on 2025/08/12 20:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field - posted by "Fabrizzio Chavez (Jira)" <ji...@apache.org> on 2025/08/12 22:39:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Ron Liu - posted by Lincoln Lee <li...@gmail.com> on 2025/08/13 02:40:59 UTC, 23 replies.
- [jira] [Created] (FLINK-38237) MongoDB CDC - row_kind virtual column is returning incorrect operation Type - posted by "Fabrizzio Chavez (Jira)" <ji...@apache.org> on 2025/08/13 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38238) Failed to process MySQL table with varchar(0) column - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/13 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI - posted by "yuan (Jira)" <ji...@apache.org> on 2025/08/13 09:08:00 UTC, 0 replies.
- Backport label - posted by David Radley <da...@uk.ibm.com> on 2025/08/13 15:32:57 UTC, 0 replies.
- Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL - posted by Shengkai Fang <fs...@gmail.com> on 2025/08/14 01:31:26 UTC, 6 replies.
- [jira] [Created] (FLINK-38240) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/08/14 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2025/08/14 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38244) When the table name of mysql supports size sensitive, fix the error that column name not being found - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/14 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/14 06:01:00 UTC, 0 replies.
- 2025/08/14 CHI Eastern time zone workgroup meeting minutes - posted by David Radley <da...@uk.ibm.com> on 2025/08/14 09:11:59 UTC, 0 replies.
- Clarification question on stateful upgrades and evolutlion - posted by David Radley <da...@uk.ibm.com> on 2025/08/14 10:03:15 UTC, 0 replies.
- [jira] [Created] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/14 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38246) Remove unreachable code in CodeGenUtils - posted by "morvenhuang (Jira)" <ji...@apache.org> on 2025/08/14 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/14 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/14 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38249) Flink CDC should let users configure Debezium’s 'skipped.operations' parameter to filter out unwanted binlog operations. - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2025/08/15 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38250) The Flink CDC type supports the timeTZ field type. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/15 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38251) Fix recompilation of restore tests for MultiJoinTestPrograms - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/15 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/08/15 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes - posted by "Jakub Stejskal (Jira)" <ji...@apache.org> on 2025/08/15 11:40:00 UTC, 0 replies.
- [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/08/15 13:42:26 UTC, 9 replies.
- [jira] [Created] (FLINK-38254) Hidding sensitive information - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/16 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38255) Add ITCase to verify sensitive table option redaction - posted by "Yang Li (Jira)" <ji...@apache.org> on 2025/08/18 01:53:00 UTC, 0 replies.
- [VOTE] FLIP-485: Add UDF Metrics - posted by Weiqing Yang <ya...@gmail.com> on 2025/08/18 06:30:59 UTC, 2 replies.
- Re: [DISCUSS] FLIP-542: Make materialized table DDL consistent with regular tables - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/08/18 09:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/08/18 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38257) Add module dynamic function loading possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/08/18 10:50:00 UTC, 0 replies.
- Re:[DISCUSS] FLIP-538: Support Custom Generic Type Serializer - posted by Yuepeng Pan <pa...@apache.org> on 2025/08/18 10:58:42 UTC, 0 replies.
- [DISCUSS] Add SQL module dynamic function loading possibility - posted by Gabor Somogyi <ga...@gmail.com> on 2025/08/18 11:23:06 UTC, 3 replies.
- [jira] [Created] (FLINK-38258) Enable model param for PTF - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38260) Connection sql syntax - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38261) Connection catalog object and manager changes - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38262) Convert connection sqlnode to operations - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38264) Connection table api - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38263) Connection and secret factory - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/08/18 20:34:00 UTC, 0 replies.
- [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL - posted by Shengkai Fang <fs...@gmail.com> on 2025/08/19 06:20:18 UTC, 10 replies.
- [jira] [Created] (FLINK-38265) Stream Split shouldn't finish when exception occors - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/08/19 06:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core - posted by Kartikey Pant <ka...@gmail.com> on 2025/08/19 06:56:36 UTC, 3 replies.
- [jira] [Created] (FLINK-38266) SQL Gateway - mask sensitive table and catalog options - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2025/08/19 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/08/19 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/08/19 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38269) Make Job Manager's REST endpoint advertised address configurable - posted by "Yaroslav (Jira)" <ji...@apache.org> on 2025/08/19 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/08/20 00:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/20 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/08/20 03:32:00 UTC, 0 replies.
- [SUMMARY] Flink 2.2 Release Sync 08/20/2025 - posted by Hang Ruan <ru...@apache.org> on 2025/08/20 07:43:42 UTC, 0 replies.
- [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) - posted by Zander Matheson <a....@gmail.com> on 2025/08/20 17:11:41 UTC, 11 replies.
- [VOTE] FLIP-535: Introduce RateLimiter to Source - posted by Zexian WU <wz...@gmail.com> on 2025/08/21 03:15:48 UTC, 3 replies.
- [jira] [Created] (FLINK-38273) Flink SQL Client Embedded Mode Configuration Regression in 1.19 - Connection fails when rest.bind-port is configured - posted by "shml (Jira)" <ji...@apache.org> on 2025/08/21 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38274) Improve kubernetes operator config options for better yaml structure - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/08/21 13:16:00 UTC, 0 replies.
- [Discuss] Improving Autoscaler Behavior for Jobs with Large Number of Tasks - posted by Sharath <ds...@gmail.com> on 2025/08/21 23:00:15 UTC, 0 replies.
- [jira] [Created] (FLINK-38275) Doris Pipeline Sink cannot create a table when the upstream has no primary key and the first column is String - posted by "Di Wu (Jira)" <ji...@apache.org> on 2025/08/22 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38276) PaimonWriter does not invalidate cache when schema changes - posted by "yangyu (Jira)" <ji...@apache.org> on 2025/08/22 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38277) Enhance postgresSQL slot management capabilities - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 06:19:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL - posted by Shengkai Fang <fs...@gmail.com> on 2025/08/22 09:59:24 UTC, 0 replies.
- [jira] [Created] (FLINK-38278) PostgresSQL supported array field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/08/22 10:20:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-kafka 4.0.1 release - posted by Fabian Paul <fp...@apache.org> on 2025/08/22 12:17:22 UTC, 0 replies.
- [jira] [Created] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/08/23 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/08/24 05:22:00 UTC, 0 replies.
- [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override - posted by Diljeet Singh <ct...@icloud.com.INVALID> on 2025/08/24 13:02:38 UTC, 4 replies.
- [jira] [Created] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled - posted by "TemiChan (Jira)" <ji...@apache.org> on 2025/08/25 02:16:00 UTC, 0 replies.
- [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm - posted by Peter Huang <hu...@gmail.com> on 2025/08/25 14:52:46 UTC, 16 replies.
- [jira] [Created] (FLINK-38282) K8S operator : S3 jarURI - posted by "raphaelauv (Jira)" <ji...@apache.org> on 2025/08/25 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38283) Support customized autoscaling algorithm - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/08/25 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility - posted by "Jaehyun Kim (Jira)" <ji...@apache.org> on 2025/08/26 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38285) Allow to overrride config options with environment variables - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/26 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/08/26 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2025/08/26 13:45:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) - posted by Zander Matheson <a....@gmail.com> on 2025/08/26 16:35:56 UTC, 0 replies.
- [jira] [Created] (FLINK-38288) Improve BlobWriter logging to include TaskRestore offloading duration - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/08/26 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/08/27 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM restarts - posted by "Urs Schoenenberger (Jira)" <ji...@apache.org> on 2025/08/27 19:57:00 UTC, 0 replies.
- [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 - posted by Roman Khachatryan <ro...@apache.org> on 2025/08/27 23:10:25 UTC, 4 replies.
- [DISCUSS] FLIP-430: Remote Compaction For Disaggregated State - posted by Han Yin <al...@gmail.com> on 2025/08/28 04:24:29 UTC, 1 replies.
- [jira] [Created] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/08/28 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38292) Flink CDC doesn't support altering table properties for Paimon Sinks - posted by "Muhammad (Jira)" <ji...@apache.org> on 2025/08/28 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/08/28 13:53:00 UTC, 0 replies.
- [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/08/28 17:30:27 UTC, 3 replies.
- 2025/08/28 CHI Eastern time zone workgroup meeting minutes - posted by David Radley <da...@uk.ibm.com> on 2025/08/28 18:40:38 UTC, 0 replies.
- [jira] [Created] (FLINK-38294) Hbase connector misclassifies failed task as successful - posted by "Chu Xue (Jira)" <ji...@apache.org> on 2025/08/29 05:46:00 UTC, 0 replies.
- http connector Jira component required - posted by David Radley <da...@uk.ibm.com> on 2025/08/29 10:16:32 UTC, 0 replies.
- Slack invite - posted by David Geraghty <da...@bbc.co.uk.INVALID> on 2025/08/29 12:29:59 UTC, 0 replies.
- [jira] [Created] (FLINK-38295) Amend parent connector pom version to 1.1.0 - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38296) Do documentation - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38298) Remove mockito dependancy so we do not need to exclude from banned checklist - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38297) wiremock version is very old - migrate to a later level - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38300) work out Flink v2 support (should work) - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38299) amend push github action to go against v1 snapsort - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38301) confirm Maven snapshot is working - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38302) change the config to use Flink config parameter names and gid fallback keys - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38303) default to use query-creator generic-json-url - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38304) Re write README - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38305) amend the prefix to not include gid and move to Flink - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38306) knit in the http connector docs into the Flink docs - posted by "david radley (Jira)" <ji...@apache.org> on 2025/08/29 15:24:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Make JAR keyword optional in CREATE FUNCTION's USING clause - posted by Zander Matheson <a....@gmail.com> on 2025/08/29 16:55:09 UTC, 0 replies.
- [jira] [Created] (FLINK-38307) Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend - posted by "Naci Simsek (Jira)" <ji...@apache.org> on 2025/08/30 12:11:00 UTC, 0 replies.
- Kafka 4.x Queue Semantics in Flink Connector Kafka - posted by RShekhar Prasad <rs...@gmail.com> on 2025/08/30 17:30:29 UTC, 0 replies.