Messages by Date
-
2026/07/10
[jira] [Created] (FLINK-40116) Support more predicates for filter pushdown during savepoint scan
Ilya Soin (Jira)
-
2026/07/10
Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input
Timo Walther
-
2026/07/10
[RESULT][VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
2026/07/10
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
2026/07/09
Re: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink
Yong Fang
-
2026/07/09
[VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/09
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh
-
2026/07/09
Re: [DISCUSS] FLIP-599: State Catalog
gyula . fora
-
2026/07/09
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Zhu Zhu
-
2026/07/09
Re: Re: [DISCUSS] Add UDF Metrics
Weiqing Yang
-
2026/07/09
[jira] [Created] (FLINK-40115) Document timestamp reliability for bounded-out-of-orderness watermarks
Hancheng Deng (Jira)
-
2026/07/09
Re: [DISCUSS] FLIP-599: State Catalog
Weiqing Yang
-
2026/07/09
[jira] [Created] (FLINK-40114) Leader information permanently erased when a change event races a pending confirmation
Prashant Bhardwaj (Jira)
-
2026/07/09
[jira] [Created] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex
Rion Williams (Jira)
-
2026/07/09
[VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4
Yuepeng Pan
-
2026/07/09
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4
Yuepeng Pan
-
2026/07/09
Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3
Yuepeng Pan
-
2026/07/09
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Yuepeng Pan
-
2026/07/09
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
João Boto
-
2026/07/09
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
João Boto
-
2026/07/09
[jira] [Created] (FLINK-40111) Keyless upsert sink should fall back to retract when the input has no upsert key
Gustavo de Morais (Jira)
-
2026/07/09
[jira] [Created] (FLINK-40112) Report a changelog mode mismatch instead of a generic planning error
Gustavo de Morais (Jira)
-
2026/07/09
[jira] [Created] (FLINK-40110) Connectors/OpenSearch: Bump flink.version to 2.1.2 in flink-connector-opensearch
Purushottam Sinha (Jira)
-
2026/07/09
[DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input
Fabian Hueske
-
2026/07/09
[jira] [Created] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed
Martijn Visser (Jira)
-
2026/07/09
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Yuepeng Pan
-
2026/07/09
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Yuepeng Pan
-
2026/07/09
[jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database
Jira
-
2026/07/09
[jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom
Dennis-Mircea Ciupitu (Jira)
-
2026/07/09
[jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
Dennis-Mircea Ciupitu (Jira)
-
2026/07/09
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Leonard Xu
-
2026/07/09
[jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager
xiechenling (Jira)
-
2026/07/08
[jira] [Created] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory
Dennis-Mircea Ciupitu (Jira)
-
2026/07/08
[jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4
Jira
-
2026/07/08
Re: [DISCUSS] State Schema Evolution for RowData
Weiqing Yang
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Charles Zhang
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
yue ma
-
2026/07/08
[jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead
ericzeng (Jira)
-
2026/07/08
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang
-
2026/07/08
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
João Boto
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Weiqing Yang
-
2026/07/08
Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API
David Chaava via dev
-
2026/07/08
[jira] [Created] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog
Piotr Nowojski (Jira)
-
2026/07/08
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Xingcan Cui
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Zakelly Lan
-
2026/07/08
[DISCUSS] FLIP-601: Cloud-Agnostic Client-Side Encryption for SDK-Native Filesystems
Aleksandr Iushmanov
-
2026/07/08
Re: [DISCUSS] FLIP-599: State Catalog
Jingsong Li
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Rui Fan
-
2026/07/08
[jira] [Created] (FLINK-40100) Reduce ArchUnit violations: remove direct usage of Flink-internal/shaded APIs in flink-connector-http
Bharath Reddy Gunapati (Jira)
-
2026/07/08
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Chanhae Oh
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
zihao chen
-
2026/07/08
[jira] [Created] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log
Ramin Gharib (Jira)
-
2026/07/08
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh
-
2026/07/08
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/08
[jira] [Created] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests
Martijn Visser (Jira)
-
2026/07/08
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/08
[jira] [Created] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer
chenzihao (Jira)
-
2026/07/08
[RESULT][VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer
zihao chen
-
2026/07/08
[jira] [Created] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java
Ramin Gharib (Jira)
-
2026/07/08
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Roman Khachatryan
-
2026/07/07
[jira] [Created] (FLINK-40095) JSON aggregation functions failing in group window aggregate
Xuyang Zhong (Jira)
-
2026/07/07
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Leonard Xu
-
2026/07/07
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Yuepeng Pan
-
2026/07/07
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Weiqing Yang
-
2026/07/07
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Gen Luo
-
2026/07/07
Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators
Soumitra Kumar
-
2026/07/07
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Yuan Mei
-
2026/07/07
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Youngil Kim
-
2026/07/07
Re: [DISCUSS] FLIP-599: State Catalog
Shengkai Fang
-
2026/07/07
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh
-
2026/07/07
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang
-
2026/07/07
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Yuepeng Pan
-
2026/07/07
Re: [DISCUSS] FLIP-599: State Catalog
Jingsong Li
-
2026/07/07
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Xingcan Cui
-
2026/07/07
[jira] [Created] (FLINK-40094) DynamicKafkaSource should mark removed split outputs idle before release
Xin Gao (Jira)
-
2026/07/07
Re: [DISCUSS] FLIP-599: State Catalog
Roman Khachatryan
-
2026/07/07
[jira] [Created] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle
Efrat Levitan (Jira)
-
2026/07/07
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Yuepeng Pan
-
2026/07/07
[jira] [Created] (FLINK-40092) BlueGreen transition should finalize immediately after deleting previous deployment
Calico Shop (Jira)
-
2026/07/07
Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3
Chanhae Oh
-
2026/07/07
[jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2
peiyu (Jira)
-
2026/07/07
[jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README
Martijn Visser (Jira)
-
2026/07/07
[jira] [Created] (FLINK-40089) Add JSON_LENGTH function
Gustavo de Morais (Jira)
-
2026/07/07
[jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429)
Martijn Visser (Jira)
-
2026/07/07
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
ChanBin Oh
-
2026/07/07
Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
주수민
-
2026/07/07
[DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh
-
2026/07/07
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/07
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/07
Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
Guowei Ma
-
2026/07/07
[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 "`)
Xin Gong (Jira)
-
2026/07/07
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/07
[jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction
Matthias Pohl (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink
reswqa (Jira)
-
2026/07/06
[VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
2026/07/06
Re: [DISCUSS] FLIP-599: State Catalog
Shengkai Fang
-
2026/07/06
Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2
Yuepeng Pan
-
2026/07/06
Re: Help Needed for JDBC Release v3.4.0
Yuepeng Pan
-
2026/07/06
Re: [DISCUSS] FLIP-599: State Catalog
Roman Khachatryan
-
2026/07/06
Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators
Roman Khachatryan
-
2026/07/06
Re: Help Needed for JDBC Release v3.4.0
Weiqing Yang
-
2026/07/06
Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API
Talat Uyarer
-
2026/07/06
[jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars
Sergey Nuyanzin (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38
Chris Lu (Jira)
-
2026/07/06
Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang
-
2026/07/06
Re: Help Needed for JDBC Release v3.4.0
Ferenc Csaky
-
2026/07/06
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2
Yuepeng Pan
-
2026/07/06
[VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3
Yuepeng Pan
-
2026/07/06
Help Needed for JDBC Release v3.4.0
Yuepeng Pan
-
2026/07/06
[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)
Fred Teunissen (Jira)
-
2026/07/06
Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR)
Sergio Chong Loo
-
2026/07/06
[RESULT] [VOTE] FLIP-588: Support per-job delegation tokens
Aleksandr Savonin
-
2026/07/06
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/06
[jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery
Rui Fan (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints
Rui Fan (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths
Fabian Hueske (Jira)
-
2026/07/06
[DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign
Dennis-Mircea Ciupitu
-
2026/07/06
Re:Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Xuyang
-
2026/07/06
[jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause
Martijn Visser (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause
Martijn Visser (Jira)
-
2026/07/06
[jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale
Martijn Visser (Jira)
-
2026/07/05
Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang
-
2026/07/05
[jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator
dylanhz (Jira)
-
2026/07/05
Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer
Junrui Lee
-
2026/07/05
Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer
weijie guo
-
2026/07/05
Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators
Soumitra Kumar
-
2026/07/05
[jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory)
Martijn Visser (Jira)
-
2026/07/05
Re: [DISCUSS] FLIP-599: State Catalog
Zakelly Lan
-
2026/07/04
[jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches
Harshit Gupta (Jira)
-
2026/07/04
RE: Apache infrastructure PR wanting to change default rulesets.
Harshit Gupta via dev
-
2026/07/04
[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
Bharath Reddy Gunapati (Jira)
-
2026/07/04
Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
2026/07/03
退订
林
-
2026/07/03
退订
林
-
2026/07/03
[jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4
Purushottam Sinha (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2
Purushottam Sinha (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1.
Purushottam Sinha (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6
Purushottam Sinha (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized
Sergey Nuyanzin (Jira)
-
2026/07/03
Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region
Roman Khachatryan
-
2026/07/03
[ANNOUNCE] Apache flink-connector-http v1.0.0 released
David Radley
-
2026/07/03
[jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml
ChanBin OH (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility
Sumin Joo (Jira)
-
2026/07/03
Re: [DISCUSS] FLIP-599: State Catalog
Dennis-Mircea Ciupitu
-
2026/07/03
[jira] [Created] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x
Purushottam Sinha (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents
Martijn Visser (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled
ericzeng (Jira)
-
2026/07/03
[jira] [Created] (FLINK-40056) Support anchor navigation for pyflink configuration options
chenzihao (Jira)
-
2026/07/03
Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
2026/07/02
[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
Gerk Elznik (Jira)
-
2026/07/02
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/02
退订
林
-
2026/07/02
退订
林
-
2026/07/02
退订
林
-
2026/07/02
Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR)
Sergio Chong Loo
-
2026/07/02
Re: [VOTE] FLIP-588: Support per-job delegation tokens
Ryan van Huuksloot via dev
-
2026/07/02
Re: [DISCUSS] FLIP-XXX Monotonic Counters support
Ryan van Huuksloot via dev
-
2026/07/02
Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region
Roman Khachatryan
-
2026/07/02
Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR)
Sergio Chong Loo
-
2026/07/02
[jira] [Created] (FLINK-40054) Update aircompressor to 2.0.3
Martijn Visser (Jira)
-
2026/07/02
[jira] [Created] (FLINK-40053) Log4j 2.26.1 bump
Martijn Visser (Jira)
-
2026/07/02
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Cole Bailey via dev
-
2026/07/02
RE: Apache infrastructure PR wanting to change default rulesets.
David Radley
-
2026/07/02
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/02
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/02
Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
2026/07/02
[jira] [Created] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED
SkylerLin (Jira)
-
2026/07/02
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/02
Re: [DISCUSS] FLIP-599: State Catalog
Dennis-Mircea Ciupitu
-
2026/07/02
[jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml
lisa (Jira)
-
2026/07/02
[jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore
Martijn Visser (Jira)
-
2026/07/02
Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region
Gen Luo
-
2026/07/01
[jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x
Taranpreet Kaur (Jira)
-
2026/07/01
Re: [VOTE] FLIP-588: Support per-job delegation tokens
Sergey Nuyanzin
-
2026/07/01
Re: [VOTE] FLIP-588: Support per-job delegation tokens
weijie guo
-
2026/07/01
[jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test
Martijn Visser (Jira)
-
2026/07/01
[jira] [Created] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+
Marc Demierre (Jira)
-
2026/07/01
RE: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Matt Belle via dev
-
2026/07/01
[jira] [Created] (FLINK-40046) Upgrade @antv/g2 to v5
Purushottam Sinha (Jira)
-
2026/07/01
[jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5
Purushottam Sinha (Jira)
-
2026/07/01
[jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x
Purushottam Sinha (Jira)
-
2026/07/01
Re: [VOTE] FLIP-588: Support per-job delegation tokens
Piotr Nowojski
-
2026/07/01
Re: [VOTE] FLIP-588: Support per-job delegation tokens
Rui Fan
-
2026/07/01
[jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism
peiyu (Jira)
-
2026/07/01
Re: [VOTE] FLIP-588: Support per-job delegation tokens
Gabor Somogyi
-
2026/07/01
[jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0
Yuepeng Pan (Jira)
-
2026/07/01
[jira] [Created] (FLINK-40041) Update JDBC connector version to 3.4.0
Yuepeng Pan (Jira)
-
2026/07/01
Re: [DISCUSS] FLIP-588: Support per-job delegation tokens
Gabor Somogyi
-
2026/07/01
[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
Jiyong Wang (Jira)
-
2026/07/01
[jira] [Created] (FLINK-40039) CTAS/RTAS do not work for PTFs with set semantics and PARTITION BY
Ramin Gharib (Jira)
-
2026/07/01
Re: [DISCUSS] FLIP-599: State Catalog
Gyula Fóra
-
2026/07/01
Re: [DISCUSS] FLIP-599: State Catalog
Han Yin
-
2026/07/01
[jira] [Created] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead
Jira
-
2026/07/01
Re: [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core
Li Wang
-
2026/07/01
Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink
Cole Bailey via dev