+1
On Tue, Jan 19, 2021 at 10:44 AM Leonard Xu wrote:
> +1
>
> Best,
> Leonard
>
> > 在 2021年1月19日，17:32，David Anderson 写道：
> >
> > +1
> >
> > David
> >
> > On Tue, Jan 19, 2021 at 5:28 AM Forward Xu
> wrote:
> >
> >> +1
> >>
> >> Dian Fu 于2021年1月19日周二 上午11:40写道：
> >>
> >>> +1
> >>>
> 在 2
谢波 created FLINK-21049:
--
Summary: query_configuration.html content out date
Key: FLINK-21049
URL: https://issues.apache.org/jira/browse/FLINK-21049
Project: Flink
Issue Type: Bug
Components: D
Timo Walther created FLINK-21050:
Summary: Add an example for complex UDFs
Key: FLINK-21050
URL: https://issues.apache.org/jira/browse/FLINK-21050
Project: Flink
Issue Type: Sub-task
Robert Metzger created FLINK-21051:
--
Summary: SQLClientSchemaRegistryITCase unstable with
InternalServerErrorException: Status 500
Key: FLINK-21051
URL: https://issues.apache.org/jira/browse/FLINK-21051
Thanks Timo for opening this discussion.
+1 I like the idea of adding a deprecation deadline and/or information when
the
functionality was deprecated. It looks like this is already done in the
PyFlink code.
Creating a JIRA issue for removing the functionality, as Till suggested,
might help to
mai
Congrats, Guowei!
Cheers,
Till
On Wed, Jan 20, 2021 at 8:32 AM Matthias Pohl
wrote:
> Congrats, Guowei!
>
> On Wed, Jan 20, 2021 at 8:22 AM Congxian Qiu
> wrote:
>
> > Congrats Guowei!
> >
> > Best,
> > Congxian
> >
> >
> > Danny Chan 于2021年1月20日周三 下午2:59写道：
> >
> > > Congratulations Guowei!
Congratulations Guowei!!
On 20/01/2021, 05:35, "Kurt Young" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
Hi everyone,
I'm very happy to announce th
Congrats and welcome! :-)
On Wed, Jan 20, 2021, at 9:57 AM, Cranmer, Danny wrote:
> Congratulations Guowei!!
>
> On 20/01/2021, 05:35, "Kurt Young" wrote:
>
> CAUTION: This email originated from outside of the organization. Do not
> click links or open attachments unless you can confirm t
akisaya created FLINK-21052:
---
Summary: Wrong FlinkKafkaProducer Constructor described in docs
Key: FLINK-21052
URL: https://issues.apache.org/jira/browse/FLINK-21052
Project: Flink
Issue Type: Bug
Congratulations, Guowei!
Best,
Hailong
在 2021-01-20 15:55:24，"Till Rohrmann" 写道：
>Congrats, Guowei!
>
>Cheers,
>Till
>
>On Wed, Jan 20, 2021 at 8:32 AM Matthias Pohl
>wrote:
>
>> Congrats, Guowei!
>>
>> On Wed, Jan 20, 2021 at 8:22 AM Congxian Qiu
>> wrote:
>>
>> > Congrats Guowei!
>> >
>> > B
Roman Khachatryan created FLINK-21053:
-
Summary: Prevent further RejectedExecutionExceptions in
CheckpointCoordinator failing JM
Key: FLINK-21053
URL: https://issues.apache.org/jira/browse/FLINK-21053
Hi Steven,
understood, thanks for expanding on your point. I will prepare a FLIP now
going for the solution of S3_ACCESS_KEY style environment variables since
overall this fits Flink use-cases better. I think your point that users
have to know how to convert s3.access-key to S3_ACCESS_KEY is valid
Jark Wu created FLINK-21054:
---
Summary: Implement mini-batch optimized slicing window aggregate
operator
Key: FLINK-21054
URL: https://issues.apache.org/jira/browse/FLINK-21054
Project: Flink
Issue
+1
Aljoscha
On 2021/01/18 08:29, Seth Wiesman wrote:
Hi devs,
The discussion of the FLIP-157 [1] seems has reached a consensus through
the mailing thread [2]. I would like to start a vote for it.
The vote will be opened until 20th January (72h), unless there is an
objection or no enough votes
+1 (binding)
Best,
Aljoscha
On 2021/01/15 22:55, Yun Gao wrote:
Hi all,
I would like to start the vote for FLIP-147[1], which propose to support
checkpoints after
tasks finished and is discussed in [2].
The vote will last at least 72 hours (Jan 20th due to weekend), following the
consensus
+1 (binding)
Best,
Arvid
On Wed, Jan 20, 2021 at 12:13 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Best,
> Aljoscha
>
> On 2021/01/15 22:55, Yun Gao wrote:
> >
> >Hi all,
> >
> >I would like to start the vote for FLIP-147[1], which propose to support
> checkpoints after
> >tasks finished and
+1
On Wed, Jan 20, 2021 at 12:07 PM Aljoscha Krettek
wrote:
> +1
>
> Aljoscha
>
> On 2021/01/18 08:29, Seth Wiesman wrote:
> >Hi devs,
> >
> >The discussion of the FLIP-157 [1] seems has reached a consensus through
> >the mailing thread [2]. I would like to start a vote for it.
> >
> >The vote w
Hi,
I would prefer not to rely on the Jira for marking when something is
supposed to be deleted. If `@Deprecated(since, planned_to_remove_on)` would
have two obligatory parameters, there would be no way to "forget" about
marking it and it would be also self documenting (I don't imagine users
using
Hi,
I think having two Deprecated annotations (Flink and Java) may be confusing.
One alternative is to combine standard annotation with mandatory Javadocs
tags (checked with checkstyle).
And starting from Java 9 it has "since" and "forRemoval" arguments.
Regards,
Roman
On Wed, Jan 20, 2021 at
Vladislav Protsenko created FLINK-21055:
---
Summary: Allow TIMESTAMP WITH LOCAL TIME ZONE (Instant) to be
rowtime
Key: FLINK-21055
URL: https://issues.apache.org/jira/browse/FLINK-21055
Project: F
Maybe a different minor idea: Would it be possible to treat the SSG
resource requirements as a hint for the runtime similar to how slot sharing
groups are designed at the moment? Meaning that we don't give the guarantee
that Flink will always deploy this set of tasks together no matter what
comes.
Congratulations!
On Wed, Jan 20, 2021 at 3:41 AM hailongwang <18868816...@163.com> wrote:
> Congratulations, Guowei!
>
> Best,
> Hailong
>
> 在 2021-01-20 15:55:24，"Till Rohrmann" 写道：
> >Congrats, Guowei!
> >
> >Cheers,
> >Till
> >
> >On Wed, Jan 20, 2021 at 8:32 AM Matthias Pohl
> >wrote:
> >
>
Congrats, Guowei!
On Wed, Jan 20, 2021 at 10:32 AM Seth Wiesman wrote:
> Congratulations!
>
> On Wed, Jan 20, 2021 at 3:41 AM hailongwang <18868816...@163.com> wrote:
>
> > Congratulations, Guowei!
> >
> > Best,
> > Hailong
> >
> > 在 2021-01-20 15:55:24，"Till Rohrmann" 写道：
> > >Congrats, Guowei
Nazar Volynets created FLINK-21057:
--
Summary: Streaming checkpointing with small interval leads app to
hang
Key: FLINK-21057
URL: https://issues.apache.org/jira/browse/FLINK-21057
Project: Flink
Nazar Volynets created FLINK-21056:
--
Summary: Streaming checkpointing is failing occasionally
Key: FLINK-21056
URL: https://issues.apache.org/jira/browse/FLINK-21056
Project: Flink
Issue Typ
Congrats, Guowei!
Best,
Paul Lam
> 2021年1月21日 07:21，Steven Wu 写道：
>
> Congrats, Guowei!
>
> On Wed, Jan 20, 2021 at 10:32 AM Seth Wiesman wrote:
>
>> Congratulations!
>>
>> On Wed, Jan 20, 2021 at 3:41 AM hailongwang <18868816...@163.com> wrote:
>>
>>> Congratulations, Guowei!
>>>
>>> Bes
Hi all,
The vote has been opened for more than 72 hours, and
currently we have alreadly received 4 votes (3 bindings)
and no -1 votes. Thus I'm happy to announce that FLIP-147
is approved.
* Guowei (changed to binding for being Committer already,
Congrats Guowei!)
* Roman (non-binding)
* Alj
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.10.3,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
I think this makes sense.
The semantic of a SSG is that operators in the group *can* be scheduled
together in a slot, which is not a *must*. Specifying resources for SSGs
should not change that semantic. In cases that needs for scheduling the
operators into different slots arise, it makes sense fo
@Till
Also +1 to treat the SSG resource requirements as a hint instead of a
restrict. We can treat it as a follow-up effort and make it clear in
JavaDocs at the first step.
Best,
Yangze Guo
On Thu, Jan 21, 2021 at 10:00 AM Xintong Song wrote:
>
> I think this makes sense.
>
> The semantic of a
Is there even a functional difference between specifying the
requirements for an SSG vs specifying the same requirements on a single
operator within that group (ideally a colocation group to avoid this
whole hint business)?
Wouldn't we get the best of both worlds in the latter case?
Users can
孙铮 created FLINK-21058:
--
Summary: The Show Partitinos command is supported under the Flink
dialect to show all partitions
Key: FLINK-21058
URL: https://issues.apache.org/jira/browse/FLINK-21058
Project: Flink
cc this to user & user-zh mailing list because this will affect lots of
users, and also quite a lot of users
were asking questions around this topic.
Let me try to understand this from user's perspective.
Your proposal will affect five functions, which are:
- PROCTIME()
- NOW()
- CURREN
Thanks to Leonard Xu for discussing this tricky topic. At present, there are
many Flink jobs in our production environment that are used to count day-level
reports (eg: count PV/UV ).
If use the default Flink SQL, the window time range of the statistics is
incorrect, then the statistical res
Great examples to understand the problem and the proposed changes, @Kurt!
Thanks Leonard for investigating this problem.
The time-zone problems around time functions and windows have bothered a
lot of users. It's time to fix them!
The return value changes sound reasonable to me, and keeping the r
Thomas Weise created FLINK-21059:
Summary: KafkaSourceEnumerator does not honor consumer properties
Key: FLINK-21059
URL: https://issues.apache.org/jira/browse/FLINK-21059
Project: Flink
Issu
Congrats, Guowei!
Thanks,
Biao /'bɪ.aʊ/
On Thu, 21 Jan 2021 at 09:30, Paul Lam wrote:
> Congrats, Guowei!
>
> Best,
> Paul Lam
>
> > 2021年1月21日 07:21，Steven Wu 写道：
> >
> > Congrats, Guowei!
> >
> > On Wed, Jan 20, 2021 at 10:32 AM Seth Wiesman
> wrote:
> >
> >> Congratulations!
> >>
> >> On
Spongebob created FLINK-21060:
-
Summary: Could not create the DispatcherResourceManagerComponent
Key: FLINK-21060
URL: https://issues.apache.org/jira/browse/FLINK-21060
Project: Flink
Issue Type:
Tzu-Li (Gordon) Tai created FLINK-21061:
---
Summary: Introduce RemotePersistedValue construct in Stateful
Functions
Key: FLINK-21061
URL: https://issues.apache.org/jira/browse/FLINK-21061
Project:
xiaozilong created FLINK-21062:
--
Summary: Meeting NPE when using the dynamic Index in elasticsearch
connector
Key: FLINK-21062
URL: https://issues.apache.org/jira/browse/FLINK-21062
Project: Flink
Dawid Wysakowicz created FLINK-21063:
Summary: ElasticsearchSinkITCase fails while setting up ES cluster
Key: FLINK-21063
URL: https://issues.apache.org/jira/browse/FLINK-21063
Project: Flink
Hi everyone,
I've now started a FLIP and am opening this discussion thread. Very much
looking forward to your feedback!
FLIP: https://cwiki.apache.org/confluence/x/ngtRCg
The first big point I'd like to discuss is about the mechanism of "when"
the EVs (environment variables) are looked up. I'll
42 matches
Mail list logo
