Thanks a lot for the release and your great job, Yu!
Also thanks to everyone who made this release possible!
Best,
Congxian
Yu Li 于2020年5月14日周四 上午1:59写道：
> The Apache Flink community is very happy to announce the release of Apache
> Flink 1.10.1, which is the first bugfix release for the Apach
Zhijiang created FLINK-17719:
Summary: Provide ChannelStateReader#hasStates for hints of reading
channel states
Key: FLINK-17719
URL: https://issues.apache.org/jira/browse/FLINK-17719
Project: Flink
Robert Metzger created FLINK-17720:
--
Summary: StreamSqlTests.test_execute_sql: "AssertionError: True is
not false"
Key: FLINK-17720
URL: https://issues.apache.org/jira/browse/FLINK-17720
Project: Fli
Robert Metzger created FLINK-17721:
--
Summary: AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry
fails with AssertionError
Key: FLINK-17721
URL: https://issues.apache.org/jira/browse/FLINK-17721
Robert Metzger created FLINK-17722:
--
Summary: "Failed to find the file" in "build_wheels" stage
Key: FLINK-17722
URL: https://issues.apache.org/jira/browse/FLINK-17722
Project: Flink
Issue T
Hi Till!
I agree to some extent that managing multiple clusters is not Flink's
primary responsibility.
However many (if not most) production users use Flink in per-job-cluster
mode which gives superior configurability and resource isolation than
standalone/session modes.
But still the best job ma
I see, thanks for all the input.
I agree with Yun Tang that the use of UnionState is problematic and can
cause issues in conjunction with this.
However, most of the large-scale users I know that also struggle with
UnionState have also increased this threshold, because with this low
threshold, they
John Lonergan created FLINK-17723:
-
Summary: Written design for flink threading model and guarantees
made to the various structual components
Key: FLINK-17723
URL: https://issues.apache.org/jira/browse/FLINK-17723
Robert Metzger created FLINK-17724:
--
Summary: PyFlink end-to-end test fails with Cannot run program
"venv.zip/.conda/bin/python": error=2, No such file or directory
Key: FLINK-17724
URL: https://issues.apache.org
Robert Metzger created FLINK-17725:
--
Summary: FileUploadHandlerTest.testUploadCleanupOnFailure fails
with "SocketTimeout timeout"
Key: FLINK-17725
URL: https://issues.apache.org/jira/browse/FLINK-17725
Thanks Yu for being our release manager and everyone else who made the
release possible!
Cheers,
Till
On Fri, May 15, 2020 at 9:15 AM Congxian Qiu wrote:
> Thanks a lot for the release and your great job, Yu!
> Also thanks to everyone who made this release possible!
>
> Best,
> Congxian
>
>
> Y
This sounds like a good plan to me Gyula. And there is always the Flink
packages option available if we want to make it available earlier.
Cheers,
Till
On Fri, May 15, 2020 at 10:12 AM Gyula Fóra wrote:
> Hi Till!
>
> I agree to some extent that managing multiple clusters is not Flink's
> prima
Zhu Zhu created FLINK-17726:
---
Summary: Scheduler should take care of tasks directly canceled by
TaskManager
Key: FLINK-17726
URL: https://issues.apache.org/jira/browse/FLINK-17726
Project: Flink
I
Thanks Yu for managing this release and everyone else who made this release
possible. Good work!
Regards,
Dian
> 在 2020年5月15日，下午6:26，Till Rohrmann 写道：
>
> Thanks Yu for being our release manager and everyone else who made the
> release possible!
>
> Cheers,
> Till
>
> On Fri, May 15, 2020 a
Roman Khachatryan created FLINK-17727:
-
Summary: Can't subsume checkpoint with no channel state in UC mode
Key: FLINK-17727
URL: https://issues.apache.org/jira/browse/FLINK-17727
Project: Flink
Hi,
Couple of contributors asked for extending cutting the release branch until
Monday, what do you think about such extension?
(+1 from my side)
Piotrek
> On 25 Apr 2020, at 21:24, Yu Li wrote:
>
> +1 for extending the feature freeze to May 15th.
>
> Best Regards,
> Yu
>
>
> On Fri, 24 A
godfrey he created FLINK-17728:
--
Summary: use sql parser to parse a statement in sql client
Key: FLINK-17728
URL: https://issues.apache.org/jira/browse/FLINK-17728
Project: Flink
Issue Type: Imp
Thanks Yu for the great work, and everyone else who made this possible.
Dian Fu 于2020年5月15日周五 下午6:55写道：
> Thanks Yu for managing this release and everyone else who made this
> release possible. Good work!
>
> Regards,
> Dian
>
> 在 2020年5月15日，下午6:26，Till Rohrmann 写道：
>
> Thanks Yu for being our
Kostas Kloudas created FLINK-17729:
--
Summary: Make mandatory to have lib/, plugin/ and dist in
yarn.provided.lib.dirs
Key: FLINK-17729
URL: https://issues.apache.org/jira/browse/FLINK-17729
Project:
I'm okay, but I would suggest to agree on a time of day. What about Monday
morning in Europe?
On Fri, May 15, 2020 at 1:43 PM Piotr Nowojski wrote:
> Hi,
>
> Couple of contributors asked for extending cutting the release branch
> until Monday, what do you think about such extension?
>
> (+1 from
Robert Metzger created FLINK-17730:
--
Summary:
HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart
times out
Key: FLINK-17730
URL: https://issues.apache.org/jira/browse/FLINK-17730
Robert Metzger created FLINK-17731:
--
Summary: Artifact X already exists for build Y
Key: FLINK-17731
URL: https://issues.apache.org/jira/browse/FLINK-17731
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-17732:
--
Summary:
RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList
Key: FLINK-17732
URL: https://issues.apache.org/jira/browse/FLINK-17732
Project: Fl
+1 from my side extend the feature freeze until Monday morning.
Cheers,
Till
On Fri, May 15, 2020 at 2:04 PM Robert Metzger wrote:
> I'm okay, but I would suggest to agree on a time of day. What about Monday
> morning in Europe?
>
> On Fri, May 15, 2020 at 1:43 PM Piotr Nowojski
> wrote:
>
> >
Jingsong Lee created FLINK-17733:
Summary: Add documentation for real-time hive
Key: FLINK-17733
URL: https://issues.apache.org/jira/browse/FLINK-17733
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-17734:
---
Summary: Add specialized collecting sink function
Key: FLINK-17734
URL: https://issues.apache.org/jira/browse/FLINK-17734
Project: Flink
Issue Type: New Featur
Hi, Deepak.
Thanks for the introduction — it's cool to see that you're interested in
contributing to Flink as part of GSoD!
We're looking forward to receiving your application! Let us know if you
have any questions, in the meantime.
Marta
On Thu, May 14, 2020 at 11:35 PM Deepak Vohra
wrote:
>
Caizhi Weng created FLINK-17735:
---
Summary: Add specialized collecting iterator to Blink planner
Key: FLINK-17735
URL: https://issues.apache.org/jira/browse/FLINK-17735
Project: Flink
Issue Type
I completely agree that there are many other aspect of our guarantees and
processes around the @Public and @PublicEvolving classes which need to be
discussed and properly defined. For the sake of keeping this discussion
thread narrowly scoped, I would suggest to start a separate discussion
about th
Please correct me if I am wrong, "put the increased value into the default
configuration" means
we will update that in default flink-conf.yaml but still leave the default
value of `state.backend.fs.memory-threshold`as previously?
It seems I did not get the point why existing setups with existing
Dear community,
with reference to the dev ML thread about guaranteeing API and binary
compatibility for @PublicEvolving classes across bug fix releases [1] I
would like to start a vote about it.
The proposal is that the Flink community starts to guarantee
that @PublicEvolving classes will be API
dengziming created FLINK-17736:
--
Summary: Add flink CEP examples
Key: FLINK-17736
URL: https://issues.apache.org/jira/browse/FLINK-17736
Project: Flink
Issue Type: Improvement
Componen
+1 for Monday morning.
Best,
Jingsong Lee
On Fri, May 15, 2020 at 8:45 PM Till Rohrmann wrote:
> +1 from my side extend the feature freeze until Monday morning.
>
> Cheers,
> Till
>
> On Fri, May 15, 2020 at 2:04 PM Robert Metzger
> wrote:
>
> > I'm okay, but I would suggest to agree on a time
The vote thread can be found here
https://lists.apache.org/thread.html/rc58099fb0e31d0eac951a7bbf7f8bda8b7b65c9ed0c04622f5333745%40%3Cdev.flink.apache.org%3E
.
Cheers,
Till
On Fri, May 15, 2020 at 3:03 PM Till Rohrmann wrote:
> I completely agree that there are many other aspect of our guarante
+1
On Fri, May 15, 2020 at 6:15 AM Till Rohrmann wrote:
> Dear community,
>
> with reference to the dev ML thread about guaranteeing API and binary
> compatibility for @PublicEvolving classes across bug fix releases [1] I
> would like to start a vote about it.
>
> The proposal is that the Flink
+1 (non-binding)
Best,
Jingsong Lee
On Fri, May 15, 2020 at 9:26 PM Thomas Weise wrote:
> +1
>
>
> On Fri, May 15, 2020 at 6:15 AM Till Rohrmann
> wrote:
>
> > Dear community,
> >
> > with reference to the dev ML thread about guaranteeing API and binary
> > compatibility for @PublicEvolving cl
+1 for Monday morning in Europe.
Best
Yun Tang
From: Jingsong Li
Sent: Friday, May 15, 2020 21:17
To: dev
Subject: Re: [DISCUSS] Exact feature freeze date
+1 for Monday morning.
Best,
Jingsong Lee
On Fri, May 15, 2020 at 8:45 PM Till Rohrmann wrote:
> +1 fro
Roman Khachatryan created FLINK-17737:
-
Summary: KeyedStateCheckpointingITCase fails in UC mode
Key: FLINK-17737
URL: https://issues.apache.org/jira/browse/FLINK-17737
Project: Flink
Issu
+1 for Monday morning in Europe.
Best,
Zhijiang
--
From:Yun Tang
Send Time:2020年5月15日(星期五) 21:58
To:dev
Subject:Re: [DISCUSS] Exact feature freeze date
+1 for Monday morning in Europe.
Best
Yun Tang
_
Sounds good, +1.
Best,
Zhijiang
--
From:Thomas Weise
Send Time:2020年5月15日(星期五) 21:33
To:dev
Subject:Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary
compatible across bug fix releases (x.y.u and x.y.v)
+1
O
Till Rohrmann created FLINK-17738:
-
Summary: Remove legacy scheduler option
Key: FLINK-17738
URL: https://issues.apache.org/jira/browse/FLINK-17738
Project: Flink
Issue Type: Task
C
Piotr Nowojski created FLINK-17739:
--
Summary: ResultPartitionTest.testInitializeMoreStateThanBuffer is
unstable
Key: FLINK-17739
URL: https://issues.apache.org/jira/browse/FLINK-17739
Project: Flink
+1
– Ufuk
On Fri, May 15, 2020 at 4:54 PM Zhijiang
wrote:
> Sounds good, +1.
>
> Best,
> Zhijiang
>
>
> --
> From:Thomas Weise
> Send Time:2020年5月15日(星期五) 21:33
> To:dev
> Subject:Re: [VOTE] Guarantee that @PublicEvolving classe
+1
On Sat, May 16, 2020 at 12:21 AM Ufuk Celebi wrote:
> +1
>
> – Ufuk
>
>
> On Fri, May 15, 2020 at 4:54 PM Zhijiang .invalid>
> wrote:
>
> > Sounds good, +1.
> >
> > Best,
> > Zhijiang
> >
> >
> > --
> > From:Thomas Weise
> > Se
+1
Best,
Yangze Guo
On Sat, May 16, 2020 at 12:26 AM Yuan Mei wrote:
>
> +1
>
> On Sat, May 16, 2020 at 12:21 AM Ufuk Celebi wrote:
>
> > +1
> >
> > – Ufuk
> >
> >
> > On Fri, May 15, 2020 at 4:54 PM Zhijiang > .invalid>
> > wrote:
> >
> > > Sounds good, +1.
> > >
> > > Best,
> > > Zhijiang
>
Andrey Zagrebin created FLINK-17740:
---
Summary: Remove flink-container/kubernetes
Key: FLINK-17740
URL: https://issues.apache.org/jira/browse/FLINK-17740
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-17741:
-
Summary: Create integration or e2e test for out of order
(savepoint) barriers
Key: FLINK-17741
URL: https://issues.apache.org/jira/browse/FLINK-17741
Projec
lisen created FLINK-17742:
-
Summary: Blob file not removed after task was cancelled in
standalone mode
Key: FLINK-17742
URL: https://issues.apache.org/jira/browse/FLINK-17742
Project: Flink
Issue Ty
Jingsong Lee created FLINK-17743:
Summary: Python e2e failed by Cannot run program
"venv.zip/.conda/bin/python"
Key: FLINK-17743
URL: https://issues.apache.org/jira/browse/FLINK-17743
Project: Flink
lisen created FLINK-17744:
-
Summary: StreamContextEnvironment#execute cannot be call
JobListener#onJobExecuted
Key: FLINK-17744
URL: https://issues.apache.org/jira/browse/FLINK-17744
Project: Flink
+1 for Monday morning in Europe.
Best,
Danny Chan
在 2020年5月15日 +0800 PM10:51，Zhijiang ，写道：
> +1 for Monday morning in Europe.
>
> Best,
> Zhijiang
>
>
> --
> From:Yun Tang
> Send Time:2020年5月15日(星期五) 21:58
> To:dev
> Subject:Re: [DI
lisen created FLINK-17745:
-
Summary: PackagedProgram' extractedTempLibraries and jarfiles may
be duplicate
Key: FLINK-17745
URL: https://issues.apache.org/jira/browse/FLINK-17745
Project: Flink
Issu
lisen created FLINK-17746:
-
Summary: PackagedProgram' extractedTempLibraries and jarfiles may
be duplicate
Key: FLINK-17746
URL: https://issues.apache.org/jira/browse/FLINK-17746
Project: Flink
Issu
lisen created FLINK-17747:
-
Summary: PackagedProgram' extractedTempLibraries and jarfiles may
be duplicate
Key: FLINK-17747
URL: https://issues.apache.org/jira/browse/FLINK-17747
Project: Flink
Issu
Kurt Young created FLINK-17748:
--
Summary: Remove registration of TableSource/TableSink in Table Env
Key: FLINK-17748
URL: https://issues.apache.org/jira/browse/FLINK-17748
Project: Flink
Issue
Kurt Young created FLINK-17749:
--
Summary: Remove fromTableSource method from TableEnvironment
Key: FLINK-17749
URL: https://issues.apache.org/jira/browse/FLINK-17749
Project: Flink
Issue Type:
+1 for Monday morning in Europe.
Best,
Congxian
Danny Chan 于2020年5月16日周六 上午10:40写道：
> +1 for Monday morning in Europe.
>
> Best,
> Danny Chan
> 在 2020年5月15日 +0800 PM10:51，Zhijiang .invalid>，写道：
> > +1 for Monday morning in Europe.
> >
> > Best,
> > Zhijiang
> >
> >
> >
Hi,
Overall, I agree with increasing this value. but the default value set to
100K maybe something too large from my side.
I want to share some more information from my side.
The small files problem is indeed a problem many users may encounter in
production env. The states(Keyed state and Operat
Dear Apace Flink,
My name is Amr Maghraby, I am a new graduate from AAST college got the
first rank on my class with CGPA 3.92 and joined the international
competition in the US called ROV got the second worldwide and last summer I
have involved in Google Summer of code 2019 and did good work also,
Respected sir/mam,
I came around the projects proposed by Apache Flink for Season of Docs 2020.
I am a newbie to organisation but really liked the ideas of projects and
would love to start contributing and prepare my proposal for Season of Docs.
Please guide me through. Where should I start and t
Hello Flink Dev Community!
I am interested in participating in Google Season of Docs for Apache Flink.
I went through the FLIP-60 detailed proposal and thought this is something
I could do well. I am currently working as a software engineer and have a
B.E in Computer Engineering from one of India'
Sorry for the late jump in.
+1 to keep the compatibility of @PublicEvolving between minor
releases(x.y.a -> x.y.b), as a user I always think this as a bug-fix
release, break the compatibility between minor releases may give users a
surprise.
As the previous emails said, how and when will a @Publi
+1 (non-binding)
Best,
Congxian
Yangze Guo 于2020年5月16日周六 上午12:51写道：
> +1
>
> Best,
> Yangze Guo
>
> On Sat, May 16, 2020 at 12:26 AM Yuan Mei wrote:
> >
> > +1
> >
> > On Sat, May 16, 2020 at 12:21 AM Ufuk Celebi wrote:
> >
> > > +1
> > >
> > > – Ufuk
> > >
> > >
> > > On Fri, May 15, 2020 at
FYI: I'm a moderator of the dev@ list, and we've received about 5 emails
from applicants that were not subscribed to the list.
Initially, I rejected their messages, asking them to subscribe and send the
email again. This has not happened from any of them.
That's why I accepted new applicant message
64 matches
Mail list logo
