Hi Alexey,
Responses inline below:
On Mon, May 13, 2024 at 7:18 PM Alexey Leonov-Vendrovskiy <
vendrov...@gmail.com> wrote:
> Thanks Jim.
>
> > 1. For the testing, I'd call the tests "execution" tests rather than
> > "restore" tests. For streaming execution, restore tests have the
> compiled
>
Hi Zakelly,
good point. I updated the FLIP to use "scale-on-failed-checkpoints-count"
and "max-delay-for-scale-trigger".
On Fri, Jun 7, 2024 at 12:18 PM Zakelly Lan wrote:
> Hi Matthias,
>
> Thanks for your reply!
>
> That's something that could be considered as another optimization. I would
> >
HI all,
+1 (non-binding)
Cheers,
Jim
On Fri, Jun 7, 2024 at 4:03 AM Yuxin Tan wrote:
> Hi everyone,
>
> Thanks for all the feedback about the FLIP-459 Support Flink
> hybrid shuffle integration with Apache Celeborn[1].
> The discussion thread is here [2].
>
> I'd like to start a vote for it.
Hi,
I think this was last discussed in FLIP-193 [1] where the reasoning is
mostly the same as Matthias said, savepoints are owned by the user and
Flink cannot depend on them.
In older versions Flink also took savepoints into account when restoring a
job, with the possibility to skip savepoints by
HI All,
I'd like to start a discussion on FLIP-463: Schema Definition in CREATE
TABLE AS Statement [1]
The proposal extends the CTAS statement to allow users to define their own
schema by adding columns, primary and partition keys, and table
distribution to the CREATE statement.
Any thoughts are
Matt Braymer-Hayes created FLINK-35558:
--
Summary: [docs] "Edit This Page" tool does not follow contribution
guidelines
Key: FLINK-35558
URL: https://issues.apache.org/jira/browse/FLINK-35558
Proj
Roman Khachatryan created FLINK-35557:
-
Summary: MemoryManager only reserves memory per consumer type once
Key: FLINK-35557
URL: https://issues.apache.org/jira/browse/FLINK-35557
Project: Flink
Hi,
Thank you everyone for the valuable comments, if there are no new messages by
then, I will start a vote on Monday.
Thanks,
Ferenc
On Monday, 3 June 2024 at 17:27, Jeyhun Karimov wrote:
>
>
> Hi Ferenc,
>
> Thanks for the proposal. +1 for it! This FLIP will improve the user
> experie
Roman Khachatryan created FLINK-35556:
-
Summary: Wrong constant in
RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED
Key: FLINK-35556
URL: https://issues.apache.org/jira/browse/FLINK-35556
Project
Zhanghao Chen created FLINK-3:
-
Summary: Serializing List with null values throws NPE
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project: Flink
Issue Type: Bu
Thanks for driving this Sergey.
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source using Java 8 (-Popen
Thanks for driving this Sergey.
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source using Java 11 (-Pope
The Apache Flink community is very happy to announce the release of Apache
flink-connector-kafka 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is
The Apache Flink community is very happy to announce the release of Apache
flink-connector-jdbc 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is a
I'm happy to announce that we have unanimously approved this release.
There are 9 approving votes, 3 of which are binding:
* Muhammet Orazov
* Ahmed Hamdy
* Hang Ruan
* Aleksandr Pilipenko
* Leonard Xu (binding)
* Fabian Paul
* Martijn Visser (binding)
* Yanquan Lv
* Danny Cranmer (binding)
There
Thanks all. This vote is now closed, I will announce the results in a
separate thread.
On Fri, Jun 7, 2024 at 11:45 AM Danny Cranmer
wrote:
> +1 (binding)
>
> - Release notes look good
> - Source archive checksum and signature is correct
> - Binary checksum and signature is correct
> - Contents
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source, tests pass using Java 8
- CI run passed [1]
- Tag ex
Hi Mingliang,
We already have a mechanism for detecting and propagating
Fatal/Non-retryable exceptions[1]. We can use that in ElasticSearch similar
to what we do for AWS connectors[2]. Also, you can check AWS connectors for
how to add a fail-fast mechanism to disable retrying all along.
> FLIP-45
+1 (non-binding)
* Checked download links & release tags
* Verified that package checksums matched
* Compiled Flink from source code with JDK 8 / 11
* Ran E2e data integration test jobs on local cluster
Regards,
yux
De : Rui Fan <1996fan...@gmail.com>
Date : vendredi, 7 juin 202
Hi Matthias,
Thanks for your reply!
That's something that could be considered as another optimization. I would
> consider this as a possible follow-up. My concern here is that we'd make
> the rescaling configuration even more complicated by introducing yet
> another parameter.
I'd be fine with
Apologies, this was RC2, not RC1.
On Fri, Jun 7, 2024 at 11:12 AM Danny Cranmer
wrote:
> I'm happy to announce that we have unanimously approved this release.
>
> There are 7 approving votes, 3 of which are binding:
> * Ahmed Hamdy
> * Hang Ruan
> * Leonard Xu (binding)
> * Yuepeng Pan
> * Zhong
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
* Ahmed Hamdy
* Hang Ruan
* Leonard Xu (binding)
* Yuepeng Pan
* Zhongqiang Gong
* Rui Fan (binding)
* Weijie Guo (binding)
There was one -1 vote that was cancelled.
* Yuepen
Thanks all. This vote is now closed, I will announce the results in a
separate thread.
On Fri, Jun 7, 2024 at 4:59 AM weijie guo wrote:
> Thanks Danny!
>
> +1(binding)
> - Verified signatures and hash sums
> - Checked the CI build
> - Checked the release note
> - Reviewed the flink-web PR
> - B
The Apache Flink community is very happy to announce the release of Apache
flink-connector-cassandra 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release
+1 (binding)
Best regards,
Weijie
Zhu Zhu 于2024年6月7日周五 16:48写道：
> +1 (binding)
>
> Thanks,
> Zhu
>
> Xintong Song 于2024年6月7日周五 16:08写道：
>
> > +1 (binding)
> >
> > Best,
> >
> > Xintong
> >
> >
> >
> > On Fri, Jun 7, 2024 at 4:03 PM Yuxin Tan wrote:
> >
> > > Hi everyone,
> > >
> > > Thanks
I'm happy to announce that we have unanimously approved this release.
There are 6 approving votes, 3 of which are binding:
* Muhammet Orazov
* Ahmed Hamdy
* Hang Ruan
* Weijie Guo (binding)
* Leonard Xu (binding)
* Rui Fan (binding)
There are no disapproving votes.
Thanks,
Danny
Thanks all. This vote is now closed, I will announce the results in a
separate thread.
On Fri, Jun 7, 2024 at 5:02 AM weijie guo wrote:
> Thanks Danny!
>
> +1(binding)
>
> - Verified signatures and hash sum
> - Checked the CI build from tag
> - Build from source
> - Reviewed flink-web PR
>
> Bes
The Apache Flink community is very happy to announce the release of Apache
flink-connector-aws 4.3.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is av
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
* Hang Ruan
* Ahmed Hamdy
* Aleksandr Pilipenko
* Leonard Xu (binding)
* Zhongqiang Gong
* Rui Fan (binding)
* Weijie Guo (binding)
There are no disapproving votes.
Thanks,
Josh England created FLINK-35554:
Summary: usrlib is not added to classpath when using containers
Key: FLINK-35554
URL: https://issues.apache.org/jira/browse/FLINK-35554
Project: Flink
Issue
Thanks all, this vote is now closed, I will announce the results on a
separate thread.
On Fri, Jun 7, 2024 at 4:58 AM weijie guo wrote:
> Thanks Danny!
>
> +1(binding)
>
> - Verified signatures and hashsums
> - Build from source
> - Checked release tag
> - Reviewed the flink-web PR
> - Checked t
The Apache Flink community is very happy to announce the release of Apache
flink-connector-gcp-pubsub 3.1.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The releas
Matthias Pohl created FLINK-35553:
-
Summary: Integrate newly added trigger interface with checkpointing
Key: FLINK-35553
URL: https://issues.apache.org/jira/browse/FLINK-35553
Project: Flink
Matthias Pohl created FLINK-35552:
-
Summary: Move CheckpointStatsTracker out of ExecutionGraph into
Scheduler
Key: FLINK-35552
URL: https://issues.apache.org/jira/browse/FLINK-35552
Project: Flink
Matthias Pohl created FLINK-35551:
-
Summary: Introduces RescaleManager#onTrigger endpoint
Key: FLINK-35551
URL: https://issues.apache.org/jira/browse/FLINK-35551
Project: Flink
Issue Type: Su
Matthias Pohl created FLINK-35550:
-
Summary: Introduce new component RescaleManager
Key: FLINK-35550
URL: https://issues.apache.org/jira/browse/FLINK-35550
Project: Flink
Issue Type: Sub-task
Matthias Pohl created FLINK-35549:
-
Summary: FLIP-461: Synchronize rescaling with checkpoint creation
to minimize reprocessing for the AdaptiveScheduler
Key: FLINK-35549
URL: https://issues.apache.org/jira/browse/
I'm happy to announce that we have unanimously approved this release.
There are 5 approving votes, 3 of which are binding:
* Ahmed Hamdy
* Hang Ruan
* Leonard Xu (binding)
* Rui Fan (binding)
* Danny Cranmer (binding)
There are no disapproving votes.
Thanks everyone!
+1(binding)
- Reviewed the flink-web PR (Left some comments)
- Checked Github release tag
- Verified signatures
- Verified sha512 (hashsums)
- The source archives do not contain any binaries
- Build the source with Maven 3 and java8 (Checked the license as well)
- Start the cluster locally with jd
This vote is now closed, I will announce the results on a separate thread.
Thanks all.
On Fri, Jun 7, 2024 at 10:10 AM Danny Cranmer
wrote:
> +1 (binding)
>
> - Release notes look good
> - Source archive checksum and signature is correct
> - Binary checksum and signature is correct
> - Contents
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source, tests pass using Java 8
- CI run passed
- Tag exists
+1 (binding)
Thanks,
Zhu
Xintong Song 于2024年6月7日周五 16:08写道：
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Fri, Jun 7, 2024 at 4:03 PM Yuxin Tan wrote:
>
> > Hi everyone,
> >
> > Thanks for all the feedback about the FLIP-459 Support Flink
> > hybrid shuffle integration with Apache Celeborn[1
Thanks, Alexey, for the proposal. I think this is a nice addition that
finally fixes the gap in the CompiledPlan. +1
Best,
Fabian
On Tue, May 14, 2024 at 1:19 AM Alexey Leonov-Vendrovskiy <
vendrov...@gmail.com> wrote:
> Thanks Jim.
>
>
>
> > 1. For the testing, I'd call the tests "execution" te
Hi,
I am evaluating delta-flink "3.2.0" , and trying to write a
Datastream[My_Custom_Class]
Flink version "1.16.3" , it would be of great help if someone can share
some examples either in Java or Scala APIs.
Thanks and Regards,
Sneh
+1 (binding)
Best,
Xintong
On Fri, Jun 7, 2024 at 4:03 PM Yuxin Tan wrote:
> Hi everyone,
>
> Thanks for all the feedback about the FLIP-459 Support Flink
> hybrid shuffle integration with Apache Celeborn[1].
> The discussion thread is here [2].
>
> I'd like to start a vote for it. The vote
Hi everyone,
Thanks for all the feedback about the FLIP-459 Support Flink
hybrid shuffle integration with Apache Celeborn[1].
The discussion thread is here [2].
I'd like to start a vote for it. The vote will be open for at least
72 hours unless there is an objection or insufficient votes.
[1]
ht
Ahmed Hamdy created FLINK-35548:
---
Summary: Add E2E tests for PubSubSinkV2
Key: FLINK-35548
URL: https://issues.apache.org/jira/browse/FLINK-35548
Project: Flink
Issue Type: Sub-task
linqigeng created FLINK-35547:
-
Summary: Sources support HybridSource implements
Key: FLINK-35547
URL: https://issues.apache.org/jira/browse/FLINK-35547
Project: Flink
Issue Type: New Feature
48 matches
Mail list logo
