You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-36984) Support precision of SQL FLOOR and CEIL functions for TimeStampLtz - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2025/01/01 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36985) remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2025/01/01 09:20:00 UTC, 0 replies.
- 申请退订邮件 - posted by 越张 <zh...@silvrr.com> on 2025/01/02 01:50:33 UTC, 0 replies.
- Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables - posted by Shengkai Fang <fs...@gmail.com> on 2025/01/02 02:51:07 UTC, 2 replies.
- Re:Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment - posted by Xuyang <xy...@163.com> on 2025/01/02 03:07:55 UTC, 2 replies.
- Re: Dynamic Iceberg Sink - posted by Anil Dasari <da...@myyahoo.com.INVALID> on 2025/01/02 03:45:22 UTC, 0 replies.
- [jira] [Created] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/01/02 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36987) Mismatched docs with current active ES table connector - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2025/01/02 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/01/02 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36989) Scheduler benchmark regression since Dec.25th - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/02 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36990) SchemaRegistry fails on failover due to NPE exception caught while executing runnable in main thread - posted by "zjjiang (Jira)" <ji...@apache.org> on 2025/01/02 07:32:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-492: Support Query Modifications for Materialized Tables - posted by Feng Jin <ji...@gmail.com> on 2025/01/02 07:58:41 UTC, 0 replies.
- [jira] [Created] (FLINK-36991) NPE in BinarySegmentUtils - posted by "Adam Domański (Jira)" <ji...@apache.org> on 2025/01/02 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36992) Migrate SplitAggregateRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/01/02 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36993) FLIP-492: Support Query Modifications for Materialized Tables - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/02 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36994) Support Alter Materialized Table As Query - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/02 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36995) Support REPLACE MATERIALIZED TABLE AS statement - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/02 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/01/02 15:50: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/01/02 17:15:54 UTC, 2 replies.
- [jira] [Created] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2025/01/02 19:13:00 UTC, 0 replies.
- [DISCUSS] FLIP-498: AsyncTableFunction for async table function support - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2025/01/02 19:47:30 UTC, 7 replies.
- Re: Log4j JSONTemplateLayout - posted by Ryan van Huuksloot <ry...@shopify.com.INVALID> on 2025/01/02 20:15:13 UTC, 0 replies.
- Extend Flink jdbc Trino supported types - posted by Christopher Teoh <te...@hotmail.com> on 2025/01/02 22:21:10 UTC, 0 replies.
- [DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed - posted by Xuyang <xy...@163.com> on 2025/01/03 04:06:38 UTC, 5 replies.
- [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 - posted by Xu Huang <hu...@gmail.com> on 2025/01/03 05:05:50 UTC, 7 replies.
- [jira] [Created] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or be restored - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/03 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36999) Null pointer exception when the source field type is decimal and the value is null - posted by "林健昌 (Jira)" <ji...@apache.org> on 2025/01/03 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37000) MySQL CDC could not handle date and time data prior to unix epoch - posted by "yux (Jira)" <ji...@apache.org> on 2025/01/03 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/03 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37002) Migrate DecomposeGroupingSetsRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/01/03 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37003) Implement async state version of Datastream Interval join - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/03 13:22:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermarkin DataStream V2 - posted by 。。。 <hg...@qq.com.INVALID> on 2025/01/03 15:29:29 UTC, 0 replies.
- Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions - posted by Robert Metzger <rm...@apache.org> on 2025/01/03 15:45:01 UTC, 3 replies.
- [jira] [Created] (FLINK-37004) Implement Multithreaded SourceReader - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/01/03 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/01/03 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37006) Apply changes from FLINK-36277 to AdaptiveJoin - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/01/03 23:08:00 UTC, 0 replies.
- [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/04 03:49:43 UTC, 8 replies.
- [RESULT][VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/01/05 18:31:48 UTC, 0 replies.
- [jira] [Created] (FLINK-37007) FLIP-494: Add missing createTable/createView methods to TableEnvironment - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/01/05 18:34:00 UTC, 0 replies.
- Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? - posted by Matthias Pohl <ma...@apache.org> on 2025/01/05 18:41:11 UTC, 10 replies.
- [jira] [Created] (FLINK-37008) Flink UI should show the type of checkpoint (full vs incremental) - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2025/01/06 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37009) Migrate PruneAggregateCallRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/01/06 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37010) Unify KeyedProcessFunction and the async one - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/06 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/01/06 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37012) Fix exception caused by MetadataColumns causing argument type mismatch - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/01/06 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37013) Job failed to restart on time - posted by "liting liu (Jira)" <ji...@apache.org> on 2025/01/06 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37014) Examples are wrong in materialized table statment doc - posted by "Mingcan Wang (Jira)" <ji...@apache.org> on 2025/01/06 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/01/06 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37016) NPE when ClusterEntrypoing is shut down before initialization - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2025/01/06 13:38:00 UTC, 0 replies.
- Re: Memory leak in pekko's Netty 4 transport. - posted by Alexander Fedulov <al...@gmail.com> on 2025/01/06 15:17:06 UTC, 4 replies.
- [jira] [Created] (FLINK-37017) Supports complex DataTypes in Flink CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/01/06 16:07:00 UTC, 0 replies.
- [VOTE] CHI: Stale PR cleanup - posted by Tom Cooper <co...@tomcooper.dev> on 2025/01/06 16:12:16 UTC, 13 replies.
- [DISCUSS] - Propagation of Startup Errors - posted by Luca Castelli <lu...@shopify.com.INVALID> on 2025/01/06 17:30:42 UTC, 0 replies.
- Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join - posted by Weiqing Yang <ya...@gmail.com> on 2025/01/06 21:11:40 UTC, 15 replies.
- [jira] [Created] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/01/06 22:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37019) Bump junit to 5.11 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/01/06 22:45:00 UTC, 0 replies.
- Re: Plans for JDBC connector for 1.20? - posted by Xingcan Cui <xi...@gmail.com> on 2025/01/06 22:52:28 UTC, 1 replies.
- Re: Blue/Green Deployments support for Flink - posted by Sergio Chong Loo <sc...@apple.com.INVALID> on 2025/01/07 02:23:29 UTC, 0 replies.
- Query Regarding encryption support in RocksDB - posted by MUKUL GUPTA <mu...@ericsson.com.INVALID> on 2025/01/07 05:34:13 UTC, 0 replies.
- Re: CHI: Automatic Stale PR Cleanup - posted by Rui Fan <19...@gmail.com> on 2025/01/07 06:13:35 UTC, 2 replies.
- [jira] [Created] (FLINK-37020) Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2025/01/07 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37021) Implement fast rescaling for ForStKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/01/07 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37022) When will flink cdc support jdk21? Is there a support plan for jdk21 in the community? - posted by "Hui Wang (Jira)" <ji...@apache.org> on 2025/01/07 07:57:00 UTC, 0 replies.
- [NOTICE] Flink 2.0 Release Sync 01/08/2025 - posted by Xintong Song <to...@gmail.com> on 2025/01/07 08:02:46 UTC, 0 replies.
- Elastic Scaling in Apache Flink and minimum parallelism - posted by Pavel Dmitriev <Pa...@sinc.de> on 2025/01/07 08:55:40 UTC, 1 replies.
- Re: Full Checkpoint information in UI and API - posted by Zakelly Lan <za...@gmail.com> on 2025/01/07 11:08:48 UTC, 2 replies.
- [jira] [Created] (FLINK-37023) JobManager rest API returns 500 error with CancellationException - posted by "amjidc (Jira)" <ji...@apache.org> on 2025/01/07 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/01/07 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37025) Periodic SQL watermarks can travel back in time - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/01/07 14:24:00 UTC, 0 replies.
- [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 - posted by Xu Huang <hu...@gmail.com> on 2025/01/07 14:49:33 UTC, 4 replies.
- [jira] [Created] (FLINK-37026) Enable Stale PR Github Action - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/01/07 15:54:00 UTC, 0 replies.
- [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/07 16:10:59 UTC, 4 replies.
- [jira] [Created] (FLINK-37027) Chinese document translation for additional TO_TIMESTAMP_LTZ() functions - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2025/01/07 19:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37028) Datastream Window operator with async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/08 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37029) Fix the materialized table docs of full mode cron expression - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/01/08 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37030) Support lazy initialization for state serializer in State V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/08 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37035) CLONE - [Release-1.20] Create a release branch - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37034) CLONE - [Release-1.20] Select executing Release Manager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37033) CLONE - [Release-1.20] Create a new version in JIRA - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37041) CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37038) CLONE - [Release-1.20] Cross team testing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37037) CLONE - [Release-1.20] Review Release Notes in JIRA - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37032) Prepare Flink 2.0 Release - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37036) CLONE - [Release-1.20] Prepare RC0 release - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/01/08 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37043) [Umbrella] Test Flink Release 2.0 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37044) Support connectors and formats as plugins - posted by "Karan Makhija (Jira)" <ji...@apache.org> on 2025/01/08 07:17:00 UTC, 0 replies.
- Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status - posted by Maximilian Michels <mx...@apache.org> on 2025/01/08 08:12:00 UTC, 4 replies.
- [jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/08 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format. - posted by "hzk (Jira)" <ji...@apache.org> on 2025/01/08 08:44:00 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 01/08/2025 - posted by Xintong Song <to...@gmail.com> on 2025/01/08 08:56:52 UTC, 0 replies.
- [jira] [Created] (FLINK-37047) Cross-team verification for "Remove DataSet API" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37051) Cross-team verification for FLINK-36369 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37052) Cross-team verification for FLINK-36245 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37053) Cross-team verification for FLINK-14068 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37054) Cross-team verification for FLINK-33750 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37056) Cross-team verification for FLINK-23620 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37058) Cross-team verification for FLINK-35573 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37059) Cross-team verification for FLINK-4602 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37060) Cross-team verification for FLIP-398 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37061) Cross-team verification for FLINK-32688 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37062) Cross-team verification for FLINK-36147 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37063) Cross-team verification for "Drop support for Java 8" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/08 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint - posted by "Ihor Mielientiev (Jira)" <ji...@apache.org> on 2025/01/08 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37066) Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/08 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37068) Cross-team verification for FLIP-473 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37069) Cross-team verification for "Disaggregated State Management" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37070) Cross-team verification for FLIP-461 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37072) Cross-team verification for FLIP-472 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37071) Cross-team verification for FLIP-398 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37074) Cross-team verification for FLINK-31362 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37075) Cross-team verification for FLINK-31836 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/01/08 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37076) Support PTF skeleton in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/01/08 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37077) CLONE - Upgrade Stateful Functions to Flink 1.16.1 - posted by "Oleksandr Kazimirov (Jira)" <ji...@apache.org> on 2025/01/08 12:12:00 UTC, 0 replies.
- Does Flink operator 1.1.0 support Flink 1.20? - posted by David Radley <da...@uk.ibm.com> on 2025/01/08 13:48:32 UTC, 2 replies.
- [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization - posted by Dawid Wysakowicz <dw...@apache.org> on 2025/01/08 15:27:43 UTC, 4 replies.
- [RESULT][VOTE] FLIP-493: Add K8S conditions to CRD's Status - posted by Lajith Koova <la...@gmail.com> on 2025/01/09 02:24:18 UTC, 0 replies.
- [jira] [Created] (FLINK-37078) Update jackson-mapper-asl dependency - posted by "Anupam Aggarwal (Jira)" <ji...@apache.org> on 2025/01/09 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37079) ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/09 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37080) Flink CDC Postgres when start with latest status in stream phase and add new table, it will be too slow - posted by "hql0312 (Jira)" <ji...@apache.org> on 2025/01/09 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher - posted by "zhang (Jira)" <ji...@apache.org> on 2025/01/09 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37082) Disable adaptive join optimization when enable batch job progress recovery - posted by "xingbe (Jira)" <ji...@apache.org> on 2025/01/09 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37083) SqlYARNApplicationITCase.testDeployScriptViaSqlClient failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/09 10:20:00 UTC, 0 replies.
- [VOTE] FLIP-496: SQL connector for keyed state data - posted by Gabor Somogyi <ga...@gmail.com> on 2025/01/09 12:57:11 UTC, 4 replies.
- [jira] [Created] (FLINK-37084) NullPointerException occurs during handling timer of window in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/01/09 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/10 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37086) State leaks for JBBC state store after job is stopped - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/01/10 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37087) Add docs for alter materialized table as query - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/01/10 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine - posted by "baimafeimayf (Jira)" <ji...@apache.org> on 2025/01/10 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37089) Advanced scheduling for derived async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/10 04:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37090) Introduce tpc-ds e2e case for adaptive broadcast join - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/01/10 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37091) Remove deprecated CatalogLock interface - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/01/10 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/01/10 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder - posted by "Mingcan Wang (Jira)" <ji...@apache.org> on 2025/01/10 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37094) Adapt the external Hive connector to the removal of deprecated APIs in table module in 2.0 - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/10 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37095) test case that used AI model may met quota not enough exception. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/10 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year - posted by "sukang (Jira)" <ji...@apache.org> on 2025/01/10 09:15:00 UTC, 0 replies.
- Flink v2 download name - posted by David Radley <da...@uk.ibm.com> on 2025/01/10 11:34:45 UTC, 0 replies.
- [jira] [Created] (FLINK-37097) Remove - posted by "david radley (Jira)" <ji...@apache.org> on 2025/01/10 11:45:00 UTC, 0 replies.
- PR introducing V1 and V2 state migration issue - posted by David Radley <da...@uk.ibm.com> on 2025/01/10 14:04:13 UTC, 1 replies.
- [jira] [Created] (FLINK-37098) Can not select time attribute from a view - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/01/10 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37099) Document possible Netty4 configurations to setup Pekko properly in JDK11+ - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/10 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37100) Fix test_netty_shuffle_memory_control.sh in CI for JDK11+ - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/10 14:23:00 UTC, 0 replies.
- Community Health Initiative (CHI) 9th of January minutes - posted by David Radley <da...@uk.ibm.com> on 2025/01/10 16:40:39 UTC, 1 replies.
- [RESULT][VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 - posted by Xu Huang <hu...@gmail.com> on 2025/01/11 09:53:51 UTC, 0 replies.
- [jira] [Created] (FLINK-37101) Remove internal set methods in SerializerConfig - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/01/11 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37102) ClassNotFoundException for ParquetColumnarRowInputFormat - posted by "Krish Narukulla (Jira)" <ji...@apache.org> on 2025/01/11 20:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. - posted by "zhuanshenbsj1 (Jira)" <ji...@apache.org> on 2025/01/12 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/01/13 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37105) Shade Apache Calcite in Flink CDC - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/01/13 02:24:00 UTC, 0 replies.
- [VOTE] FLIP-501: Support Window Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/13 06:36:52 UTC, 4 replies.
- [VOTE] FLIP-500: Support Join Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/13 06:55:22 UTC, 5 replies.
- [jira] [Created] (FLINK-37106) Consider extracting common methods in WindowJoinOperator - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/13 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37107) Allow buffer overdraft in async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/13 10:49:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-496: SQL connector for keyed state data - posted by Gabor Somogyi <ga...@gmail.com> on 2025/01/13 12:01:12 UTC, 1 replies.
- [jira] [Created] (FLINK-37108) Source/Sink test suites test invalid recovery - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/01/13 13:22:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation - posted by Timo Walther <tw...@apache.org> on 2025/01/13 14:42:22 UTC, 4 replies.
- [DISCUSSION] flink-connector-hive first release of externalized connector - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/01/13 22:15:33 UTC, 9 replies.
- [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) - posted by Sergio Chong Loo <sc...@apple.com.INVALID> on 2025/01/13 22:39:20 UTC, 3 replies.
- [jira] [Created] (FLINK-37109) Increase state processor API performance when reading keyed rocksdb state - posted by "Gary Lam (Jira)" <ji...@apache.org> on 2025/01/13 22:55:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (with Coordination) - posted by Sergio Chong Loo <sc...@apple.com.INVALID> on 2025/01/13 23:16:21 UTC, 1 replies.
- [jira] [Created] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. - posted by "林健昌 (Jira)" <ji...@apache.org> on 2025/01/14 01:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37111) Allow setting `sink.version` for StarRocks Pipeline connector - posted by "yux (Jira)" <ji...@apache.org> on 2025/01/14 02:52:00 UTC, 0 replies.
- 退订 - posted by 张洋 <28...@qq.com.INVALID> on 2025/01/14 02:53:56 UTC, 4 replies.
- [jira] [Created] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/01/14 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37113) Introduce document for datastream api v2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/14 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow - posted by "hql0312 (Jira)" <ji...@apache.org> on 2025/01/14 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/14 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2025/01/14 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37117) Add docs for async state SQL operator in 2.0 - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/14 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37118) Enhance flink cdc metrics - posted by "melin (Jira)" <ji...@apache.org> on 2025/01/14 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/14 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/01/14 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37121) Fix syntax and examples in create table statement doc - posted by "Mingcan Wang (Jira)" <ji...@apache.org> on 2025/01/14 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/01/14 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37123) FlinkCDC YAML supports TIMESTAMP_TZ - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/01/14 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/01/14 16:20:00 UTC, 0 replies.
- Stale PR Action running but the labels are missing - posted by Tom Cooper <co...@tomcooper.dev> on 2025/01/14 17:22:43 UTC, 9 replies.
- [jira] [Created] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "sehaj pal singh sandhu (Jira)" <ji...@apache.org> on 2025/01/14 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37126) Add Validator for Autoscler - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/01/15 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/15 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37128) Skip binlog replay filter when skip backfill - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/01/15 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37129) AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/15 02:49:00 UTC, 0 replies.
- Re: StreamingFilSink with FlinkRunner - posted by Taher Koitawala <ta...@gmail.com> on 2025/01/15 03:08:41 UTC, 1 replies.
- [jira] [Created] (FLINK-37130) Provide a util converting future of StateIterator to Iterable - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/15 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37131) checkpoint tolerable-failed invalid - posted by "altenchen (Jira)" <ji...@apache.org> on 2025/01/15 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37132) Add schema validation in Multi Transform - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/01/15 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37133) Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/15 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37134) Cross-team verification for FLIP-492 - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/15 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37135) FLIP-500: Support Join Extension in DataStream V2 API - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/01/15 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/01/15 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37137) testGenerateStreamGraphJson failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/15 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37138) testDeployScriptViaSqlClient failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/15 09:16:00 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 01/15/2025 - posted by Xintong Song <to...@gmail.com> on 2025/01/15 09:16:09 UTC, 0 replies.
- [jira] [Created] (FLINK-37139) Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2025/01/15 09:23:00 UTC, 0 replies.
- [NOTICE] Release 2.0 Feature Freeze on Jan 20 - posted by Xintong Song <to...@gmail.com> on 2025/01/15 09:24:21 UTC, 0 replies.
- [jira] [Created] (FLINK-37140) Create InternalTimerServiceAsyncImpl when restore async operator - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/01/15 11:20:00 UTC, 0 replies.
- [ANNOUNCE] Flink master branch default JDK changed to JDK 17 - posted by Martijn Visser <ma...@apache.org> on 2025/01/15 11:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-37141) The version of the Flink Operator in operatorhub.io is old 1.6.0 - posted by "Hector Miuler Malpica Gallegos (Jira)" <ji...@apache.org> on 2025/01/16 00:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37142) Update version of flink-connector-kafka to 4.0-SNAPSHOT - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/16 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37143) Update version of flink-connector-kafka to 4.0-SNAPSHOT - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/16 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37144) Update flink-connector-kafka version to 3.4-SNAPSHOT - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/16 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37145) testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/16 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37146) Prometheus Push Gateway not work on 1.18.1 - posted by "Naijie Liu (Jira)" <ji...@apache.org> on 2025/01/16 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37147) The where condition run time advance caused a program error - posted by "lixu (Jira)" <ji...@apache.org> on 2025/01/16 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37148) Add documentation for datastream v2 api - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/16 07:08:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-500: Support Join Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/16 07:11:29 UTC, 0 replies.
- [RESULT][VOTE] FLIP-501: Support Window Extension in DataStream V2 API - posted by Xu Huang <hu...@gmail.com> on 2025/01/16 07:12:50 UTC, 0 replies.
- [jira] [Created] (FLINK-37149) Add Adaptive Batch Execution Documentation - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/01/16 09:10:00 UTC, 0 replies.
- [jira] [Created] (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/01/16 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37151) Remove reduandant testing dependencies of Flink UI - posted by "Ao Yuchen (Jira)" <ji...@apache.org> on 2025/01/16 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37152) Update Flink version to 1.20 in Flink CDC - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/16 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37153) Monitor late event count in temporal join - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2025/01/16 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37154) Support reading binary data from Kafka - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/01/16 12:53:00 UTC, 0 replies.
- Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) - posted by Alexander Fedulov <al...@gmail.com> on 2025/01/16 15:12:40 UTC, 22 replies.
- [jira] [Created] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by "Allison Chang (Jira)" <ji...@apache.org> on 2025/01/16 22:11:00 UTC, 0 replies.
- [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by Allison <ac...@gmail.com> on 2025/01/17 00:06:46 UTC, 5 replies.
- [jira] [Created] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks. - posted by "cheng qian (Jira)" <ji...@apache.org> on 2025/01/17 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37157) Enable daily benchmark for Java 21 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/17 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/01/17 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/17 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/01/17 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/01/17 06:18:00 UTC, 0 replies.
- [DISCUSS] Release Flink CDC version 3.3.0 - posted by Hang Ruan <ru...@apache.org> on 2025/01/17 07:38:15 UTC, 2 replies.
- [jira] [Created] (FLINK-37162) Add Data Sources Documentation - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/17 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/17 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/17 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37165) The starrocks connector is found to be missing some options. - posted by "sukang (Jira)" <ji...@apache.org> on 2025/01/17 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37167) Fix operand reordering in SqlValidatorImpl for tableCharacteristics - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/01/17 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37166) FlinkConfigManager version prefix logic not safe - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/01/17 12:56:00 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 - posted by Hang Ruan <ru...@apache.org> on 2025/01/18 07:25:21 UTC, 5 replies.
- [jira] [Created] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/01/19 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37169) Broken links to connector JARs in documentation - posted by "xxchan (Jira)" <ji...@apache.org> on 2025/01/19 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37170) Disable 1.18 CI - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/01/19 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/20 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/20 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37173) Failed to pass license check in JDK11 build - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/20 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37174) SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed - posted by "xuyang (Jira)" <ji...@apache.org> on 2025/01/20 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37175) Support JSON built-in function for JSON_OBJECT - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/01/20 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37176) setup_hugo.sh doesn't work on macbook - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/01/20 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37177) Update chinese documentation of json function - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/01/20 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/01/20 14:11:00 UTC, 0 replies.
- [ANNOUNCE] Flink 2.0 feature freeze - posted by Xintong Song <to...@gmail.com> on 2025/01/20 14:57:39 UTC, 0 replies.
- [jira] [Created] (FLINK-37179) [ArgoCD] App Out Of sync after update to v1.6.0 - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2025/01/20 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37180) Implement StreamOperator for PTF - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/01/20 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/01/20 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes. - posted by "Ao Li (Jira)" <ji...@apache.org> on 2025/01/20 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37183) Usrlib symlinks are not followed - posted by "Joery (Jira)" <ji...@apache.org> on 2025/01/20 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37184) Support ZStandard compressed input in new File API - posted by "Joery (Jira)" <ji...@apache.org> on 2025/01/20 18:19:00 UTC, 0 replies.
- [KINDELY REMINDER] Flink 2.0 Release Sync 01/22/2025 - posted by Xintong Song <to...@gmail.com> on 2025/01/21 01:32:29 UTC, 0 replies.
- [jira] [Created] (FLINK-37185) NoClassDefFoundError raised from ORC tests - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/21 02:36:00 UTC, 0 replies.
- [jira] [Created] (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/01/21 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2025/01/21 07:26:00 UTC, 0 replies.
- [jira] [Created] (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/01/21 07:30:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 - posted by Hang Ruan <ru...@apache.org> on 2025/01/21 07:44:24 UTC, 0 replies.
- [jira] [Created] (FLINK-37189) Incorrect version string of maven-enforcer-plugin requireJavaVersion - posted by "xuhuang (Jira)" <ji...@apache.org> on 2025/01/21 08:02:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink CDC 3.3.0 released - posted by Hang Ruan <ru...@apache.org> on 2025/01/21 09:48:12 UTC, 1 replies.
- [jira] [Created] (FLINK-37190) Make Kudu `FlushMode` configurable in Flink SQL - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/21 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/01/21 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37192) [pyflink] Replace deprecated avro-python3 with avro - posted by "Mina Asham (Jira)" <ji...@apache.org> on 2025/01/21 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37193) Ingress recreated after perform a change to CRD - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2025/01/21 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/22 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37195) TimestampAdd / TimestampDiff series function not available in cluster - posted by "yux (Jira)" <ji...@apache.org> on 2025/01/22 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37196) Build documentation github action can't work - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/01/22 06:38:00 UTC, 0 replies.
- [ANNOUNCE] Release 2.0.0, release candidate #0 - posted by Xintong Song <to...@gmail.com> on 2025/01/22 07:15:43 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 01/22/2015 - posted by Xintong Song <to...@gmail.com> on 2025/01/22 07:27:11 UTC, 0 replies.
- [Discuss] Flink CDC 3.4 Kick Off - posted by Yanquan Lv <de...@gmail.com> on 2025/01/22 07:33:38 UTC, 3 replies.
- [jira] [Created] (FLINK-37197) Release flink-connector-mongodb v2.0.0 for Flink 1.20 - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2025/01/22 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37198) AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row. - posted by "Juliusz Nadberezny (Jira)" <ji...@apache.org> on 2025/01/22 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/22 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37200) Add e2e test for ElasticSearch Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/22 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/01/22 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37202) Introduce TDengine connector - posted by "kevinmen (Jira)" <ji...@apache.org> on 2025/01/22 12:33:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/22 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37204) Add missing StarRocks connector options for 1.2.10. - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2025/01/23 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37205) Correct the state cache behavior during bump beam version - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/01/23 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37206) Initialization issue of batching timer service in async state operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/23 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37207) Distributed cache set in the DataStream API does not work if a job use both the Table API & DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/01/23 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37208) Properly notify a new key is selected for async state operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/23 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37209) Add Embedding AI Model for Qwen - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/23 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37210) Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/23 09:29:00 UTC, 0 replies.
- [VOTE] FLIP-502: QueryOperation SQL Serialization customization - posted by Dawid Wysakowicz <wy...@gmail.com> on 2025/01/23 10:56:06 UTC, 4 replies.
- [jira] [Created] (FLINK-37211) Fix field resolution for PARTITION BY/ORDER BY - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/01/23 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37212) hbase connector "Unable to load exception received from server:org.apache.hadoop.hbase.NotServingRegionException" - posted by "jonasjc (Jira)" <ji...@apache.org> on 2025/01/23 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37213) Improve performance of unbounded OVER aggregations - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/01/23 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37214) Migrate TaskSlotTableImplTest from using the test thread as the main thread - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/01/23 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37215) SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/01/23 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37216) Default MAX_BATCH_SIZE_IN_BYTES is less than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions - posted by "qinghuan wang (Jira)" <ji...@apache.org> on 2025/01/23 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37217) In `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2025/01/24 02:55:00 UTC, 0 replies.
- [jira] [Created] (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/01/24 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37219) Support value state in PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/01/24 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/01/24 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator - posted by "Ben Brandt (Jira)" <ji...@apache.org> on 2025/01/24 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37222) Table planner exception when sql client submit job - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/24 17:03:00 UTC, 0 replies.
- Minutes for 8th Community Health Initiative (CHI) Western time zone. - posted by David Radley <da...@uk.ibm.com> on 2025/01/24 17:40:42 UTC, 0 replies.
- [jira] [Created] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/25 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/25 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37225) Remove remaining test resources of Gelly - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/01/26 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2025/01/26 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2025/01/26 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20 - posted by "sigalit (Jira)" <ji...@apache.org> on 2025/01/26 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37229) Add DELETING/DELETED lifecycle states - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/01/27 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37230) Consolidate Kudu connector table options - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/27 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37231) Add doc for newly added source metric statistics - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/27 18:35:00 UTC, 0 replies.
- [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by Weiqing Yang <ya...@gmail.com> on 2025/01/27 22:04:51 UTC, 2 replies.
- [VOTE] FLIP-498: AsyncTableFunction for async table function support - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2025/01/27 23:01:41 UTC, 5 replies.
- [jira] [Created] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2025/01/28 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37233) Flink-CDC Documentation change request - posted by "911432 (Jira)" <ji...@apache.org> on 2025/01/28 13:07:00 UTC, 0 replies.
- [VOTE] Release 1.19.2, release candidate #1 - posted by Alexander Fedulov <al...@gmail.com> on 2025/01/28 17:29:21 UTC, 2 replies.
- [jira] [Created] (FLINK-37234) Add timeout for test case to avoid Infinite waiting - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/29 00:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/01/29 01:05:00 UTC, 0 replies.
- [VOTE] Release 1.20.1, release candidate #1 - posted by Alexander Fedulov <al...@gmail.com> on 2025/01/29 12:32:12 UTC, 2 replies.
- [jira] [Created] (FLINK-37236) Make Flink operator compatible with 2.0 preview - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/01/29 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37237) Enforce SQL PRIMARY KEY definition for Kudu tables and remove table option - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/01/29 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/01/30 00:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37239) Improve documentation for multiple built-in functions - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/01/30 08:39:00 UTC, 0 replies.
- Minutes for 9th Community Health Initiative (CHI) Eastern time zone. - posted by David Radley <da...@uk.ibm.com> on 2025/01/30 12:52:08 UTC, 0 replies.
- [jira] [Created] (FLINK-37240) Changing column nullability throws StateMigrationException in a SQL pipeline with a JOIN - posted by "Eric Xiao (Jira)" <ji...@apache.org> on 2025/01/30 21:38:00 UTC, 0 replies.
- Flink Operator 1.11 release planning - posted by Gyula Fóra <gy...@gmail.com> on 2025/01/31 09:27:43 UTC, 2 replies.
- [jira] [Created] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/01/31 12:18:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-498: AsyncTableFunction for async table function support - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2025/01/31 18:24:24 UTC, 0 replies.
- [jira] [Created] (FLINK-37242) Enable setting custom labels for flink-operator-webhook-service - posted by "thanh tung dao (Jira)" <ji...@apache.org> on 2025/01/31 21:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37243) Ensure that async callbacks happen on known thread - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/01/31 22:06:00 UTC, 0 replies.