You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses - posted by "Kaivalya Apte (Jira)" <ji...@apache.org> on 2026/07/01 04:43:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API - posted by Ramin Gharib <ra...@gmail.com> on 2026/07/01 07:35:16 UTC, 3 replies.
- [jira] [Created] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/07/01 09:06:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink - posted by Cole Bailey via dev <de...@flink.apache.org> on 2026/07/01 09:27:18 UTC, 7 replies.
- Re: [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core - posted by Li Wang <li...@gmail.com> on 2026/07/01 10:21:12 UTC, 0 replies.
- [jira] [Created] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2026/07/01 10:37:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-599: State Catalog - posted by Han Yin <al...@gmail.com> on 2026/07/01 11:56:59 UTC, 21 replies.
- [jira] [Created] (FLINK-40039) CTAS/RTAS do not work for PTFs with set semantics and PARTITION BY - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/01 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40040) SchemaRegistry loses coordination responses when a failure's cause is a user-classloader-only class (e.g. a JDBC driver exception), causing the job to hang until rpcTimeout and enter a restart loop - posted by "Jiyong Wang (Jira)" <ji...@apache.org> on 2026/07/01 13:30:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-588: Support per-job delegation tokens - posted by Gabor Somogyi <ga...@gmail.com> on 2026/07/01 14:15:08 UTC, 0 replies.
- [jira] [Created] (FLINK-40041) Update JDBC connector version to 3.4.0 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/07/01 14:16:00 UTC, 0 replies.
- Re: [VOTE] FLIP-588: Support per-job delegation tokens - posted by Gabor Somogyi <ga...@gmail.com> on 2026/07/01 14:16:20 UTC, 5 replies.
- [jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/07/01 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/07/01 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/01 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/01 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40046) Upgrade @antv/g2 to v5 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/01 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ - posted by "Marc Demierre (Jira)" <ji...@apache.org> on 2026/07/01 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/01 22:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/07/02 05:12:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region - posted by Gen Luo <lu...@gmail.com> on 2026/07/02 07:18:53 UTC, 4 replies.
- [jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/02 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml - posted by "lisa (Jira)" <ji...@apache.org> on 2026/07/02 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED - posted by "SkylerLin (Jira)" <ji...@apache.org> on 2026/07/02 12:52:00 UTC, 0 replies.
- RE: Apache infrastructure PR wanting to change default rulesets. - posted by David Radley <da...@uk.ibm.com> on 2026/07/02 16:14:36 UTC, 1 replies.
- [jira] [Created] (FLINK-40053) Log4j 2.26.1 bump - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/02 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40054) Update aircompressor to 2.0.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/02 19:02:00 UTC, 0 replies.
- Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) - posted by Sergio Chong Loo <sc...@apple.com> on 2026/07/02 20:20:03 UTC, 2 replies.
- Re: [DISCUSS] FLIP-XXX Monotonic Counters support - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/07/02 21:23:34 UTC, 1 replies.
- 退订 - posted by 林 <13...@qq.com> on 2026/07/03 01:53:40 UTC, 4 replies.
- [jira] [Created] (FLINK-40055) Operator serializes managed-deployment config in its own YAML dialect, breaking Flink 1.x deployments when the operator itself runs on standard config.yaml - posted by "Gerk Elznik (Jira)" <ji...@apache.org> on 2026/07/03 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40056) Support anchor navigation for pyflink configuration options - posted by "chenzihao (Jira)" <ji...@apache.org> on 2026/07/03 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled - posted by "ericzeng (Jira)" <ji...@apache.org> on 2026/07/03 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/03 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility - posted by "Sumin Joo (Jira)" <ji...@apache.org> on 2026/07/03 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml - posted by "ChanBin OH (Jira)" <ji...@apache.org> on 2026/07/03 09:56:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-http v1.0.0 released - posted by David Radley <da...@uk.ibm.com> on 2026/07/03 10:35:09 UTC, 0 replies.
- [jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/03 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/03 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/03 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/03 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/03 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/04 00:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/07/04 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches - posted by "Harshit Gupta (Jira)" <ji...@apache.org> on 2026/07/05 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/05 17:41:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators - posted by Soumitra Kumar <ku...@gmail.com> on 2026/07/05 21:58:10 UTC, 3 replies.
- Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer - posted by weijie guo <gu...@gmail.com> on 2026/07/06 02:28:20 UTC, 1 replies.
- [jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator - posted by "dylanhz (Jira)" <ji...@apache.org> on 2026/07/06 04:11:00 UTC, 0 replies.
- Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/06 06:13:22 UTC, 8 replies.
- [jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/06 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/06 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/06 07:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign - posted by Dennis-Mircea Ciupitu <de...@gmail.com> on 2026/07/06 08:51:40 UTC, 3 replies.
- [jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/07/06 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/07/06 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/07/06 10:03:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-588: Support per-job delegation tokens - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/07/06 11:08:22 UTC, 0 replies.
- [jira] [Created] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) - posted by "Fred Teunissen (Jira)" <ji...@apache.org> on 2026/07/06 17:05:00 UTC, 0 replies.
- Help Needed for JDBC Release v3.4.0 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/06 17:23:09 UTC, 3 replies.
- [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/06 17:25:25 UTC, 2 replies.
- [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/06 17:31:04 UTC, 1 replies.
- [jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 - posted by "Chris Lu (Jira)" <ji...@apache.org> on 2026/07/06 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/06 20:52:00 UTC, 0 replies.
- [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region - posted by 熊饶饶 <xi...@gmail.com> on 2026/07/07 04:07:08 UTC, 14 replies.
- [jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink - posted by "reswqa (Jira)" <ji...@apache.org> on 2026/07/07 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/07/07 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2026/07/07 07:33:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion - posted by Chanhae Oh <dh...@gmail.com> on 2026/07/07 10:09:01 UTC, 14 replies.
- [jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/07 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40089) Add JSON_LENGTH function - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/07 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/07 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2 - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/07/07 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40092) BlueGreen transition should finalize immediately after deleting previous deployment - posted by "Calico Shop (Jira)" <ji...@apache.org> on 2026/07/07 15:25:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/07 16:45:10 UTC, 7 replies.
- [jira] [Created] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/07/07 17:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40094) DynamicKafkaSource should mark removed split outputs idle before release - posted by "Xin Gao (Jira)" <ji...@apache.org> on 2026/07/07 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40095) JSON aggregation functions failing in group window aggregate - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2026/07/08 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/08 07:45:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer - posted by zihao chen <is...@gmail.com> on 2026/07/08 08:16:29 UTC, 0 replies.
- [jira] [Created] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer - posted by "chenzihao (Jira)" <ji...@apache.org> on 2026/07/08 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/08 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/08 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40100) Reduce ArchUnit violations: remove direct usage of Flink-internal/shaded APIs in flink-connector-http - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/07/08 13:33:00 UTC, 0 replies.
- [DISCUSS] FLIP-601: Cloud-Agnostic Client-Side Encryption for SDK-Native Filesystems - posted by Aleksandr Iushmanov <iz...@gmail.com> on 2026/07/08 14:14:48 UTC, 0 replies.
- [jira] [Created] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/07/08 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead - posted by "ericzeng (Jira)" <ji...@apache.org> on 2026/07/09 00:47:00 UTC, 0 replies.
- Re: [DISCUSS] State Schema Evolution for RowData - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/09 06:14:24 UTC, 5 replies.
- [jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4 - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2026/07/09 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/07/09 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager - posted by "xiechenling (Jira)" <ji...@apache.org> on 2026/07/09 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/07/09 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/07/09 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database - posted by "João Boto (Jira)" <ji...@apache.org> on 2026/07/09 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/09 12:08:00 UTC, 0 replies.
- [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input - posted by Fabian Hueske <fh...@apache.org> on 2026/07/09 13:24:09 UTC, 7 replies.
- [jira] [Created] (FLINK-40110) Connectors/OpenSearch: Bump flink.version to 2.1.2 in flink-connector-opensearch - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/09 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40111) Keyless upsert sink should fall back to retract when the input has no upsert key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/09 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40112) Report a changelog mode mismatch instead of a generic planning error - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/09 15:02:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/09 18:00:00 UTC, 9 replies.
- [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/09 18:00:00 UTC, 9 replies.
- [jira] [Created] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/07/09 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40114) Leader information permanently erased when a change event races a pending confirmation - posted by "Prashant Bhardwaj (Jira)" <ji...@apache.org> on 2026/07/09 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40115) Document timestamp reliability for bounded-out-of-orderness watermarks - posted by "Hancheng Deng (Jira)" <ji...@apache.org> on 2026/07/10 01:28:00 UTC, 0 replies.
- Re: Re: [DISCUSS] Add UDF Metrics - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/10 02:20:51 UTC, 4 replies.
- [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink - posted by Dian Fu <di...@gmail.com> on 2026/07/10 05:22:26 UTC, 10 replies.
- [RESULT][VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region - posted by 熊饶饶 <xi...@gmail.com> on 2026/07/10 08:29:44 UTC, 0 replies.
- [jira] [Created] (FLINK-40116) Support more predicates for filter pushdown during savepoint scan - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2026/07/10 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40117) Web dashboard: extend Vitest smoke-test coverage to remaining high-traffic views - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/10 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40118) Web dashboard: SubTask TimeLine shows "N - undefined" instead of the task endpoint - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/10 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40119) Blue/Green: after an aborted transition, the next deploy deletes Blue immediately instead of waiting the deletion delay - posted by "Calico Shop (Jira)" <ji...@apache.org> on 2026/07/10 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/10 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/07/10 21:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40122) Expose a public getter for the persisted RowData field names - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/11 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/07/11 07:22:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems - posted by Samrat Deb <de...@gmail.com> on 2026/07/12 05:44:14 UTC, 2 replies.
- Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector - posted by Efrat Levitan <ef...@gmail.com> on 2026/07/12 08:09:51 UTC, 0 replies.
- [jira] [Created] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/12 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40125) Add auto cancel for concurrently run jobs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/12 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40126) Implement Topic integrity checks in Kafka Connector - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/07/12 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40127) JDBC connector: 37 files ship without the required ASF license header - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/12 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/07/12 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Datasteam - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/07/12 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/13 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/07/13 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/13 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40133) Update HBase version to 2.6.6 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/07/13 12:53:00 UTC, 0 replies.
- [VOTE] FLIP-599: State Catalog - posted by Gyula Fóra <gy...@gmail.com> on 2026/07/13 16:38:02 UTC, 12 replies.
- [jira] [Created] (FLINK-40134) Bump maven-rat-plugin to 0.17 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/13 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2026/07/13 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/07/13 21:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/07/13 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40138) Migration test snapshot generator does not drive the JUnit 5 lifecycle, breaking snapshot generation for JUnit-5-migrated tests in flink-tests - posted by "David Anderson (Jira)" <ji...@apache.org> on 2026/07/13 21:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/07/13 21:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/07/13 22:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40141) Make IS_DECIMAL, IS_DIGIT, and IS_ALPHA return NULL for NULL input - posted by "dylanhz (Jira)" <ji...@apache.org> on 2026/07/14 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40142) [Table SQL / API] Support partition transform expressions in PARTITIONED BY clause - posted by "liting liu (Jira)" <ji...@apache.org> on 2026/07/14 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options - posted by "caosurong (Jira)" <ji...@apache.org> on 2026/07/14 03:32:00 UTC, 0 replies.
- [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/14 03:35:49 UTC, 4 replies.
- [jira] [Created] (FLINK-40144) Avoid query database when only get table column - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2026/07/14 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40145) flink-model-triton javadoc fails on JDK 11: kotlin.stdlib split-package - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/07/14 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40146) Support AlterTableCommentEvent in StarRocks sink - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/14 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation - posted by "Fred Teunissen (Jira)" <ji...@apache.org> on 2026/07/14 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40148) TableIdRouter resolves wrong sink table when source regex has multi-digit suffix and sink-table has no back-reference - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/07/14 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40149) Rename lookup option asyncPolling to async-polling for Flink naming consistency - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/07/14 17:02:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Add support for GROUP BY , GROUP BY ALL, and ORDER BY ALL - posted by Tisya Bhatia via dev <de...@flink.apache.org> on 2026/07/14 17:17:30 UTC, 5 replies.
- [jira] [Created] (FLINK-40150) Remove assumeTrue with cluster rebuild from RescaleTimelineITCase - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2026/07/14 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40151) Align YAML Transform BETWEEN, IN, and LIKE semantics with Flink SQL - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/15 06:34:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) - posted by Do...@swisscom.com on 2026/07/15 06:40:06 UTC, 6 replies.
- [jira] [Created] (FLINK-40152) PostgreSQL CDC connector captures case-variant tables when only one is specified - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2026/07/15 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40153) CREATE TABLE LIKE cannot resolve inherited metadata columns in a derived watermark expression - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2026/07/15 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40154) Upgrade Parquet dependency to 1.16.0 - posted by "David Chaava (Jira)" <ji...@apache.org> on 2026/07/15 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40155) Kubernetes Operator: support and end-to-end test Helm 4 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/15 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40156) FLIP-600: Independent Checkpoint Based On Pipeline Region - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/07/15 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40157) MapState#asyncPutAll on ForSt: reads chained on the returned StateFuture see the new keys but null values - posted by "Francis (Jira)" <ji...@apache.org> on 2026/07/16 07:49:00 UTC, 0 replies.
- Possible race in MapState#asyncPutAll on ForSt: chained reads see keys but null values - posted by Francis Altomare <fr...@helpscout.com> on 2026/07/16 07:53:51 UTC, 1 replies.
- [jira] [Created] (FLINK-40158) Add translation rules for SNAPSHOT function in batch mode - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/07/16 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink - posted by "Bread S (Jira)" <ji...@apache.org> on 2026/07/16 11:31:00 UTC, 0 replies.
- Re: Reviewers for Kafka Connector Projection Pushdown - posted by Farooq Qaiser via dev <de...@flink.apache.org> on 2026/07/16 21:28:16 UTC, 0 replies.
- [jira] [Created] (FLINK-40160) Casting 'NaN' to Float or Double throws CompileException - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/17 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40161) Log original MySQL DDL events before parsing - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/17 09:08:00 UTC, 0 replies.
- Flip-587 - posted by David Radley <da...@uk.ibm.com> on 2026/07/17 09:55:56 UTC, 1 replies.
- [jira] [Created] (FLINK-40162) Fast-running FlinkSessionJob does not reflect actual state of the job - posted by "Milind L (Jira)" <ji...@apache.org> on 2026/07/17 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40163) Add a new baseline nightly build to the Github Actions pipeline - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/07/17 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully - posted by "Milind L (Jira)" <ji...@apache.org> on 2026/07/17 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/07/17 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40166) SQL query parsing fails if current catalog is unreachable - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/07/17 20:27:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink - posted by Dian Fu <di...@gmail.com> on 2026/07/18 01:40:12 UTC, 0 replies.
- [RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/18 04:31:36 UTC, 0 replies.
- [jira] [Created] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40169) Add target option to the EARLY_FIRE hint - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 22:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 23:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40173) Add restore coverage for early-fire interval join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 23:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40171) Emit and retract early-fire results in the interval join operator - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 23:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40172) Support processing-time early fire on a row-time interval join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 23:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40174) Document the EARLY_FIRE hint for interval joins - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/07/18 23:32:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-599: State Catalog - posted by Gyula Fóra <gy...@gmail.com> on 2026/07/19 07:49:38 UTC, 0 replies.
- [jira] [Created] (FLINK-40175) FLIP-599: State Catalog - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40176) Introduce basic StateCatalog functionality - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40177) Support reading Keyed and Flattened Keyed states - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40178) Keyed state cataloging integration test - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40179) Support windowed states in state catalog - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40180) Non-keyed state support in StateCatalog - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/07/19 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40181) Make spotless checking changes since last green build in ci - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/19 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40182) ArrayToArray and MapToMap generate code which might fail with NPE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/19 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40183) Add regression coverage for CheckpointCoordinator scheduling - posted by "amirhossein deljouyi (Jira)" <ji...@apache.org> on 2026/07/19 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40184) Remove inconsistency checks from DynamoDB Connector - posted by "Abhi Gupta (Jira)" <ji...@apache.org> on 2026/07/19 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40185) Introduce DataFrame API in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40186) Support the basic functionality of DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40187) Introduce DataType class in DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40188) Check connection string at the start of job for opensearch distributor - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/07/20 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/07/20 04:47:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/20 05:06:40 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/20 05:07:47 UTC, 0 replies.
- [jira] [Created] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40191) Add aggregation support to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40192) Add as-of join support to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40193) Add join_lateral support to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40194) Add drop_duplicates to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40196) Add missing-value handling to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40195) Flink kubernetes operator certificate secret name should be configurable - posted by "Sebastian Struß (Jira)" <ji...@apache.org> on 2026/07/20 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40197) Add sql bindings to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/07/20 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40200) TaskManager locking up in org.rocksdb.Checkpoint.createCheckpoint - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/07/20 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40201) [Oracle CDC] Fix compatibility with Oracle 26ai and Debezium 3.4.2.Final - posted by "Mohammad Suhel Ksolves Cassandra Experties (Jira)" <ji...@apache.org> on 2026/07/20 10:46:00 UTC, 0 replies.
- [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 - posted by wenjin <we...@gmail.com> on 2026/07/20 12:39:42 UTC, 5 replies.
- Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views - posted by FeatZhang <fe...@apache.org> on 2026/07/20 13:32:26 UTC, 0 replies.
- Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function - posted by FeatZhang <fe...@apache.org> on 2026/07/20 13:35:08 UTC, 0 replies.
- [VOTE] FLIP-527: State Schema Evolution for RowData - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/21 00:59:13 UTC, 5 replies.
- [jira] [Created] (FLINK-40202) HybridSplitAssigner may initialize enumerator metrics concurrently with snapshot split assignment - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/07/21 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40203) Add explicit option for Flink SQL-compatible YAML Transform expression semantics - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/21 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40204) Introduce statement-level codegen for YAML Transform expressions - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/21 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40205) PTF are failing in case of usage multiple PARTITION/ORDER BY - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/21 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40206) Upgrade pulsar client to latest patch version to address critical vulnerabilities - posted by "Nikola Stanisavljevic (Jira)" <ji...@apache.org> on 2026/07/21 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40207) Make NaN and Infinity case-insensitive - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/21 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC - posted by "Aleksandr Iushmanov (Jira)" <ji...@apache.org> on 2026/07/21 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40209) Introduce Regional Checkpoint core mechanism and notification dispatch - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/07/21 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40210) Add Per-Region timeout handling and bounded source forced global checkpoint - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/07/21 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40212) Add Regional Checkpoint user documentation - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/07/21 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40211) Add Regional Checkpoint metrics, REST API and Web UI support - posted by "raoraoxiong (Jira)" <ji...@apache.org> on 2026/07/21 13:43:00 UTC, 0 replies.
- Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage - posted by Zakelly Lan <za...@gmail.com> on 2026/07/21 16:16:04 UTC, 1 replies.
- Help Needed for JDBC Release v3.4.0 & v4.1.0 - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/22 01:30:00 UTC, 7 replies.
- [jira] [Created] (FLINK-40213) Preserve JSON_OBJECTAGG key when wrapping value - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2026/07/22 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2026/07/22 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40215) AvroSerializer is not adhering to pojo rules of avro generation - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/07/22 03:22:00 UTC, 0 replies.
- FLINK-37686: ForSt consecutive checkpoint failures after JM deletes reused files (production report, 2.2.1) - posted by Francis Altomare <fr...@helpscout.com> on 2026/07/22 08:19:59 UTC, 0 replies.
- [jira] [Created] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits - posted by "kim (Jira)" <ji...@apache.org> on 2026/07/22 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40217) Variant.toJson() can emit invalid JSON for numbers that overflow to non-finite doubles - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/22 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40218) Allow building a Variant from a token source, without a String round-trip - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/22 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40219) Incorrect output type of LateralSnapshotJoin for build-side time attribute with inconsistent nullability - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/07/22 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40220) Update the version of JDBC connector docs - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/07/22 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40221) Update weekly.yml of jdbc connector for jdbc-3.4.0 and jdbc-4.1.0 - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/07/22 15:33:00 UTC, 0 replies.
- FLINK-38023: PR #28161 code review request - posted by Avi Sanwal <av...@gmail.com> on 2026/07/23 03:14:00 UTC, 0 replies.
- RE: Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector - posted by Wenhao Ji <pr...@gmail.com> on 2026/07/23 03:37:22 UTC, 1 replies.
- [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion - posted by Chanhae Oh <dh...@gmail.com> on 2026/07/23 06:59:06 UTC, 5 replies.
- [jira] [Created] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals - posted by "Timo Theusner (Jira)" <ji...@apache.org> on 2026/07/23 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/23 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40224) Move CI scripts used by both GHA and AZP out of tools/azure-pipelines - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/07/23 11:21:00 UTC, 0 replies.
- Flink operator stuck with "Job not found" - posted by Filippo Ghibellini <fi...@zalando.de> on 2026/07/23 12:14:44 UTC, 1 replies.
- [jira] [Created] (FLINK-40225) JSON parsing for json functions accepts trailing content after the first value - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/23 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40226) Standalone session cluster JM recovery enters infinite MISSING loop and fails with HTTP 409 on TM Deployment when TaskManager pods still exist - posted by "Aniruddh J (Jira)" <ji...@apache.org> on 2026/07/23 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore - posted by "Yuhan Hao (Jira)" <ji...@apache.org> on 2026/07/23 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40228) Bump frontend-maven-plugin to 2.0.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/23 20:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40229) Introduce HttpSinkConfig and wire core sink options via ReadableConfig - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/07/23 22:38:00 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 - posted by wenjin <we...@gmail.com> on 2026/07/24 07:04:34 UTC, 0 replies.
- [jira] [Created] (FLINK-40230) StringToBinary and RawToBinary cast rules might generate runtime code with useless array copy - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/24 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40231) HistoryServerArchiveFetcherTest.testArchiveStateTransition is flaky in CI - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/24 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null - posted by "Fan Deng (Jira)" <ji...@apache.org> on 2026/07/24 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40233) JSON functions return NULL when sharing a parsed input - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/24 10:51:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-jdbc 3.4.0 & 4.1.0 released - posted by Yuepeng Pan <pa...@apache.org> on 2026/07/24 12:27:23 UTC, 0 replies.
- [jira] [Created] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2026/07/24 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40235) FLIP-27 source subtask stalls the watermark after all its splits finish - posted by "Jing Hung (Jira)" <ji...@apache.org> on 2026/07/24 19:42:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-527: State Schema Evolution for RowData - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/25 01:27:37 UTC, 0 replies.
- [jira] [Created] (FLINK-40236) _infer_type infers ARRAY for a list whose first element is None - posted by "Nikolaus Schuetz (Jira)" <ji...@apache.org> on 2026/07/25 04:24:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Agents 0.3.1 released - posted by wenjin <we...@gmail.com> on 2026/07/25 10:57:19 UTC, 0 replies.
- [jira] [Created] (FLINK-40237) CepOperator does not clean up expired NFA state in processing-time timer callbacks - posted by "YuXiang Zhou (Jira)" <ji...@apache.org> on 2026/07/26 04:41:00 UTC, 0 replies.
- [VOTE] FLIP-485: Add UDF Metrics - posted by Weiqing Yang <ya...@gmail.com> on 2026/07/26 18:30:09 UTC, 3 replies.
- [jira] [Created] (FLINK-40238) Expose numberOfConsecutiveFailedCheckpoints as a JobManager-level gauge - posted by "Yang Li (Jira)" <ji...@apache.org> on 2026/07/27 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40239) Support additional Flink SQL regular expression functions in YAML Transform - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/27 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40240) Support additional Flink SQL regular expression functions in YAML Transform - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/27 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40241) Support VARIANT as column type in the 'raw' format - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/27 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries - posted by "Michael (Jira)" <ji...@apache.org> on 2026/07/27 19:10:00 UTC, 0 replies.
- [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator - posted by Dale Lane <da...@proton.me> on 2026/07/27 20:08:02 UTC, 0 replies.
- [jira] [Created] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2026/07/28 05:30:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion - posted by Chanhae Oh <dh...@gmail.com> on 2026/07/28 07:15:16 UTC, 0 replies.
- [jira] [Created] (FLINK-40244) Support YashanDB in flink-connector-jdbc - posted by "Linsert (Jira)" <ji...@apache.org> on 2026/07/28 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder - posted by "Nikita Singhvi (Jira)" <ji...@apache.org> on 2026/07/28 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225) - posted by "Yishai Greenberg (Jira)" <ji...@apache.org> on 2026/07/28 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/07/28 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40248) Move publishing nightly snapshots from AZP to GHA - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/07/28 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/28 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/28 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40251) Support Process Table Function (PTF) in Python Table API - posted by "Wang Chengyu (Jira)" <ji...@apache.org> on 2026/07/28 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40252) Graceful TaskManager termination on Kubernetes - posted by "Gangadharayya Hiremath (Jira)" <ji...@apache.org> on 2026/07/28 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file - posted by "wenhao.yu (Jira)" <ji...@apache.org> on 2026/07/29 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/07/29 08:34:00 UTC, 0 replies.
- Re: [DISCUSSION] Native GCS Filesystem in Apache Flink - posted by Samrat Deb <de...@gmail.com> on 2026/07/29 13:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/07/29 13:04:00 UTC, 0 replies.
- [DISCUSS] FLIP-603: [FileSystems] GCS SDK-native filesystem - posted by Samrat Deb <de...@gmail.com> on 2026/07/29 13:11:24 UTC, 0 replies.
- [jira] [Created] (FLINK-40256) Docs: config options in sub-packages are silently missing from the configuration reference - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/07/29 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE - posted by "soyeong choe (Jira)" <ji...@apache.org> on 2026/07/30 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE - posted by "soyeong choe (Jira)" <ji...@apache.org> on 2026/07/30 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE - posted by "soyeong choe (Jira)" <ji...@apache.org> on 2026/07/30 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40260) Support Python PTF definition API and the stateless runtime path - posted by "Wang Chengyu (Jira)" <ji...@apache.org> on 2026/07/30 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40261) Support Set semantics, pass-through columns and ROW Value State for Python PTF - posted by "Wang Chengyu (Jira)" <ji...@apache.org> on 2026/07/30 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/07/30 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40263) Enum symbol validation - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/07/30 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40264) nested legacyTimestampMapping - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/07/30 06:51:00 UTC, 0 replies.
- FLINK-39900 - Change in review - posted by Francis Altomare <fr...@helpscout.com> on 2026/07/30 07:27:56 UTC, 0 replies.
- [jira] [Created] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2026/07/30 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40266) MAX_WATERMARK might not be emitted for finished operators - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/07/30 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/07/30 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40268) Add new JSON_TYPE built-in function - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/07/30 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/07/30 23:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names) - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/07/31 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40271) Group window properties produce invalid SQL in QueryOperation#asSerializableString - posted by "Timo Theusner (Jira)" <ji...@apache.org> on 2026/07/31 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40272) Add cache file for checkstyle - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/07/31 22:56:00 UTC, 0 replies.