You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/01 22:44:00 UTC, 0 replies.
- [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project - posted by Xintong Song <to...@gmail.com> on 2025/06/02 01:31:08 UTC, 39 replies.
- Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project - posted by Xintong Song <to...@gmail.com> on 2025/06/02 02:18:44 UTC, 0 replies.
- [jira] [Created] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/02 07:34:00 UTC, 0 replies.
- Re: [VOTE] Release 1.19.3, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2025/06/02 07:41:21 UTC, 5 replies.
- Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2025/06/02 10:10:54 UTC, 3 replies.
- Re: Question on usage of SQL Gateway with a remote Flink cluster - posted by Ammu P <am...@gmail.com> on 2025/06/02 10:11:38 UTC, 0 replies.
- Re: [DISCUSS] FLIP-532: Donate GetInData HTTP Connector to Flink - posted by David Radley <da...@uk.ibm.com> on 2025/06/02 13:01:41 UTC, 0 replies.
- Re: Bug: Race condition in Flink Kinesis EFO de/registration on restart - posted by Jonathan Du <jd...@atlassian.com.INVALID> on 2025/06/03 01:06:44 UTC, 0 replies.
- [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/06/03 03:30:00 UTC, 4 replies.
- Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal - posted by Nicolas Fraison <ni...@datadoghq.com.INVALID> on 2025/06/03 06:52:18 UTC, 11 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 - posted by Gabor Somogyi <ga...@gmail.com> on 2025/06/03 07:02:41 UTC, 0 replies.
- [jira] [Created] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/03 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2025/06/03 10:53:00 UTC, 0 replies.
- [KINDLY REMINDER] Flink 2.1 Release Sync 06/04/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/03 11:32:26 UTC, 0 replies.
- [jira] [Created] (FLINK-37886) Introduce the ITCase to check whether unaligned checkpoint works well for jobs with sink writer and committer - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/03 12:03:00 UTC, 0 replies.
- [HELP] Failing ArchitectureTest on master (CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API) - posted by Gabor Somogyi <ga...@gmail.com> on 2025/06/03 12:36:19 UTC, 0 replies.
- [jira] [Created] (FLINK-37887) Watched namespaces not picked up automatically by the operator - posted by "Igor Milavec (Jira)" <ji...@apache.org> on 2025/06/03 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg - posted by "r0y4d3v (Jira)" <ji...@apache.org> on 2025/06/03 13:59:00 UTC, 0 replies.
- Request a permission - posted by Zhe Wang <ja...@gmail.com> on 2025/06/03 14:04:35 UTC, 2 replies.
- Missing required TM metrics when truing to use the autoscaler - posted by David Radley <da...@uk.ibm.com> on 2025/06/03 15:27:11 UTC, 0 replies.
- [jira] [Created] (FLINK-37889) FLIP-516: Add new FlinkLogicalMultiJoin rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/03 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37890) FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/03 15:48:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API - posted by Martijn Visser <ma...@apache.org> on 2025/06/03 18:04:34 UTC, 8 replies.
- [jira] [Created] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/03 23:01:00 UTC, 0 replies.
- Call for Presentations: Current New Orleans, October 29-30, 2025 - posted by Robert Metzger <rm...@apache.org> on 2025/06/04 05:59:39 UTC, 0 replies.
- [SUMMARY] Flink 2.1 Release Sync 06/04/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/04 07:44:20 UTC, 2 replies.
- [jira] [Created] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/04 08:40:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.12.0 released - posted by Gabor Somogyi <ga...@gmail.com> on 2025/06/04 08:41:42 UTC, 0 replies.
- [jira] [Created] (FLINK-37893) Rest Port Name should be made configurable - posted by "Mayur Dhingra (Jira)" <ji...@apache.org> on 2025/06/04 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37894) Introduce new Join Operator with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2025/06/04 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs - posted by "Sebastian Struß (Jira)" <ji...@apache.org> on 2025/06/04 14:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-533: Cassandra Sink V2 - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/06/04 14:40:13 UTC, 6 replies.
- Waiting on approval to Jira account - posted by Jonathan Du <jd...@atlassian.com.INVALID> on 2025/06/05 01:56:31 UTC, 0 replies.
- [jira] [Created] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join. - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37898) Implement delta join operator - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/05 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37899) Unstable JoinRestoreTest - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 03:21:00 UTC, 0 replies.
- Flink CDC for mongoDB, need to understand MongoDBStreamFetchTask better - posted by Sachin Mittal <sj...@gmail.com> on 2025/06/05 03:48:49 UTC, 0 replies.
- [jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/06/05 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37901) Support to serde ExecNode for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37902) Support batch execution for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37903) Support runtime config for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37904) Support state ttl for async ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/05 06:56:00 UTC, 0 replies.
- 2025/06/05 CHI Eastern time zone workgroup meeting minutes - posted by David Radley <da...@uk.ibm.com> on 2025/06/05 08:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/06/05 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/06/05 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/05 10:53:00 UTC, 0 replies.
- Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by Allison <ac...@gmail.com> on 2025/06/05 19:49:19 UTC, 6 replies.
- [jira] [Created] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts - posted by "Jonathan Du (Jira)" <ji...@apache.org> on 2025/06/06 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error - posted by "Sachin Mittal (Jira)" <ji...@apache.org> on 2025/06/06 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/06 07:34:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project - posted by Xintong Song <to...@gmail.com> on 2025/06/06 07:35:27 UTC, 0 replies.
- [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink - posted by David Radley <da...@uk.ibm.com> on 2025/06/06 16:09:03 UTC, 16 replies.
- [jira] [Created] (FLINK-37911) [Helm] Reorganize Helm chart templates - posted by "Yi Chen (Jira)" <ji...@apache.org> on 2025/06/06 16:31:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP 505: Flink History Server Scalability Improvements, Remote Data Store Fetch and Per Job Fetch - posted by Allison <ac...@gmail.com> on 2025/06/06 21:04:25 UTC, 0 replies.
- [jira] [Created] (FLINK-37912) Typing the DataStream interfaces - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2025/06/06 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/06/07 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2025/06/07 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37915) Migrate Firehose and Kinesis Stream IT Test to E2E test package - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/06/08 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37916) FLIP-516: Add StreamPhysicalMultiJoin physical node - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/08 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37917) Add support for MultiJoinedRowData - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/08 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards. - posted by "hajimeni (Jira)" <ji...@apache.org> on 2025/06/09 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37919) Logback | Not applied - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2025/06/09 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37920) Reuse same utils for AsyncScalar, AsyncLookupJoin and AsyncMLPredict - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/09 06:20:00 UTC, 0 replies.
- Invitation to Slack - posted by Алексей Поздняков <03...@gmail.com> on 2025/06/09 09:25:26 UTC, 1 replies.
- [jira] [Created] (FLINK-37921) Refactor current implementation with implementation in FLIP-425 - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/09 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37922) Integrating Variant Type into Flink - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37924) Support variant field accessing - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37925) Support type casting between variant and primitive type - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37926) Support type casting between variant and constructed type - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/09 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37927) Add batch mode support for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/09 18:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37928) Support only insert only stream for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/09 19:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37929) Support cdc stream for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/09 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37930) Generalize the AsyncExecutionController - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 03:09:00 UTC, 0 replies.
- [DISCUSS] FLIP Suggestion: Externalize and Modernize Apache Pinot Connector - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/06/10 03:30:00 UTC, 0 replies.
- [KINDLY REMINDER] Flink 2.1 Release Sync 06/11/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/10 05:54:19 UTC, 0 replies.
- [jira] [Created] (FLINK-37931) LookupJoinUtil failed to compile - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/10 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability - posted by "Shruti Singhania (Jira)" <ji...@apache.org> on 2025/06/10 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37933) Move TransformationScan/SinkProvider out of planner - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/10 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37934) Get the case-sensitive variable names and method names of mysql are not standardized, and need to be adjusted - posted by "林健昌 (Jira)" <ji...@apache.org> on 2025/06/10 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37935) Allow to read WindowingStrategy by downstream projects - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/10 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/10 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2025/06/10 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37938) ml evaluate implementation for different task types - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 00:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37939) Metrics for ml predict function - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/11 00:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37940) Support retry for ML_PREDICT - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/11 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/11 02:57:00 UTC, 0 replies.
- [SUMMARY] Flink 2.1 Release Sync 06/11/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/11 06:50:57 UTC, 0 replies.
- [jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11 - posted by "guoqinglong (Jira)" <ji...@apache.org> on 2025/06/11 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data - posted by "sunshuxian (Jira)" <ji...@apache.org> on 2025/06/11 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/06/11 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/11 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN - posted by "slankka (Jira)" <ji...@apache.org> on 2025/06/11 13:45:00 UTC, 0 replies.
- [VOTE] FLIP-533: Cassandra Sink V2 - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/06/12 03:30:00 UTC, 6 replies.
- [jira] [Created] (FLINK-37947) Add sql hint to enable this optimization - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/12 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/12 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2025/06/12 10:44:00 UTC, 0 replies.
- Re: [VOTE] Release 1.20.2, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2025/06/12 11:54:46 UTC, 0 replies.
- [jira] [Created] (FLINK-37950) MongoDB connector should support ordered option - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2025/06/12 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/12 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/06/12 17:10:00 UTC, 0 replies.
- [VOTE] Release 1.19.3, release candidate #2 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2025/06/12 19:10:07 UTC, 4 replies.
- [jira] [Created] (FLINK-37953) Add OBF password obfuscation support for SSL configurations - posted by "Basapuram Kumar (Jira)" <ji...@apache.org> on 2025/06/13 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37954) Full the exception message when the regular could not be optimized into delta join while delta join strategy is FORCE - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/13 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/06/13 09:31:00 UTC, 0 replies.
- [VOTE] Release 1.20.2, release candidate #2 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2025/06/13 11:26:35 UTC, 3 replies.
- 2025/06/12 CHI Western time zone workgroup meeting minutes - posted by David Radley <da...@uk.ibm.com> on 2025/06/13 14:21:33 UTC, 0 replies.
- Error aware SQL streams - posted by David Radley <da...@uk.ibm.com> on 2025/06/13 15:06:26 UTC, 2 replies.
- [FLINK-37908] Requesting reviewers on PR - posted by Jonathan Du <jd...@atlassian.com.INVALID> on 2025/06/16 04:40:45 UTC, 0 replies.
- [jira] [Created] (FLINK-37956) Update SQL gateway for inline structured types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/16 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37957) Do not write empty lists to compiled plan - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/16 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37958) Flink CDC Sink connector support fluss - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/06/16 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37959) supported All postgres sql 14 field types. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/06/16 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/16 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37961) Support skip some state operators in TaskManager. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/06/16 12:14:00 UTC, 0 replies.
- Flink CDC and Debezium Version - posted by Mohsen Rezaei <mo...@gmail.com> on 2025/06/16 18:03:06 UTC, 1 replies.
- [jira] [Created] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 00:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover - posted by "yux (Jira)" <ji...@apache.org> on 2025/06/17 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37964) AsyncSinkWriterStateSerializer should consider the estimated size of request entry - posted by "Jiaan Geng (Jira)" <ji...@apache.org> on 2025/06/17 04:25:00 UTC, 0 replies.
- [KINDLY REMINDER] Flink 2.1 Release Sync 06/18/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/17 05:54:29 UTC, 0 replies.
- [jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/17 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37967) Add Confluent product and link to vendor solutions documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/06/17 14:08:00 UTC, 0 replies.
- [SUMMARY] Flink 2.1 Release Sync 06/18/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/18 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis - posted by "Radha Krishna Peteti (Jira)" <ji...@apache.org> on 2025/06/18 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37969) Allow Transformation subgraphs to be merged during translation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/06/18 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/18 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37971) SQL hints are dropped by planner when - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2025/06/18 16:23:00 UTC, 0 replies.
- CLIFrontend exit codes not reflecting application results? - posted by Allison <ac...@gmail.com> on 2025/06/18 18:29:52 UTC, 0 replies.
- [jira] [Created] (FLINK-37972) Support jar and UserClassLoader sharing between jobs. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/06/19 01:27:00 UTC, 0 replies.
- Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by Hao Li <hl...@confluent.io.INVALID> on 2025/06/19 05:21:29 UTC, 3 replies.
- 2025/06/19 CHI Eastern time zone workgroup meeting minutes - posted by David Radley <da...@uk.ibm.com> on 2025/06/19 10:46:53 UTC, 0 replies.
- [jira] [Created] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/06/19 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37974) Avoid confusion when declaring table arguments - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/06/19 13:03:00 UTC, 0 replies.
- [DISCUSS] FLIP-440: Annotation naming for PTFs - posted by Timo Walther <tw...@apache.org> on 2025/06/19 13:50:39 UTC, 6 replies.
- [jira] [Created] (FLINK-37975) sync a lot sharding table Post Transform failed - posted by "tongyp (Jira)" <ji...@apache.org> on 2025/06/19 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37976) DeltaJoinITCase seems to be struck in CI - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/20 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37977) Variant implements Serializable - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2025/06/20 12:24:00 UTC, 0 replies.
- Slack invitation - posted by Jure Prevc <j....@sportradar.com> on 2025/06/20 13:31:55 UTC, 2 replies.
- [jira] [Created] (FLINK-37978) Change max-buffer config to max-concurrent-operations - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/20 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/06/21 00:43:00 UTC, 0 replies.
- [ANNOUNCE] Flink 2.1 feature freeze - posted by Ron Liu <ro...@gmail.com> on 2025/06/21 02:54:14 UTC, 8 replies.
- [jira] [Created] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/22 21:57:00 UTC, 0 replies.
- [DISCUSS] FLIP-534 Reduce OLAP Query Latency In Flink Session Cluster. - posted by wj wang <ho...@gmail.com> on 2025/06/23 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/23 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37982) When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2025/06/23 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2025/06/23 13:19:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-533: Cassandra Sink V2 - posted by Poorvank Bhatia <pu...@gmail.com> on 2025/06/23 18:45:00 UTC, 0 replies.
- Help - Question on triaging slowness - posted by Siva Ram Gujju <si...@gmail.com> on 2025/06/23 23:23:31 UTC, 3 replies.
- Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint - posted by Qiang He <po...@gmail.com> on 2025/06/24 03:50:12 UTC, 2 replies.
- [jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/06/24 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2025/06/24 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2 - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/06/24 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37988) Add left join support - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37989) Add condition support - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/06/24 22:23:00 UTC, 0 replies.
- [SUMMARY] Flink 2.1 Release Sync 06/25/2025 - posted by Ron Liu <ro...@gmail.com> on 2025/06/25 06:32:45 UTC, 0 replies.
- [jira] [Created] (FLINK-37990) [Umbrella] Test Flink Release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 06:35:00 UTC, 0 replies.
- [KINDLY REMINDER] release-2.1 branch cut - posted by Ron Liu <ro...@gmail.com> on 2025/06/25 09:10:06 UTC, 0 replies.
- [jira] [Created] (FLINK-37991) Upgrade pemja to 0.6.x - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/06/25 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/25 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38006) Support Python for Flink AWS connectors in Flink 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/06/25 16:38:00 UTC, 0 replies.
- [DISCUSS] FLIP-535: Support Storage Partition Join in Flink - posted by Lu Niu <qq...@gmail.com> on 2025/06/25 22:36:38 UTC, 0 replies.
- [ANNOUNCE] Introducing "Debo" – A Unified Management Tool for the Hadoop Ecosystem, Including Flink Support - posted by Surafel Temesgen <de...@gmail.com> on 2025/06/26 07:43:31 UTC, 0 replies.
- [jira] [Created] (FLINK-38007) Prepare Flink 2.1 Release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38008) [Release-2.1] Create a new version in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38009) [Release-2.1] Select executing Release Manager - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38010) [Release-2.1] Create a release branch - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 08:49:00 UTC, 0 replies.
- [ANNOUNCE] release-2.1 branch cut - posted by Ron Liu <ro...@gmail.com> on 2025/06/26 09:06:59 UTC, 0 replies.
- [jira] [Created] (FLINK-38011) [Release-2.1] Prepare RC0 release - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38013) [Release-2.1] Cross team testing - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38015) [Release-2.1] Review and update documentation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38017) [Release-2.1] Add release note for release 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/26 09:37:00 UTC, 0 replies.
- [Jira Account Request] Inquiry on Registration Progress - posted by 张皓然 <96...@qq.com.INVALID> on 2025/06/26 11:22:19 UTC, 0 replies.
- [jira] [Created] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/06/26 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/26 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/06/27 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing - posted by "Thorne (Jira)" <ji...@apache.org> on 2025/06/27 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/27 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema - posted by "Keshav Kansal (Jira)" <ji...@apache.org> on 2025/06/27 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38024) Unify the timestamp types to use TimestampData with time zone information. - posted by "zjjiang (Jira)" <ji...@apache.org> on 2025/06/27 08:35:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 - posted by Daren Wong <da...@gmail.com> on 2025/06/27 13:22:37 UTC, 2 replies.
- [VOTE] Release flink-connector-aws v6.0.0, release candidate #1 - posted by Daren Wong <da...@gmail.com> on 2025/06/27 13:23:09 UTC, 2 replies.
- Minutres of 2025/06/26 CHI Western time zone workgroup meeting - posted by David Radley <da...@uk.ibm.com> on 2025/06/27 13:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-38025) Update Flink Doc for aws connector v6.0.0 - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/06/27 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38026) Oracle CDC scanNewlyAddedTableEnabled is case-sensitive to the database name, which results in the inability to match the database tables. - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2025/06/27 15:55:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink - posted by Alexander Matheson <a....@gmail.com> on 2025/06/27 21:23:42 UTC, 2 replies.
- [jira] [Created] (FLINK-38027) Apply simplify for watermark expresions - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/06/29 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/06/30 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/06/30 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2025/06/30 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38031) Support and Release Connectors for Flink 2.1 - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/06/30 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/06/30 07:29:00 UTC, 0 replies.
- Flink 1.20.1 - Window Tumbling Group has empty result but event_time and watermark have been set - posted by dmitri yanno mahayana <dm...@gmail.com> on 2025/06/30 07:56:33 UTC, 0 replies.
- [VOTE] FLIP-523 - Handle TLS Certificate Renewal - posted by Nicolas Fraison <ni...@datadoghq.com.INVALID> on 2025/06/30 07:58:11 UTC, 0 replies.
- [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink - posted by David Radley <da...@uk.ibm.com> on 2025/06/30 13:48:07 UTC, 0 replies.