You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-38855) Upgrade jackson to 2.20.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/02 08:42:00 UTC, 0 replies.
- Re: [jira] [Updated] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema - posted by Matthias Pohl <ma...@apache.org> on 2026/01/02 12:58:26 UTC, 0 replies.
- Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler - posted by Matthias Pohl via dev <de...@flink.apache.org> on 2026/01/02 16:14:27 UTC, 6 replies.
- [jira] [Created] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/04 15:10:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 21.0, release candidate #2 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/01/04 19:24:42 UTC, 1 replies.
- [jira] [Created] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference - posted by "featzhang (Jira)" <ji...@apache.org> on 2026/01/05 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38860) Remove flink shaded guava usage from operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/01/05 07:07:00 UTC, 0 replies.
- Re:Re: Re: [FLIP-558] Improvements to SinkUpsertMaterializer and changelog disorder - posted by Xuyang <xy...@163.com> on 2026/01/05 08:39:07 UTC, 9 replies.
- [jira] [Created] (FLINK-38861) Update Documentation to cover new CREATE/ALTER operations for MATERIALIZED TABLEs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/05 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/05 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" - posted by "Roman Grebennikov (Jira)" <ji...@apache.org> on 2026/01/05 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38864) HTTP Connector : Add IGNORE_STATUS_CODE http-completion-state - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/05 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/05 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode - posted by "Matt Cuento (Jira)" <ji...@apache.org> on 2026/01/05 21:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath - posted by "James Kan (Jira)" <ji...@apache.org> on 2026/01/05 23:24:00 UTC, 0 replies.
- Re: [ANNOUNCE] New Apache Flink Committer - Yuepeng Pan(RocMarshal) - posted by Maximilian Michels <mx...@apache.org> on 2026/01/06 13:06:20 UTC, 4 replies.
- [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline - posted by Daniel Rossos via dev <de...@flink.apache.org> on 2026/01/06 19:10:08 UTC, 2 replies.
- [jira] [Created] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/06 19:37:00 UTC, 0 replies.
- [DISCUSSION] Question on FLIP-450 network buffer removal and high-throughput regression in Flink 2.0 - posted by Han You via dev <de...@flink.apache.org> on 2026/01/06 22:37:12 UTC, 0 replies.
- Re: [DISCUSS] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner - posted by Yuepeng Pan <hi...@gmail.com> on 2026/01/07 01:33:35 UTC, 11 replies.
- Re: [DISCUSS] FLIP-560: Application Capability Enhancement - posted by Shengkai Fang <fs...@gmail.com> on 2026/01/07 02:08:32 UTC, 8 replies.
- [jira] [Created] (FLINK-38869) InitializationContext for KafkaSubscriber - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/07 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/07 08:08:00 UTC, 0 replies.
- [DISCUSS] FLIP-561: Restructure Flink documentation - posted by Martijn Visser <ma...@apache.org> on 2026/01/07 10:01:32 UTC, 13 replies.
- Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink - posted by Geng Biao <bi...@gmail.com> on 2026/01/07 12:10:08 UTC, 5 replies.
- Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler - posted by Matthias Pohl <ma...@apache.org> on 2026/01/07 15:25:33 UTC, 4 replies.
- Proposal to start a Flink digest blog. - posted by David Radley <da...@uk.ibm.com> on 2026/01/07 16:30:16 UTC, 2 replies.
- [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/07 20:18:33 UTC, 11 replies.
- [jira] [Created] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields - posted by "Vishal Kamlapure (Jira)" <ji...@apache.org> on 2026/01/07 21:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely - posted by "ConfX (Jira)" <ji...@apache.org> on 2026/01/08 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38873) mysql pipeline error when adding the same column - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2026/01/08 06:09:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 21.0, release candidate #3 - posted by Martijn Visser <ma...@apache.org> on 2026/01/08 11:20:07 UTC, 7 replies.
- [jira] [Created] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/08 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2026/01/08 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/08 23:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38878) Add PARSE_JSON/TRY_PARSE_JSON function to Flink CDC pipeline - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38879) Add VARIANT type support in Paimon pipeline sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/09 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38880) Add async scalar function support in Python - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/09 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38881) PostgreSQL Partition Table Routing Support - posted by "tchivs (Jira)" <ji...@apache.org> on 2026/01/09 07:12:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution - posted by Ramin Gharib <ra...@gmail.com> on 2026/01/09 07:34:10 UTC, 1 replies.
- [jira] [Created] (FLINK-38882) Introduce rules for async python scalar function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/09 08:38:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan - posted by Leonard Xu <xb...@gmail.com> on 2026/01/09 09:04:27 UTC, 17 replies.
- Re: [ANNOUNCE] New Apache Flink PMC Member �C Hang Ruan - posted by Biao Geng <bi...@gmail.com> on 2026/01/09 10:14:08 UTC, 0 replies.
- [jira] [Created] (FLINK-38883) Race condition of REST API and JRS entry might lead to inconsistent state - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/09 14:04:00 UTC, 0 replies.
- Re: Vendor-specific repos (re: flink-connector-aws) - posted by Robert Metzger <rm...@apache.org> on 2026/01/09 15:59:23 UTC, 3 replies.
- [DISCUSS] FLINK-38290 - Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated - posted by Royston Tauro <ta...@gmail.com> on 2026/01/10 08:05:04 UTC, 0 replies.
- [jira] [Created] (FLINK-38884) Migrate IncrementalAggregateRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/10 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/10 23:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38886) Provide GenericRecordData in Pipeline public API - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38887) YAML Transform module supports nested types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38888) YAML Pipeline supports item subscription of complex types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38889) YAML Kafka sink connector supports serializing complex types - posted by "yux (Jira)" <ji...@apache.org> on 2026/01/11 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/11 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38891) Migrate MiniBatchIntervalInferRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/11 15:00:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler - posted by Yuepeng Pan <hi...@gmail.com> on 2026/01/12 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38899) Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38898) Introduce the Rescales/Overview sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38901) Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38902) Add user instructions and usage documentation for FLIP-487. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2026/01/12 10:59:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-aws v5.1.0, release candidate #2 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/12 12:28:34 UTC, 0 replies.
- [jira] [Created] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/12 13:37:00 UTC, 0 replies.
- [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder - posted by Dawid Wysakowicz <dw...@apache.org> on 2026/01/12 14:33:34 UTC, 7 replies.
- [jira] [Created] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/12 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38905) YAML Transform to handle dirty data gracefully - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/13 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38906) Polish YAML transform built-in functions - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/01/13 06:27:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-shaded 21.0, release candidate #3 - posted by Martijn Visser <ma...@apache.org> on 2026/01/13 09:47:52 UTC, 0 replies.
- [ANNOUNCE] Apache Flink-shaded 21.0 released - posted by Martijn Visser <ma...@apache.org> on 2026/01/13 09:48:57 UTC, 0 replies.
- [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler - posted by Yuepeng Pan <hi...@gmail.com> on 2026/01/13 15:46:21 UTC, 13 replies.
- [jira] [Created] (FLINK-38907) Records lost using filtered autocreate mode - posted by "Gio Gutierrez (Jira)" <ji...@apache.org> on 2026/01/13 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/13 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38909) Unable to delete S3 checkpoint due to presence of default file - posted by "CHANHAE OH (Jira)" <ji...@apache.org> on 2026/01/14 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38910) mysql-cdc-connector datastrea support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/14 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/14 05:48:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause - posted by Martijn Visser <ma...@apache.org> on 2026/01/14 09:45:36 UTC, 2 replies.
- Kubernetes Operator 1.14.0 release planning - posted by Gyula Fóra <gy...@gmail.com> on 2026/01/14 11:41:55 UTC, 6 replies.
- [jira] [Created] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with nested objects - posted by "david radley (Jira)" <ji...@apache.org> on 2026/01/14 12:03:00 UTC, 0 replies.
- FLINK-38913 - posted by David Radley <da...@uk.ibm.com> on 2026/01/14 12:07:28 UTC, 0 replies.
- [jira] [Created] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/14 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment - posted by "Daniel Rossos (Jira)" <ji...@apache.org> on 2026/01/14 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2026/01/14 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 19:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/01/14 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38921) osc support custom regx - posted by "谢波 (Jira)" <ji...@apache.org> on 2026/01/15 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38922) Cache Maven dependencies during documentation build - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/15 10:19:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-aws v5.1.0 released - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/15 11:17:06 UTC, 0 replies.
- [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector - posted by Efrat Levitan <ef...@gmail.com> on 2026/01/15 11:37:44 UTC, 3 replies.
- [jira] [Created] (FLINK-38924) Redirect users to main page when encountering a 404 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38925) Update Matomo URL to the right domain - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/15 13:18:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder - posted by Dawid Wysakowicz <dw...@apache.org> on 2026/01/15 14:46:52 UTC, 0 replies.
- [jira] [Created] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38927) Support ON CONFLICT in SqlParser - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38929) Add the ON CONFLICT configuration options - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2026/01/15 14:51:00 UTC, 0 replies.
- [VOTE] FLIP-561: Restructure Flink documentation - posted by Martijn Visser <ma...@apache.org> on 2026/01/15 16:35:38 UTC, 14 replies.
- [jira] [Created] (FLINK-38930) Filtering record before processing without spilling strategy - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/01/15 16:52:00 UTC, 0 replies.
- Enhance Flink DynamicKafkaSource - posted by Bowen Li <bl...@apache.org> on 2026/01/15 20:31:33 UTC, 2 replies.
- Proposal for DemultiplexingSink - posted by Rion Williams <ri...@gmail.com> on 2026/01/16 03:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-38931) Support finish method in Python Table Function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/16 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2026/01/16 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38933) python udx supports get_index_of_this_subtask - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/16 06:13:00 UTC, 0 replies.
- [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner - posted by Yuepeng Pan <hi...@gmail.com> on 2026/01/16 07:12:34 UTC, 6 replies.
- Re: [VOTE] FLIP-339: Support Adaptive Partition Selection forStreamPartitioner - posted by o酷鱼o <zr...@qq.com> on 2026/01/16 08:40:13 UTC, 2 replies.
- [jira] [Created] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored - posted by "John Watson (Jira)" <ji...@apache.org> on 2026/01/16 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38935) HTTP Connector Fixe Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. - posted by "David Radley (Jira)" <ji...@apache.org> on 2026/01/16 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 - posted by "liuerbao (Jira)" <ji...@apache.org> on 2026/01/17 06:47:00 UTC, 0 replies.
- [DISCUSS] SSL hostname verification - posted by Mate Czagany <cz...@gmail.com> on 2026/01/17 08:29:01 UTC, 1 replies.
- [jira] [Created] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/01/17 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/17 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 00:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38941) Add Python building blocks for Async Python Scalar Function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/19 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38942) Add documentation for async python scalar function - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/01/19 07:01:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner - posted by Yuepeng Pan <hi...@gmail.com> on 2026/01/19 08:11:41 UTC, 0 replies.
- [jira] [Created] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38944) Introduce a benchmark on adaptive partition selection for rescale partitioner and rebalance partitioner - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/19 08:28:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-561: Restructure Flink documentation - posted by Martijn Visser <ma...@apache.org> on 2026/01/19 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38945) [FLIP-561] Restructure Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/19 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38946) Update Datadog API endpoint from app.datadoghq to api.datadoghq - posted by "Ivan Stoiev (Jira)" <ji...@apache.org> on 2026/01/19 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38948) Document SINGLE_VALUE aggregate function - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/01/19 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38949) unpack_build_artifact.sh script speed improvement - posted by "Tom Ho (Jira)" <ji...@apache.org> on 2026/01/19 16:19:00 UTC, 0 replies.
- Re: Optional configuration parameters for better performance - posted by Rahul Teke <ra...@gmail.com> on 2026/01/19 19:44:25 UTC, 3 replies.
- [jira] [Created] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses - posted by "Sebastien Pereira (Jira)" <ji...@apache.org> on 2026/01/19 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38951) Upgrade pemja to 0.5.6 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2026/01/20 01:35:00 UTC, 0 replies.
- [VOTE] FLIP-560: Application Capability Enhancement - posted by Yi Zhang <zh...@163.com> on 2026/01/20 02:03:34 UTC, 7 replies.
- [jira] [Created] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/20 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38953) Cleanup configurations for SSL hostname verification - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/20 17:15:00 UTC, 0 replies.
- JSON_STRING and helper utilities around VARIANT data type - posted by Swapna Marru <sw...@gmail.com> on 2026/01/20 23:53:28 UTC, 1 replies.
- [jira] [Created] (FLINK-38954) Flink Benchmark Score Decreases After Upgrading JDK Versions of Flink Engine and User Program - posted by "zhangxing (Jira)" <ji...@apache.org> on 2026/01/21 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/21 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38956) The Web UI cannot automatically show the latest edge name for AdaptiveScheduler - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/21 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/01/21 17:17:00 UTC, 0 replies.
- [discussion] Prevent direct edits to FlinkDeployments owned by FlinkBlueGreenDeployments - posted by James Kan via dev <de...@flink.apache.org> on 2026/01/21 17:46:00 UTC, 1 replies.
- [DISCUSS] Planning Flink 2.3 - posted by David Anderson <da...@apache.org> on 2026/01/21 21:43:41 UTC, 6 replies.
- Reviewers for Kafka Connector Projection Pushdown - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/01/21 22:33:26 UTC, 1 replies.
- [jira] [Created] (FLINK-38958) Support provided lib archives for YARN application mode - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/01/21 22:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode - posted by archit goyal <go...@gmail.com> on 2026/01/21 23:29:35 UTC, 0 replies.
- [jira] [Created] (FLINK-38959) Added support for schema change in the postgres pipeline connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2026/01/22 01:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility - posted by "Han Yin (Jira)" <ji...@apache.org> on 2026/01/22 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/22 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38962) Add OpenSearch 3.x connector support - posted by "Julian Dimitrov (Jira)" <ji...@apache.org> on 2026/01/22 16:32:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/22 20:27:49 UTC, 4 replies.
- [DISCUSS] Release flink-connector-parent v2.0.0 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/22 20:47:37 UTC, 4 replies.
- [jira] [Created] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/22 22:20:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-560: Application Capability Enhancement - posted by Yi Zhang <zh...@163.com> on 2026/01/23 02:20:28 UTC, 0 replies.
- [jira] [Created] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" - posted by "Tao Wang (Jira)" <ji...@apache.org> on 2026/01/23 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38966) Update rsync Github Actions to 8.0.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/01/23 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/01/23 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38968) Add toCatalogTable method to CatalogMaterializedTable interface - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/01/23 14:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing - posted by jk liu <jk...@gmail.com> on 2026/01/23 15:11:07 UTC, 0 replies.
- [jira] [Created] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/23 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/25 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule - posted by "Roman Rybak (Jira)" <ji...@apache.org> on 2026/01/25 22:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38972) FLIP-560: Application Capability Enhancement - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38973) Job ID assignment and matching based on name - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38974) Handle jobs during HA recovery - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38975) Re-execute applications after HA recovery in session mode - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38976) Support multiple jobs in an application - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38978) Expose JM config for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38977) Expose exceptions for applications - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2026/01/26 02:32:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - David Radley - posted by Robert Metzger <rm...@apache.org> on 2026/01/26 13:56:34 UTC, 38 replies.
- [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/26 18:32:09 UTC, 5 replies.
- [jira] [Created] (FLINK-38979) flink-tests-java17 skipped while java21 build - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/26 19:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/27 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2026/01/27 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/01/27 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38984) Python interpreter not found when using thread mode (pemja) - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/01/27 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38985) [Doc] Add document for VARIANT type and related functions - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/01/27 12:05:00 UTC, 0 replies.
- Proposal to release the HTTP connector version 1.0 and 2.0 - posted by David Radley <da...@uk.ibm.com> on 2026/01/27 14:12:08 UTC, 1 replies.
- [jira] [Created] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions - posted by "Swapna Marru (Jira)" <ji...@apache.org> on 2026/01/27 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem - posted by "yunjiong zhao (Jira)" <ji...@apache.org> on 2026/01/28 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/28 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38989) Support resetting backlog status - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2026/01/28 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38990) Support configurable initial delay for first checkpoint trigger - posted by "Liu (Jira)" <ji...@apache.org> on 2026/01/28 08:41:00 UTC, 0 replies.
- Re: [DISCUSS] Status of Statefun Project - posted by Martijn Visser <ma...@apache.org> on 2026/01/28 11:27:38 UTC, 3 replies.
- [jira] [Created] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming - posted by "Vishal P R (Jira)" <ji...@apache.org> on 2026/01/28 17:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2026/01/28 19:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38993) Move query change validation logic from converter to operation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/28 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli - posted by "Mingliang Zhu (Jira)" <ji...@apache.org> on 2026/01/29 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38995) Update the current Status of Disaggregated State & ForSt - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2026/01/29 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38996) Add origin transform sql expression into exception message - posted by "Jia Fan (Jira)" <ji...@apache.org> on 2026/01/29 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38997) Job can get stuck in state transition because unexpected error during ExecutionGraph creation - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/01/29 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2026/01/29 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-38999) License lineage files - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/01/29 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39000) Avoid redundant seeks during operator list state restore - posted by "Ivan Torres (Jira)" <ji...@apache.org> on 2026/01/29 19:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39001) [doc] Supplement the documentation regarding dynamic table addition - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/01/30 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-39002) Could not resolve ResourceManager because of NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/01/30 08:39:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws v6.0.0, release candidate #4 - posted by Ferenc Csaky <fe...@pm.me> on 2026/01/30 10:59:53 UTC, 2 replies.
- [jira] [Created] (FLINK-39003) Inaccurate millisBehindLatest metric from the Kinesis source connector on failover - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2026/01/30 12:25:00 UTC, 0 replies.