You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [VOTE] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by gongzhongqiang <go...@apache.org> on 2024/04/01 01:23:51 UTC, 2 replies.
- Re: Bug report for reading Hive table as streaming source. - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2024/04/01 01:27:29 UTC, 2 replies.
- Re: Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project - posted by Hang Ruan <ru...@gmail.com> on 2024/04/01 01:48:32 UTC, 6 replies.
- Re: [VOTE] FLIP-424: Asynchronous State APIs - posted by Zakelly Lan <za...@gmail.com> on 2024/04/01 02:08:42 UTC, 1 replies.
- Re: [DISCUSS] FLIP-427: Disaggregated State Store - posted by Hangxiang Yu <ma...@gmail.com> on 2024/04/01 02:18:22 UTC, 0 replies.
- Re: [VOTE] FLIP-427: Disaggregated state Store - posted by Hangxiang Yu <ma...@gmail.com> on 2024/04/01 02:26:12 UTC, 0 replies.
- [RESULT][VOTE] FLIP-427: Disaggregated state Store - posted by Hangxiang Yu <ma...@gmail.com> on 2024/04/01 02:35:40 UTC, 0 replies.
- Re: [VOTE] FLIP-426: Grouping Remote State Access - posted by Hangxiang Yu <ma...@gmail.com> on 2024/04/01 02:37:12 UTC, 0 replies.
- Re: [DISCUSS] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by Jinzhong Li <li...@gmail.com> on 2024/04/01 03:06:07 UTC, 0 replies.
- [RESULT][VOTE] FLIP-426: Grouping Remote State Access - posted by Jinzhong Li <li...@gmail.com> on 2024/04/01 03:15:44 UTC, 0 replies.
- [RESULT][VOTE] FLIP-424: Asynchronous State APIs - posted by Zakelly Lan <za...@gmail.com> on 2024/04/01 03:23:18 UTC, 0 replies.
- [RESULT][VOTE] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by Jinzhong Li <li...@gmail.com> on 2024/04/01 03:25:03 UTC, 0 replies.
- [jira] [Created] (FLINK-34973) FLIP-423: Disaggregated State Storage and Management - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/01 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34974) FLIP-424: Asynchronous State APIs - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/01 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/01 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2024/04/01 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34977) FLIP-433: State Access on DataStream API V2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/01 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34979) Implement State Future and related utilities - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/01 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34978) Introduce Asynchronous State APIs - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/01 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34980) Translate overview document into Chinese - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/04/01 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34981) FLIP-426: Grouping Remote State Access - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/01 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/01 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34983) Hive param sink.partition-commit.policy.kind default value is not work in stream mode - posted by "yunfan (Jira)" <ji...@apache.org> on 2024/04/01 08:19:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-399: Flink Connector Doris - posted by wudi <67...@qq.com.INVALID> on 2024/04/01 09:52:26 UTC, 2 replies.
- Re: [DISCUSS] FLIP-434: Support optimizations for pre-partitioned data sources - posted by Jeyhun Karimov <je...@gmail.com> on 2024/04/01 09:59:51 UTC, 10 replies.
- Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP) - posted by Yuan Mei <yu...@gmail.com> on 2024/04/01 10:52:15 UTC, 0 replies.
- [RESULT][VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP) - posted by Yuan Mei <yu...@gmail.com> on 2024/04/01 11:27:04 UTC, 0 replies.
- [jira] [Created] (FLINK-34984) Disaggregated State Storage and Management (Umbrella FLIP) - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2024/04/01 11:47:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Introduce Flink SQL variables - posted by Jeyhun Karimov <je...@gmail.com> on 2024/04/01 13:24:03 UTC, 1 replies.
- RE: Re: Iceberg table maintenance - posted by wenjin <we...@gmail.com> on 2024/04/02 02:07:31 UTC, 3 replies.
- [jira] [Created] (FLINK-34985) It doesn't support to access fields by name for map function in thread mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2024/04/02 02:13:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines - posted by Ron liu <ro...@gmail.com> on 2024/04/02 02:28:49 UTC, 30 replies.
- Re: [DISCUSS] Externalized Google Cloud Connectors - posted by Leonard Xu <xb...@gmail.com> on 2024/04/02 04:13:08 UTC, 3 replies.
- [jira] [Created] (FLINK-34986) Basic framework for async execution of state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/02 04:14:00 UTC, 0 replies.
- [IMPROVEMENT] Using ServiceLoader to load ExtendedParseStrategy - posted by Naveen Kumar <nk...@gmail.com> on 2024/04/02 05:14:35 UTC, 0 replies.
- Re: [VOTE] FLIP-437: Support ML Models in Flink SQL - posted by Timo Walther <tw...@apache.org> on 2024/04/02 07:12:16 UTC, 9 replies.
- [jira] [Created] (FLINK-34987) Introduce Internal State Interface for Async API - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/02 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34988) Class loading issues in JDK17 and JDK21 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/04/02 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/04/02 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/04/02 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34991) Flink Operator ClassPath Race Condition Bug - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2024/04/02 16:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX Apicurio-avro format - posted by Balint Bene <ba...@shopify.com.INVALID> on 2024/04/02 18:02:57 UTC, 3 replies.
- [jira] [Created] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/03 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34993) Support Model CRUD in parser - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/03 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task" - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/04/03 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34995) flink kafka connector source stuck when partition leader invalid - posted by "yansuopeng (Jira)" <ji...@apache.org> on 2024/04/03 09:16:00 UTC, 0 replies.
- Inquiry Regarding Azure Pipelines - posted by Yisha Zhou <zh...@bytedance.com.INVALID> on 2024/04/03 09:33:19 UTC, 2 replies.
- [jira] [Created] (FLINK-34996) Deserializer can't be instantiated when connector-kafka installed into Flink Libs - posted by "Hugo Gu (Jira)" <ji...@apache.org> on 2024/04/03 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34997) PyFlink YARN per-job on Docker test failed on azure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/03 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34998) Wordcount on Docker test failed on azure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/03 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34999) PR CI stopped operating - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/04/03 11:33:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/04/03 11:49:22 UTC, 2 replies.
- [jira] [Created] (FLINK-35000) PullRequest template doesn't use the correct format to refer to the testing code convention - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/04/03 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35001) Avoid scientific notation for DOUBLE to STRING - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/04/03 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35002) GitHub action/upload-artifact@v4 can timeout - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/03 13:38:00 UTC, 0 replies.
- Participate in the ASF 25th Anniversary Campaign - posted by Brian Proffitt <bk...@apache.org> on 2024/04/03 13:50:12 UTC, 0 replies.
- Parallelism is not working as expected for Apache Beam Code Running on a Flink Kubernetes Cluster - posted by Dipak Tandel <di...@gmail.com> on 2024/04/03 13:55:53 UTC, 0 replies.
- [jira] [Created] (FLINK-35003) Update zookeeper to 3.8.4 to address CVE-2024-23944 - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2024/04/03 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35004) SqlGatewayE2ECase could not start container - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/03 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35005) SqlClientITCase Failed to build JobManager image - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/03 15:20:00 UTC, 0 replies.
- Community over Code EU 2024: Start planning your trip! - posted by Ryan Skraba <ry...@skraba.com> on 2024/04/03 15:44:21 UTC, 0 replies.
- Re: [DISCUSS] FLIP-437: Support ML Models in Flink SQL - posted by Hao Li <hl...@confluent.io.INVALID> on 2024/04/03 17:57:40 UTC, 1 replies.
- [FYI] The Azure CI for PRs is currently not triggered - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2024/04/04 06:22:50 UTC, 2 replies.
- [jira] [Created] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor - posted by "Kirill Plugatarev (Jira)" <ji...@apache.org> on 2024/04/04 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/04/04 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/04/04 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35009) Change on getTransitivePredecessors breaks connectors - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/04/04 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/04/04 13:51:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-437: Support ML Models in Flink SQL - posted by Hao Li <hl...@confluent.io.INVALID> on 2024/04/04 15:24:54 UTC, 0 replies.
- [jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/04/04 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/04 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35013) Support temporary model - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35014) SqlNode to operation conversion for models - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/04/04 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35018) ML_EVALUATE function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35016) Catalog changes for model CRUD - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35017) ML_PREDICT function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35019) Support show create model syntax - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 19:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35020) Model Catalog implementation in Hive etc - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/04/04 22:47:00 UTC, 0 replies.
- Two potential bugs in Flink ML - posted by Komal M <ko...@gmail.com> on 2024/04/05 05:59:23 UTC, 4 replies.
- [jira] [Created] (FLINK-35021) AggregateQueryOperations produces wrong asSerializableString representation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/04/05 09:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-438: Amazon SQS Sink Connector - posted by "Dhingra, Priya" <dh...@amazon.com.INVALID> on 2024/04/05 18:16:42 UTC, 13 replies.
- [jira] [Created] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/04/06 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35023) YARNApplicationITCase failed on Azure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/07 02:21:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI - posted by Rui Fan <19...@gmail.com> on 2024/04/07 02:37:21 UTC, 4 replies.
- Re: [External] Inquiry Regarding Azure Pipelines - posted by Yisha Zhou <zh...@bytedance.com.INVALID> on 2024/04/07 03:41:52 UTC, 2 replies.
- [jira] [Created] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 04:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35026) Introduce async-state configurations - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35028) Processing timer firing under async execution model - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35029) Store timer in JVM heap when async execution enabled - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35030) Introduce Epoch Manager for watermark under async execution - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35031) Event timer firing under async execution model - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/07 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35034) codegen compile error raised when use kafka connector and protobuf format - posted by "yufeng.sun (Jira)" <ji...@apache.org> on 2024/04/07 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/04/07 07:32:00 UTC, 0 replies.
- 退订 - posted by 995626544 <99...@qq.com.INVALID> on 2024/04/07 08:04:30 UTC, 0 replies.
- [jira] [Created] (FLINK-35036) Flink CDC Job cancel with savepoint failed - posted by "Fly365 (Jira)" <ji...@apache.org> on 2024/04/07 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35037) Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2024/04/07 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35038) Bump test dependency org.yaml:snakeyaml to 2.2 - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2024/04/07 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed - posted by "JJJJude (Jira)" <ji...@apache.org> on 2024/04/08 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35040) The performance of serializerHeavyString regresses since April 3 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/08 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/08 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/08 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35043) Release beta version of ForSt - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35044) Introduce statebackend-forst module - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35047) Introduce ForStStateBackend - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35048) Implement all methods of AsyncKeyedStateBakend - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35049) Implement Async State API for ForStStateBackend - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/08 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35050) Remove Lazy Initialization of DynamoDbBeanElementConverter - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/04/08 08:51:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-rabbitmq, v3.0.2 release candidate #1 - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/04/08 10:55:15 UTC, 0 replies.
- [jira] [Created] (FLINK-35051) Weird priorities when processing unaligned checkpoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/04/08 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35052) Webhook validator should reject unsupported Flink versions - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/04/08 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35053) TIMESTAMP with TIME ZONE not supported by JDBC connector for Postgres - posted by "Pietro (Jira)" <ji...@apache.org> on 2024/04/08 14:39:00 UTC, 0 replies.
- [VOTE] FLIP-399: Flink Connector Doris - posted by wudi <67...@qq.com.INVALID> on 2024/04/09 02:47:55 UTC, 17 replies.
- [jira] [Created] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/04/09 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35055) Flink CDC connector release contains jar with incompatible licenses - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/09 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35056) when initial sqlserver table that - posted by "yandufeng (Jira)" <ji...@apache.org> on 2024/04/09 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35057) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink jdbc connector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/04/09 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35058) Encountered change event for table db.table whose schema isn't known to this connector - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/04/09 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.5.5 in flink-connector-jdbc - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/04/09 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35060) Provide compatibility of old CheckpointMode for connector testing framework - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/09 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35061) Migrate TemporalJoinUtil - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/04/09 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35062) Migrate RewriteMultiJoinConditionRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/04/09 08:17:00 UTC, 0 replies.
- [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/04/09 08:20:00 UTC, 7 replies.
- [jira] [Created] (FLINK-35063) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict - posted by "chendaping (Jira)" <ji...@apache.org> on 2024/04/09 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict - posted by "chendaping (Jira)" <ji...@apache.org> on 2024/04/09 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35065) Add numFiredTimers and numFiredTimersPerSecond metrics - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/04/09 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2024/04/09 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/09 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35068) Introduce built-in serialization support for Set - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/04/09 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/09 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35070) remove unused duplicate code - posted by "niliushall (Jira)" <ji...@apache.org> on 2024/04/09 12:26:00 UTC, 0 replies.
- [VOTE] FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI - posted by Rui Fan <19...@gmail.com> on 2024/04/10 04:36:00 UTC, 14 replies.
- [jira] [Created] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/10 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/10 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently - posted by "Julien Tournay (Jira)" <ji...@apache.org> on 2024/04/10 08:25:00 UTC, 0 replies.
- RE: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format - posted by David Radley <da...@uk.ibm.com> on 2024/04/10 08:56:32 UTC, 3 replies.
- [jira] [Created] (FLINK-35074) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/10 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35075) Migrate TwoStageOptimizedAggregateRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/04/10 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake - posted by "elon_X (Jira)" <ji...@apache.org> on 2024/04/10 12:24:00 UTC, 0 replies.
- Re: Support minibatch for TopNFunction - posted by Roman Boyko <ro...@gmail.com> on 2024/04/10 15:49:37 UTC, 0 replies.
- [jira] [Created] (FLINK-35077) Add package license check for Flink CDC modules. - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/11 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35078) Include Flink CDC pipeline connector sub-modules in the CI runs - posted by "Muhammet Orazov (Jira)" <ji...@apache.org> on 2024/04/11 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35079) MongoConnector failed to resume token when current collection removed - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/11 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35080) Allow to specify additional pushdown filter in table properties - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2024/04/11 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35081) CompileException when watermark definition contains coalesce and to_timestamp built-in functions - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2024/04/11 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check - posted by "elon_X (Jira)" <ji...@apache.org> on 2024/04/11 12:20:00 UTC, 0 replies.
- Testing with custom generated data - posted by lo...@ververica.com.INVALID on 2024/04/11 15:20:22 UTC, 0 replies.
- Re: Question around Flink's AdaptiveBatchScheduler - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/04/11 18:09:54 UTC, 7 replies.
- [jira] [Created] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/04/12 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35090) Doris sink fails to create table when database does not exist - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/12 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35091) Incorrect Warning msg in JM when use influxdb - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2024/04/12 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35092) Add integrated test for Doris sink pipeline connector - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/12 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/12 03:34:00 UTC, 0 replies.
- [SUMMARY] Flink 1.20 Release Sync 04/09/2024 - posted by weijie guo <gu...@gmail.com> on 2024/04/12 07:35:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee - posted by Jark Wu <im...@gmail.com> on 2024/04/12 07:59:00 UTC, 42 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Jing Ge - posted by Jark Wu <im...@gmail.com> on 2024/04/12 08:02:01 UTC, 35 replies.
- [jira] [Created] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/04/12 08:24:00 UTC, 0 replies.
- Proposal: I hope the official documentation can provide an "Integrations" section. - posted by Kaiming Wan <wa...@gmail.com> on 2024/04/12 09:57:10 UTC, 3 replies.
- [jira] [Created] (FLINK-35095) ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/12 12:18:00 UTC, 0 replies.
- Re: [EXTERNAL] RE: [DISCUSS] FLIP-XXX Apicurio-avro format - posted by David Radley <da...@uk.ibm.com> on 2024/04/12 16:08:17 UTC, 2 replies.
- [jira] [Created] (FLINK-35096) Flink OpenSearch Connector - posted by "Harish Sharma (Jira)" <ji...@apache.org> on 2024/04/12 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line - posted by "David Perkins (Jira)" <ji...@apache.org> on 2024/04/12 21:05:00 UTC, 0 replies.
- [Vote] FLIP-438: Amazon SQS Sink Connector - posted by "Dhingra, Priya" <dh...@amazon.com.INVALID> on 2024/04/12 21:56:04 UTC, 9 replies.
- [jira] [Created] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format - posted by "Andrey Gaskov (Jira)" <ji...@apache.org> on 2024/04/13 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35099) Support for multiple datasources - posted by "melin (Jira)" <ji...@apache.org> on 2024/04/15 01:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35100) Quickstarts Java nightly end-to-end test failed on Azure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/15 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport - posted by "chenyu (Jira)" <ji...@apache.org> on 2024/04/15 02:18:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Zakelly Lan - posted by Yuan Mei <yu...@gmail.com> on 2024/04/15 02:50:06 UTC, 37 replies.
- [jira] [Created] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/15 03:17:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI - posted by Rui Fan <19...@gmail.com> on 2024/04/15 03:31:45 UTC, 0 replies.
- [jira] [Created] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration - posted by "SwathiChandrashekar (Jira)" <ji...@apache.org> on 2024/04/15 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35104) Add kafka pipeline data source connector - posted by "melin (Jira)" <ji...@apache.org> on 2024/04/15 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/15 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35106) Kubernetes Operator ignores checkpoint type configuration - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/04/15 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35107) rename flink-connector-datagen-test module folder to flink-connector-datagen-tests - posted by "xleoken (Jira)" <ji...@apache.org> on 2024/04/15 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35108) Deployment recovery is triggered on terminal jobs after jm shutdown ttl - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/04/15 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35109) Drop support for Flink 1.17 and 1.18 in Flink Kafka connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/04/15 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35111) Modify the spelling mistakes in the taskmanager html - posted by "JJJJude (Jira)" <ji...@apache.org> on 2024/04/15 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35110) Modify the spelling mistakes in the taskmanager html - posted by "JJJJude (Jira)" <ji...@apache.org> on 2024/04/15 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35112) Membership for Row class does not include field names - posted by "Wouter Zorgdrager (Jira)" <ji...@apache.org> on 2024/04/15 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35113) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink AWS connectors - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/15 11:58:02 UTC, 0 replies.
- [jira] [Created] (FLINK-35114) Remove old Table API implementations - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/04/15 13:27:00 UTC, 0 replies.
- [DISCUSS] Connector releases for Flink 1.19 - posted by Danny Cranmer <da...@apache.org> on 2024/04/15 13:44:18 UTC, 6 replies.
- [jira] [Created] (FLINK-35115) Kinesis connector writes wrong sequence number at stop with savepoint - posted by "Vadim Vararu (Jira)" <ji...@apache.org> on 2024/04/15 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35116) Upgrade JOSDK dependency to 4.8.3 - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2024/04/15 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35117) AsyncScalarFunction has a dependency issue. - posted by "roland (Jira)" <ji...@apache.org> on 2024/04/16 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35118) StreamingHiveSource cannot track tables that have more than 32,767 partitions - posted by "roland (Jira)" <ji...@apache.org> on 2024/04/16 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect - posted by "Qishang Zhong (Jira)" <ji...@apache.org> on 2024/04/16 03:45:00 UTC, 0 replies.
- [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration - posted by Swathi C <sw...@gmail.com> on 2024/04/16 06:18:39 UTC, 10 replies.
- [jira] [Created] (FLINK-35120) Add Doris Pipeline connector integration test cases - posted by "Xiqian YU (Jira)" <ji...@apache.org> on 2024/04/16 06:47:00 UTC, 0 replies.
- [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource - posted by Xia Sun <xi...@gmail.com> on 2024/04/16 07:07:52 UTC, 14 replies.
- [jira] [Created] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/16 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35122) Implement Watermark Alignment for DynamicKafkaSource - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2024/04/16 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35123) Flink Kubernetes Operator should not do deleteHAData - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2024/04/16 08:19:00 UTC, 0 replies.
- [DISCUSS] FLIP-446: Kubernetes Operator State Snapshot CRD - posted by Mate Czagany <cz...@gmail.com> on 2024/04/16 09:34:37 UTC, 12 replies.
- [jira] [Created] (FLINK-35124) Connector Release Fails to run Checkstyle - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/16 10:25:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v4.3.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/16 10:58:46 UTC, 4 replies.
- [jira] [Created] (FLINK-35125) Implement ValueState for ForStStateBackend - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/16 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35126) Improve checkpoint progress health check config and enable by default - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/04/16 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/04/17 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35128) Re-calculate the starting binlog offset after the new table added - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/17 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/17 03:04:00 UTC, 0 replies.
- [VOTE] FLIP-442: General Improvement to Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/04/17 05:00:00 UTC, 10 replies.
- [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines - posted by Ron liu <ro...@gmail.com> on 2024/04/17 06:27:27 UTC, 14 replies.
- [jira] [Created] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2024/04/17 08:29:00 UTC, 0 replies.
- [DISCUSS][QUESTION] Drop jdk 8 support for Flink connector Opensearch - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/04/17 09:02:36 UTC, 2 replies.
- [jira] [Created] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.18/1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35131) Support and Release Connectors for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35133) Release flink-connector-cassandra v4.3.0 for Flink 1.18/1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.18/1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35135) Release flink-connector-gcp-pubsub vX.X.X for Flink 1.18/1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35138) Release flink-connector-kafka vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35141) Release flink-connector-pulsar vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35142) Release flink-connector-rabbitmq vX.X.X for Flink 1.19 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/17 09:14:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/17 10:02:06 UTC, 2 replies.
- [VOTE] Release flink-connector-mongodb v1.2.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/17 10:15:55 UTC, 4 replies.
- [jira] [Created] (FLINK-35143) Expose newly added tables capture in mysql pipeline connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/17 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35144) Support multi source sync for FlinkCDC - posted by "Congxian Qiu (Jira)" <ji...@apache.org> on 2024/04/17 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35145) Add timeout for cluster termination - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/04/17 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35146) CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/17 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table - posted by "Sharon Xie (Jira)" <ji...@apache.org> on 2024/04/17 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/04/17 22:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/18 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid - posted by "qyw (Jira)" <ji...@apache.org> on 2024/04/18 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/04/18 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35152) Flink CDC Doris/Starrocks Sink Auto create table event should support setting auto partition fields for each table - posted by "tumengyao (Jira)" <ji...@apache.org> on 2024/04/18 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/18 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35154) Javadoc aggregate fails - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2024/04/18 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35155) Introduce TableRuntimeException - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/04/18 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35156) Wire new operators for async state with DataStream V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/18 10:13:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2 - posted by Danny Cranmer <da...@apache.org> on 2024/04/18 10:19:13 UTC, 3 replies.
- [VOTE] Release flink-connector-mongodb v1.2.0, release candidate #2 - posted by Danny Cranmer <da...@apache.org> on 2024/04/18 10:20:34 UTC, 3 replies.
- [VOTE] Release flink-connector-gcp-pubsub v3.1.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/18 10:32:11 UTC, 2 replies.
- [jira] [Created] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/04/18 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35158) Error handling in StateFuture's callback - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/04/18 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/04/18 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks - posted by "elon_X (Jira)" <ji...@apache.org> on 2024/04/18 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35161) Implement StateExecutor for ForStStateBackend - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/18 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35162) Support grouping state get and put access - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/18 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/04/18 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35164) Support `ALTER CATALOG RESET` syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/04/18 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35165) AdaptiveBatch Scheduler should not restrict the default source parallelism to the max parallelism set - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2024/04/18 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2024/04/19 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35167) [CDC] Introduce MaxCompute pipeline DataSink - posted by "zhangdingxin (Jira)" <ji...@apache.org> on 2024/04/19 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35168) Basic State Iterator for async processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/19 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2024/04/19 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35170) SqlServer connector support scanNewlyAddedTableEnabled param - posted by "fengfengzai (Jira)" <ji...@apache.org> on 2024/04/19 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35171) Class 'FlinkSqlParserImpl' is missed - posted by "chenyu (Jira)" <ji...@apache.org> on 2024/04/19 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35172) DDL statement is added to the Schema Change Event - posted by "melin (Jira)" <ji...@apache.org> on 2024/04/19 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35173) Debezium Custom Time Serializer - posted by "ZhengYu Chen (Jira)" <ji...@apache.org> on 2024/04/19 09:52:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v4.3.0, release candidate #2 - posted by Danny Cranmer <da...@apache.org> on 2024/04/19 10:07:27 UTC, 3 replies.
- [jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/04/19 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3 - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/19 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/04/19 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35177) Datagen examples in documentation do not compile - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2024/04/20 00:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership - posted by "elon_X (Jira)" <ji...@apache.org> on 2024/04/20 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35179) add postgres pipeline data sink connector - posted by "melin (Jira)" <ji...@apache.org> on 2024/04/20 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode - posted by "Wei Yuan (Jira)" <ji...@apache.org> on 2024/04/20 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/04/20 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/04/20 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2024/04/20 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator - posted by "Roman Boyko (Jira)" <ji...@apache.org> on 2024/04/21 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35185) Resuming Externalized Checkpoint(rocks, incremental, no parallelism change) end-to-end test failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/22 01:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 - posted by yue ma <ma...@gmail.com> on 2024/04/22 06:09:42 UTC, 16 replies.
- [RESULT][VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines - posted by Ron Liu <ro...@gmail.com> on 2024/04/22 06:33:43 UTC, 0 replies.
- [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table - posted by Ron Liu <ro...@gmail.com> on 2024/04/22 06:41:39 UTC, 9 replies.
- [jira] [Created] (FLINK-35186) Create State V2 from new StateDescriptor - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/04/22 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35190) Support the syntaxes of Create, Suspend, Resume, Refresh and Drop materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35191) Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35192) operator oom - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/04/22 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35193) Support drop materialized table syntax and execution - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35194) Support describe job syntax - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35195) Support the execution of materialized table in continuous mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35196) bouncycastle class not found for flink pulsar connector - posted by "Wenbing Shen (Jira)" <ji...@apache.org> on 2024/04/22 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35197) Support the execution of suspend, resume materialized table in continuous mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35198) Support the execution of refresh materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35199) Support the execution of create materialized table in full refreshmode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35200) Support the execution of suspend, resume materialized table in full refresh mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35201) Support the execution of drop materialized table in full refresh mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35202) Support the execution of set freshness for materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35203) Support the execution of alter materialized table set refresh mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35204) Support the execution of alter materialized table set options - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35205) Support the execution of alter materialized table reset options - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35206) Desc table syntax support materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/04/22 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35207) Kubernetes session E2E test fails to fetch packages. - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/22 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2024/04/22 09:23:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics - posted by jialiang tan <ta...@gmail.com> on 2024/04/22 09:47:29 UTC, 8 replies.
- [RESULT][VOTE] FLIP-442: General Improvement to Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/04/22 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35209) Add a DeserializationSchema decorator that counts deserialize errors - posted by "Nicolas Perrin (Jira)" <ji...@apache.org> on 2024/04/22 12:39:00 UTC, 0 replies.
- [VOTE] Release flink-connector-cassandra v3.2.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/22 13:04:13 UTC, 2 replies.
- [VOTE] Release flink-connector-kafka v3.2.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2024/04/22 13:55:22 UTC, 4 replies.
- [jira] [Created] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions - posted by "Nicolas Perrin (Jira)" <ji...@apache.org> on 2024/04/22 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35211) when synchronize LOB fields using oracle cdc, an error occurs - posted by "wangsw (Jira)" <ji...@apache.org> on 2024/04/23 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode - posted by "Wei Yuan (Jira)" <ji...@apache.org> on 2024/04/23 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35213) A potential inconsistent table structure issue - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/04/23 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2024/04/23 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/23 05:58:00 UTC, 0 replies.
- [SUMMARY] Flink 1.20 Release Sync 04/23/2024 - posted by Rui Fan <19...@gmail.com> on 2024/04/23 09:13:12 UTC, 3 replies.
- [jira] [Created] (FLINK-35216) Support for RETURNING clause of JSON_QUERY - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/04/23 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage - posted by "Marc Aurel Fritz (Jira)" <ji...@apache.org> on 2024/04/23 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35218) Duplicated values caused by expired state TTL - posted by "garcia (Jira)" <ji...@apache.org> on 2024/04/23 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35219) [Flink SQL]Support deserialize json string into Map - posted by "zhihao zhang (Jira)" <ji...@apache.org> on 2024/04/24 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35220) the error of mysql cdc - posted by "xiaotouming (Jira)" <ji...@apache.org> on 2024/04/24 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser - posted by "Wencong Liu (Jira)" <ji...@apache.org> on 2024/04/24 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35223) Add jobType in JobDetailsInfo related rest api - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35222) Adding getJobType for AccessExecutionGraph - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35224) Show the JobType on Flink WebUI - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35225) Remove Execution mode in Flink WebUI - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35227) Remove execution-mode in ExecutionConfigInfo - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/04/24 07:56:00 UTC, 0 replies.
- [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD - posted by Mate Czagany <cz...@gmail.com> on 2024/04/24 08:03:19 UTC, 11 replies.
- [jira] [Created] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster - posted by "Ignas Daukšas (Jira)" <ji...@apache.org> on 2024/04/24 08:44:00 UTC, 0 replies.
- Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax - posted by Yubin Li <ly...@gmail.com> on 2024/04/24 08:56:59 UTC, 6 replies.
- [jira] [Created] (FLINK-35229) join An error occurred when the table was empty - posted by "lixu (Jira)" <ji...@apache.org> on 2024/04/24 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines. - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2024/04/24 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35231) Test relies on listJobsFunction in TestingClusterClient are broken - posted by "Artem Plyusnin (Jira)" <ji...@apache.org> on 2024/04/24 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35232) Support for retry settings on GCS connector - posted by "Vikas M (Jira)" <ji...@apache.org> on 2024/04/24 19:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2024/04/25 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/04/25 05:57:00 UTC, 0 replies.
- CSRF token available in apache flink - posted by Swathi C <sw...@gmail.com> on 2024/04/25 06:54:05 UTC, 0 replies.
- [jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/04/25 07:19:00 UTC, 0 replies.
- [DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/04/25 08:34:00 UTC, 1 replies.
- [jira] [Created] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website - posted by "hongxu han (Jira)" <ji...@apache.org> on 2024/04/25 08:53:00 UTC, 0 replies.
- [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc - posted by Joao Boto <bo...@boto.pro> on 2024/04/25 08:54:13 UTC, 5 replies.
- [jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization - posted by "zhangdingxin (Jira)" <ji...@apache.org> on 2024/04/25 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/25 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35239) 1.19 docs show outdated warning - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2024/04/25 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/04/25 16:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ - posted by "Alexey Leonov-Vendrovskiy (Jira)" <ji...@apache.org> on 2024/04/25 18:02:00 UTC, 0 replies.
- [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource - posted by Xia Sun <xi...@gmail.com> on 2024/04/26 02:21:02 UTC, 6 replies.
- [jira] [Created] (FLINK-35242) Add fine-grained schema evolution strategy - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/26 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/26 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35244) Move package for flink-connector-tidb-cdc test - posted by "Xie Yi (Jira)" <ji...@apache.org> on 2024/04/26 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35245) Add metrics for flink-connector-tidb-cdc - posted by "Xie Yi (Jira)" <ji...@apache.org> on 2024/04/26 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/26 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21 - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2024/04/26 17:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35248) Support table/column comment to modify DDL - posted by "melin (Jira)" <ji...@apache.org> on 2024/04/27 03:29:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-399: Flink Connector Doris - posted by wudi <67...@qq.com.INVALID> on 2024/04/27 05:05:37 UTC, 0 replies.
- [jira] [Created] (FLINK-35249) Support DataGeneratorSource in PyFlink - posted by "Wei Yuan (Jira)" <ji...@apache.org> on 2024/04/27 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35250) Translate the "Flink Operations Playground" page into Chinese - posted by "Juan Zifeng (Jira)" <ji...@apache.org> on 2024/04/27 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/04/27 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35252) Update the operators marked as deprecated in the instance program on the official website - posted by "hongxu han (Jira)" <ji...@apache.org> on 2024/04/28 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35253) State Processor API - posted by "Juan Zifeng (Jira)" <ji...@apache.org> on 2024/04/28 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35254) build_wheels_on_macos failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/04/28 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35255) DataSinkWriterOperator should override snapshotState和processWatermark method - posted by "yanghuai (Jira)" <ji...@apache.org> on 2024/04/28 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35256) Pipeline transform ignores column type nullability - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/28 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35257) optimize the handling of schema.change.behavior as EXCEPTION - posted by "yanghuai (Jira)" <ji...@apache.org> on 2024/04/28 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35258) Broken links to Doris in Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/04/28 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/04/28 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35260) Translate "Watermark alignment "page into Chinese - posted by "hongxu han (Jira)" <ji...@apache.org> on 2024/04/29 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35261) Flink CDC pipeline transform doesn't support decimal comparison - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/29 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35262) Bridge between AsyncKeyedStateBackend and AsyncExecutionController - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/29 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35263) FLIP-446: Kubernetes Operator State Snapshot CRD - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/04/29 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/29 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35265) Implement FlinkStateSnapshot custom resource - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/04/29 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35266) Add e2e tests for FlinkStateSnapshot CRs - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/04/29 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35267) Create documentation for FlinkStateSnapshot CR - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/04/29 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35268) Support TTL for Async State API - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/04/29 10:21:00 UTC, 0 replies.
- Flink stateful functions and Agentic Architecture - posted by David Carroll <da...@spotter.la.INVALID> on 2024/04/29 13:35:11 UTC, 0 replies.
- [DISCUSS] FLIP-443: Interruptible watermark processing - posted by Piotr Nowojski <pn...@apache.org> on 2024/04/29 13:56:10 UTC, 4 replies.
- [DISCUSS] FLIP-451: Refactor Async sink API - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/04/29 14:08:50 UTC, 2 replies.
- [jira] [Created] (FLINK-35269) Fix logging level for errors in AWS connector sinks - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/04/29 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35270) Enrich information in logs, making it easier for debugging - posted by "Haifei Chen (Jira)" <ji...@apache.org> on 2024/04/29 17:24:00 UTC, 0 replies.
- [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2024/04/29 22:57:18 UTC, 2 replies.
- [jira] [Created] (FLINK-35271) Add doc for syntax `describe job 'xxx'` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/04/30 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column - posted by "yux (Jira)" <ji...@apache.org> on 2024/04/30 01:43:00 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1 - posted by Qingsheng Ren <re...@apache.org> on 2024/04/30 05:11:39 UTC, 0 replies.
- [jira] [Created] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2024/04/30 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/04/30 10:35:00 UTC, 0 replies.
- [DISCUSS] FLIP-444: Native file copy support - posted by Piotr Nowojski <pn...@apache.org> on 2024/04/30 13:15:05 UTC, 2 replies.
- [jira] [Created] (FLINK-35275) ArrayContainsFunction uses wrong DataType to create element getter - posted by "PengFei Li (Jira)" <ji...@apache.org> on 2024/04/30 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35276) SortCodeGeneratorTest.testMultiKeys fails on negative zero - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/04/30 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35277) Fix the error in the `asncdcaddremove.sql` script for the DB2 test container. - posted by "wenli xiao (Jira)" <ji...@apache.org> on 2024/04/30 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35278) Occasional NPE on k8s operator status replacement - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2024/04/30 14:30:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD - posted by Mate Czagany <cz...@gmail.com> on 2024/04/30 15:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob - posted by "Alan Zhang (Jira)" <ji...@apache.org> on 2024/04/30 17:01:00 UTC, 0 replies.