RocMarshal created FLINK-38342:
--
Summary: Support record rescale information
Key: FLINK-38342
URL: https://issues.apache.org/jira/browse/FLINK-38342
Project: Flink
Issue Type: Sub-task
RocMarshal created FLINK-38339:
--
Summary: Adjust the statistics-related classes for reusing in the
statistical calculations of the rescale history
Key: FLINK-38339
URL: https://issues.apache.org/jira/browse/FLINK
Scott Fauerbach created FLINK-38337:
---
Summary: Chinese translation for document PR
Key: FLINK-38337
URL: https://issues.apache.org/jira/browse/FLINK-38337
Project: Flink
Issue Type
Hi Folks,
Flink 2.1 has been out for a while now and the current Kubernetes Operator
release (1.12.1) only supports Flink 2.0.
The main branch already has support for Flink 2.2 so a release with 2.1 support
seems prudent.
I was wondering what barriers, other than maintainer time, prevent a
Sergei Morozov created FLINK-38334:
--
Summary: MySQL CDC source may get stuck in the INITIAL_ASSIGNING
state
Key: FLINK-38334
URL: https://issues.apache.org/jira/browse/FLINK-38334
Project: Flink
RocMarshal created FLINK-38333:
--
Summary: UMBRELLA: FLIP-495: Support AdaptiveScheduler record and
query the rescale history
Key: FLINK-38333
URL: https://issues.apache.org/jira/browse/FLINK-38333
yisha zhou created FLINK-38331:
--
Summary: Support displaying the hash keys on edges in web ui
Key: FLINK-38331
URL: https://issues.apache.org/jira/browse/FLINK-38331
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-38318:
---
Summary: Add python autoformatter to pyflink
Key: FLINK-38318
URL: https://issues.apache.org/jira/browse/FLINK-38318
Project: Flink
Issue Type: Bug
david radley created FLINK-38329:
Summary: Add labels to PRs showing the targeted version
Key: FLINK-38329
URL: https://issues.apache.org/jira/browse/FLINK-38329
Project: Flink
Issue Type
Zakelly Lan created FLINK-38327:
---
Summary: NPE during recovery from file-merged checkpoint after FO
Key: FLINK-38327
URL: https://issues.apache.org/jira/browse/FLINK-38327
Project: Flink
Issue
Hi,
I have the initial contribution [1] for Flip-532 [2] and jira FLINK-38245 [3].
Please could someone review and merge this including the commit history. There
is still work to do for this connector, but I would like to lay down this
initial code so others can be involved to enhance it via
vikasap created FLINK-38330:
---
Summary: Updating state-size in status increases the number of
409's to K8s
Key: FLINK-38330
URL: https://issues.apache.org/jira/browse/FLINK-38330
Project:
david radley created FLINK-38328:
Summary: Community review acting strangely messages in PRs should
adding and removing labels
Key: FLINK-38328
URL: https://issues.apache.org/jira/browse/FLINK-38328
melin created FLINK-38326:
-
Summary: Kubernetes support oAuthToken authentication
Key: FLINK-38326
URL: https://issues.apache.org/jira/browse/FLINK-38326
Project: Flink
Issue Type: Improvement
Thomas Cooper created FLINK-38322:
-
Summary: Update to Kafka Client 4.1.0
Key: FLINK-38322
URL: https://issues.apache.org/jira/browse/FLINK-38322
Project: Flink
Issue Type: Improvement
Jacky Lau created FLINK-38321:
-
Summary: Optimize the timer registration logic n window early/late
firing scenarios
Key: FLINK-38321
URL: https://issues.apache.org/jira/browse/FLINK-38321
Project: Flink
Lucas Borges created FLINK-38325:
Summary: Checkpoints are hanging and timing out frequently
Key: FLINK-38325
URL: https://issues.apache.org/jira/browse/FLINK-38325
Project: Flink
Issue Type
Lucas Borges created FLINK-38324:
Summary: Job fails to restore keyed state backend when using Forst
state backend on S3
Key: FLINK-38324
URL: https://issues.apache.org/jira/browse/FLINK-38324
Salva created FLINK-38323:
-
Summary: Global Scale Factor Mode
Key: FLINK-38323
URL: https://issues.apache.org/jira/browse/FLINK-38323
Project: Flink
Issue Type: New Feature
Components
Mate Czagany created FLINK-38320:
Summary: Upgrade Pekko to 1.2.0
Key: FLINK-38320
URL: https://issues.apache.org/jira/browse/FLINK-38320
Project: Flink
Issue Type: Technical Debt
Dian Fu created FLINK-38319:
---
Summary: TO_TIMESTAMP_LTZ only accepts literal values in PyFlink
Key: FLINK-38319
URL: https://issues.apache.org/jira/browse/FLINK-38319
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-38317:
---
Summary: PushCalcPastChangelogNormalizeRule fails in case of
partial push down and trimmed fields
Key: FLINK-38317
URL: https://issues.apache.org/jira/browse/FLINK-38317
Marton Greber created FLINK-38316:
-
Summary: Clarify on some of the names in the source
Key: FLINK-38316
URL: https://issues.apache.org/jira/browse/FLINK-38316
Project: Flink
Issue Type
Hi, devs,
This is the second meeting for Flink 2.2 release cycle. I'd like to share
the information synced in the meeting.
- Feature Freeze
It is worth noting that there are only 9 weeks left until the
feature freeze time(October 31, 2025), and developers need to pay attention to
the fe
Ruan Hang created FLINK-38315:
-
Summary: Performance regression since August 21
Key: FLINK-38315
URL: https://issues.apache.org/jira/browse/FLINK-38315
Project: Flink
Issue Type: Bug
Kumar Mallikarjuna created FLINK-38309:
--
Summary: Add Basic Authentication Support to OpenTelemetry HTTP
Metrics Reporter
Key: FLINK-38309
URL: https://issues.apache.org/jira/browse/FLINK-38309
Sergey Nuyanzin created FLINK-38312:
---
Summary: Add support for SHOW CREATE MATERIALIZED TABLES
Key: FLINK-38312
URL: https://issues.apache.org/jira/browse/FLINK-38312
Project: Flink
Issue
Sergei Morozov created FLINK-38310:
--
Summary: Binary keys in a FinishedSnapshotSplitInfo are
incorrectly compared and hashed
Key: FLINK-38310
URL: https://issues.apache.org/jira/browse/FLINK-38310
-16092
But meantime we, the Flink community's contribution to this development is
building the foundation for improved streaming pipelines, where users
particularly want to use this feature with Flink 2.1.x native ML inference
using ML_PREDICT. As queue semantics mature and prove themselv
Aleksandr Iushmanov created FLINK-38314:
---
Summary: Flink dashboard incorrectly shows units for RocksDB
`live-sst-files-size` metric for timer state
Key: FLINK-38314
URL: https://issues.apache.org/jira
Sergey Nuyanzin created FLINK-38313:
---
Summary: Add support for DISTRIBUTION in MATERIALIZED TABLES
Key: FLINK-38313
URL: https://issues.apache.org/jira/browse/FLINK-38313
Project: Flink
Sergey Nuyanzin created FLINK-38311:
---
Summary: FLIP-542: Make materialized table DDL consistent with
regular tables
Key: FLINK-38311
URL: https://issues.apache.org/jira/browse/FLINK-38311
Project
more managerial), or if you'd like help drafting a follow-up or
comment for the Google Doc.
[1]
https://cwiki.apache.org/confluence/display/KAFKA/Queues+for+Kafka+%28KIP-932%29+-+Preview+Release+Notes
[2]
https://nightlies.apache.org/flink/flink-docs-release-2.1/docs/dev/datastream/
.
Regards,
Shekhar Prasad Rajak,
On Tuesday 2 September 2025 at 03:39:31 pm GMT+5:30, Gyula Fóra
wrote:
Hello!
I see there is a WIP PR that has a bit more architecture / technical
information here: https://github.com/apache/flink-connector-kafka/pull/189
It would be nice to put
Hello!
I see there is a WIP PR that has a bit more architecture / technical
information here: https://github.com/apache/flink-connector-kafka/pull/189
It would be nice to put this into a google doc proposal that follows the
FLIP format for discussion.
One question that came to me immediately is
Roman Khachatryan created FLINK-38308:
-
Summary: Prevent excessive logging from parsing SQL
timestamps/dates
Key: FLINK-38308
URL: https://issues.apache.org/jira/browse/FLINK-38308
Project: Flink
(to avoid reprocessing or
allow retries).Use cases where scaling Flink ML/LLM workload is critical -
Shifting Kafka coordination and assignment logic to the broker side would
simplify today’s complex Flink source management, making consumption more
efficient, scalable, and far less error-prone
Naci Simsek created FLINK-38307:
---
Summary: Resuming from both savepoints and checkpoints is NOT
supported for Changelog State Backend
Key: FLINK-38307
URL: https://issues.apache.org/jira/browse/FLINK-38307
david radley created FLINK-38296:
Summary: Do documentation
Key: FLINK-38296
URL: https://issues.apache.org/jira/browse/FLINK-38296
Project: Flink
Issue Type: Sub-task
Reporter
david radley created FLINK-38302:
Summary: change the config to use Flink config parameter names and
gid fallback keys
Key: FLINK-38302
URL: https://issues.apache.org/jira/browse/FLINK-38302
Project
david radley created FLINK-38304:
Summary: Re write README
Key: FLINK-38304
URL: https://issues.apache.org/jira/browse/FLINK-38304
Project: Flink
Issue Type: Sub-task
Reporter
david radley created FLINK-38306:
Summary: knit in the http connector docs into the Flink docs
Key: FLINK-38306
URL: https://issues.apache.org/jira/browse/FLINK-38306
Project: Flink
Issue
david radley created FLINK-38305:
Summary: amend the prefix to not include gid and move to Flink
Key: FLINK-38305
URL: https://issues.apache.org/jira/browse/FLINK-38305
Project: Flink
Issue
david radley created FLINK-38303:
Summary: default to use query-creator generic-json-url
Key: FLINK-38303
URL: https://issues.apache.org/jira/browse/FLINK-38303
Project: Flink
Issue Type
david radley created FLINK-38301:
Summary: confirm Maven snapshot is working
Key: FLINK-38301
URL: https://issues.apache.org/jira/browse/FLINK-38301
Project: Flink
Issue Type: Sub-task
david radley created FLINK-38300:
Summary: work out Flink v2 support (should work)
Key: FLINK-38300
URL: https://issues.apache.org/jira/browse/FLINK-38300
Project: Flink
Issue Type: Sub-task
david radley created FLINK-38299:
Summary: amend push github action to go against v1 snapsort
Key: FLINK-38299
URL: https://issues.apache.org/jira/browse/FLINK-38299
Project: Flink
Issue
david radley created FLINK-38297:
Summary: wiremock version is very old - migrate to a later level
Key: FLINK-38297
URL: https://issues.apache.org/jira/browse/FLINK-38297
Project: Flink
david radley created FLINK-38298:
Summary: Remove mockito dependancy so we do not need to exclude
from banned checklist
Key: FLINK-38298
URL: https://issues.apache.org/jira/browse/FLINK-38298
Project
david radley created FLINK-38295:
Summary: Amend parent connector pom version to 1.1.0
Key: FLINK-38295
URL: https://issues.apache.org/jira/browse/FLINK-38295
Project: Flink
Issue Type: Sub
Hi Tom,
Thinking about releases. I see:
Kafka connector 3.3 and 3.4, Flink 1.20
Kafka connector 4.0, Kafka client 3.9.0 Flink 2.0
Kafka connector 4.0.1, Kafka client 3.9.1 Flink 2.0. (does this version work
with Flink 2.1 or is [1] a show stopper?)
I assume we might want:
Kafka connector
FYI, I have posted a PR [1] for the Flink 2.1 update for the Kafka connector.
The main change with this update is that Flink has removed [2] (without
deprecating first) the stripRowPrefix method from the DataTypeUtilsTest class.
I couldn't see any evidence that this logic was moved to any
Chu Xue created FLINK-38294:
---
Summary: Hbase connector misclassifies failed task as successful
Key: FLINK-38294
URL: https://issues.apache.org/jira/browse/FLINK-38294
Project: Flink
Issue Type
Yunfeng Zhou created FLINK-38291:
Summary: Reduce thread lock overhead for Flink UI REST handlers
Key: FLINK-38291
URL: https://issues.apache.org/jira/browse/FLINK-38291
Project: Flink
Issue
Attila Mészáros created FLINK-38293:
---
Summary: Update Checkstyle version and related rules in Kubernetes
Operator
Key: FLINK-38293
URL: https://issues.apache.org/jira/browse/FLINK-38293
Project
Muhammad created FLINK-38292:
Summary: Flink CDC doesn't support altering table properties for
Paimon Sinks
Key: FLINK-38292
URL: https://issues.apache.org/jira/browse/FLINK-38292
Project:
Urs Schoenenberger created FLINK-38290:
--
Summary: Application cluster: FINISHED FlinkDeployment falls back
to RECONCILING if JM restarts
Key: FLINK-38290
URL: https://issues.apache.org/jira/browse/FLINK
Thomas Cooper created FLINK-38289:
-
Summary: Update Flink Connector Kafka to use Flink 2.1
Key: FLINK-38289
URL: https://issues.apache.org/jira/browse/FLINK-38289
Project: Flink
Issue Type
Aleksandr Iushmanov created FLINK-38288:
---
Summary: Improve BlobWriter logging to include TaskRestore
offloading duration
Key: FLINK-38288
URL: https://issues.apache.org/jira/browse/FLINK-38288
Shekhar Prasad Rajak created FLINK-38287:
Summary: Kafka 4.1.0 Queue Semantics support in Flink Connector
Kafka
Key: FLINK-38287
URL: https://issues.apache.org/jira/browse/FLINK-38287
Project
Ramin Gharib created FLINK-38286:
Summary: MAP function with duplicate keys produces
non-deterministic results
Key: FLINK-38286
URL: https://issues.apache.org/jira/browse/FLINK-38286
Project: Flink
Attila Mészáros created FLINK-38285:
---
Summary: Allow to overrride config options with environment
variables
Key: FLINK-38285
URL: https://issues.apache.org/jira/browse/FLINK-38285
Project: Flink
Jaehyun Kim created FLINK-38284:
---
Summary: Prepare to upgrade hadoop version to 3.4.2 across Flink's
Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility
Key: FLINK-38284
URL:
Here is a sample in-progress PR:
https://github.com/apache/flink-kubernetes-operator/pull/1020/files Is this in
the direction you were thinking Gyula?
Zhenqiu Huang created FLINK-38283:
-
Summary: Support customized autoscaling algorithm
Key: FLINK-38283
URL: https://issues.apache.org/jira/browse/FLINK-38283
Project: Flink
Issue Type: New
raphaelauv created FLINK-38282:
--
Summary: K8S operator : S3 jarURI
Key: FLINK-38282
URL: https://issues.apache.org/jira/browse/FLINK-38282
Project: Flink
Issue Type: Bug
Affects Versions
Going to try the plugin approach similar to
https://cwiki.apache.org/confluence/display/FLINK/FLIP-514%3A+Custom+Evaluator+plugin+for+Flink+Autoscaler
I'll draft up a PR
community for everyone to use easily. One example of
such an effort is this flip:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-514%3A+Custom+Evaluator+plugin+for+Flink+Autoscaler
In your case I think we should consider instead introducing a plugin/hook for the
scalingrealizer if that'
those extensions to
the community for everyone to use easily.
One example of such an effort is this flip:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-514%3A+Custom+Evaluator+plugin+for+Flink+Autoscaler
In your case I think we should consider instead introducing a plugin/hook
for the
TemiChan created FLINK-38281:
Summary: Schema changes still caused column size does not match
the data size after enabling scan.parse.online.schema.changes.enabled
Key: FLINK-38281
URL: https://issues.apache.org/jira
Hi, I am looking to do some customizations when flink kubernetes autoscaling
operations are about to happen, for example I need to apply some Blue/Green
operations are complete before parallelism update. For me to provide this
ability presently, I would need to stand up a standalone autoscaler
Zhanghao Chen created FLINK-38280:
-
Summary: Bump ASM 9.8 to support Java 25 bytecode
Key: FLINK-38280
URL: https://issues.apache.org/jira/browse/FLINK-38280
Project: Flink
Issue Type: Sub
Yanquan Lv created FLINK-38279:
--
Summary: Failed to restore job when using MySQL Source with
scan.startup.mode=snapshot in streaming mode
Key: FLINK-38279
URL: https://issues.apache.org/jira/browse/FLINK-38279
The Apache Flink community is very happy to announce the release of
Apache flink-connector-kafka 4.0.1.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streaming applications.
The release is available for download
ouyangwulin created FLINK-38278:
---
Summary: PostgresSQL supported array field types.
Key: FLINK-38278
URL: https://issues.apache.org/jira/browse/FLINK-38278
Project: Flink
Issue Type
Hi Dev,
I'm happy to announce that FLIP-540: Support VECTOR_SEARCH in Flink SQL[1]
has been accepted with 10 approving votes (4 binding) [2]. There are no
disapproving votes.
Timo Walther (binding)
dylanhz (non-binding)
Weiqing Yang (non-binding)
Mingge Deng (non-binding)
Hao Li (non-bi
t; > > > > >
>> > > > > > On Tue, Aug 19, 2025 at 10:01 AM dylanhz
>> wrote:
>> > > > > >
>> > > > > > > +1 (non-binding)
>> > > > > > >
>> > > > > > > Best regards,
&
ouyangwulin created FLINK-38277:
---
Summary: Enhance postgresSQL slot management capabilities
Key: FLINK-38277
URL: https://issues.apache.org/jira/browse/FLINK-38277
Project: Flink
Issue Type
yangyu created FLINK-38276:
--
Summary: PaimonWriter does not invalidate cache when schema changes
Key: FLINK-38276
URL: https://issues.apache.org/jira/browse/FLINK-38276
Project: Flink
Issue Type
Di Wu created FLINK-38275:
-
Summary: Doris Pipeline Sink cannot create a table when the
upstream has no primary key and the first column is String
Key: FLINK-38275
URL: https://issues.apache.org/jira/browse/FLINK-38275
Gyula Fora created FLINK-38274:
--
Summary: Improve kubernetes operator config options for better
yaml structure
Key: FLINK-38274
URL: https://issues.apache.org/jira/browse/FLINK-38274
Project: Flink
shml created FLINK-38273:
Summary: Flink SQL Client Embedded Mode Configuration Regression
in 1.19 - Connection fails when rest.bind-port is configured
Key: FLINK-38273
URL: https://issues.apache.org/jira/browse/FLINK
Thanks to all.
Best,
Ron
Ramin Gharib 于2025年8月20日周三 21:39写道：
> Congrats, Ron!
>
> Cheers,
>
> Ramin
>
> On Wed, Aug 13, 2025 at 4:41 AM Lincoln Lee
> wrote:
>
> > On behalf of the PMC, I'm very happy to announce a new Apache Flink PMC
> > Member
>
> > >
> > > > > > On Tue, Aug 19, 2025 at 10:01 AM dylanhz
> wrote:
> > > > > >
> > > > > > > +1 (non-binding)
> > > > > > >
> > > > > > > Best regards,
> > > > > >
Congrats, Ron!
Cheers,
Ramin
On Wed, Aug 13, 2025 at 4:41 AM Lincoln Lee wrote:
> On behalf of the PMC, I'm very happy to announce a new Apache Flink PMC
> Member
> - Ron Liu.
>
> Ron has been a dedicated and invaluable contributor to the Flink community
> for
>
x27;t know the details however it seems ok
>
> [1] https://dist.apache.org/repos/dist/release/flink/KEYS
>
> On Tue, Aug 19, 2025 at 6:50 PM Weiqing Yang wrote:
> >
> > +1 (non-binding)
> >
> > Verified:
> >
> >- Signature and checksum
> >-
Hi, devs
Today we had our first meeting for Flink 2.2 release cycle. I'd like to
share the info synced in the meeting.
1. Feature freezing and release:
- Feature Freeze: October 31, 2025, 00:00 CEST(UTC+2)
- Release: End of November 2025
2. Update 2.2 Release page:
Flink 2.2 release has
Ruan Hang created FLINK-38272:
-
Summary: The BatchJobRecoveryTest failed of azure cron adaptive
scheduler pipeline
Key: FLINK-38272
URL: https://issues.apache.org/jira/browse/FLINK-38272
Project: Flink
eers,
> > > > > Weiqing
> > > > >
> > > > > On Tue, Aug 19, 2025 at 10:01 AM dylanhz wrote:
> > > > >
> > > > > > +1 (non-binding)
> > > > > >
> > > > > > Best regards,
> > > > > > dylanhz
> >
ouyangwulin created FLINK-38271:
---
Summary: PostgresSQL pipeline supports table schema evolution.
Key: FLINK-38271
URL: https://issues.apache.org/jira/browse/FLINK-38271
Project: Flink
Issue
> dylanhz
> > > > >
> > > > >
> > > > >
> > > > > > 2025年8月19日 22:54，Timo Walther 写道：
> > > > > >
> > > > > > +1 (binding)
> > > > > >
> > > > > > Thanks,
>
t; > > dylanhz
> > > >
> > > >
> > > >
> > > > > 2025年8月19日 22:54，Timo Walther 写道：
> > > > >
> > > > > +1 (binding)
> > > > >
> > > > > Thanks,
> > > > > Timo
> >
Sergei Morozov created FLINK-38270:
--
Summary: MySQL CDC source may ignore newly added tables while
reading the binlog (scenario 2)
Key: FLINK-38270
URL: https://issues.apache.org/jira/browse/FLINK-38270
Yaroslav created FLINK-38269:
Summary: Make Job Manager's REST endpoint advertised address
configurable
Key: FLINK-38269
URL: https://issues.apache.org/jira/browse/FLINK-38269
Project:
int
C86916A824E92CBDB46CF1E7538B49E9BCF0B72F
however it is also present in KEYS[1] file under Arvid's name
Don't know the details however it seems ok
[1] https://dist.apache.org/repos/dist/release/flink/KEYS
On Tue, Aug 19, 2025 at 6:50 PM Weiqing Yang wrote:
>
> +1 (non-binding)
>
> Ver
wrote:
> > >
> > > Congratulations Ron!
> > > Kind regards, David.
> > >
> > > From: Zhanghao Chen
> > > Date: Thursday, 14 August 2025 at 01:57
> > > To: dev@flink.apache.org
> > > Subject: [EXTERNAL] Re: [ANN
t; >
> > > > Thanks,
> > > > Timo
> > > >
> > > >
> > > > On 19.08.25 08:20, Shengkai Fang wrote:
> > > >> Hi everyone,
> > > >> I'd like to start a vote on FLIP-540: Support VECTOR_SEA
t; >
> > > 2025年8月19日 22:54，Timo Walther 写道：
> > >
> > > +1 (binding)
> > >
> > > Thanks,
> > > Timo
> > >
> > >
> > > On 19.08.25 08:20, Shengkai Fang wrote:
> > >> Hi everyone,
> > >> I'd li
gt; >
> > On 19.08.25 08:20, Shengkai Fang wrote:
> >> Hi everyone,
> >> I'd like to start a vote on FLIP-540: Support VECTOR_SEARCH in Flink
> >> SQL[1], which has been discussed in this thread [2].
> >> The vote will be open for at least 72 hours unle
+1 (non-binding)
Best regards,
dylanhz
> 2025年8月19日 22:54，Timo Walther 写道：
>
> +1 (binding)
>
> Thanks,
> Timo
>
>
> On 19.08.25 08:20, Shengkai Fang wrote:
>> Hi everyone,
>> I'd like to start a vote on FLIP-540: Support VECTOR_SEARCH in Flink
1 - 100 of 11268 matches
Mail list logo
