Juha Mynttinen created FLINK-19238:
--
Summary: RocksDB performance issue with low managed memory and
high parallelism
Key: FLINK-19238
URL: https://issues.apache.org/jira/browse/FLINK-19238
Project: F
Congrats and welcome, Arvid!
Best Regards,
Yu
On Tue, 15 Sep 2020 at 14:51, Yun Gao wrote:
> Congratulations Arvid !
>
> Best,
> Yun
>
>
>
> --Original Mail --
> Sender:Yangze Guo
> Send Date:Tue Sep 15 13:39:56 2020
> Recipients:dev
> Subject:Re: [ANNOUNCE]
Congratulations, Niels!
Best Regards,
Yu
On Tue, 15 Sep 2020 at 14:52, Yun Gao wrote:
> Congratulations Niels!
>
> Best,
> Yun
>
>
> --
> Sender:Congxian Qiu
> Date:2020/09/15 13:33:31
> Recipient:dev@flink.apache.org
> Theme:R
Sorry for joining so late.
Generally speaking I like this idea very much!
I have one idea about the StateBackend interface. Could we instead of
adding a flag method boolean isLegacyStateBackend remove the
checkpointstorage related methods from StateBackend right away? The
old/legacy implementatio
Welcome, Niels!
Best,
Dawid
On 14/09/2020 11:22, Matt Wang wrote:
> Congratulations, Niels!
>
>
> --
>
> Best,
> Matt Wang
>
>
> On 09/14/2020 17:02，Konstantin Knauf wrote：
> Congratulations!
>
> On Mon, Sep 14, 2020 at 10:51 AM tison wrote:
>
> Congrats!
>
> Best,
> tison.
>
>
> Aljoscha Krett
+1 (binding)
Aljoscha
Congratulations Arvid! Very well deserved!
Best,
Dawid
On 15/09/2020 04:38, Zhijiang wrote:
> Hi all,
>
> On behalf of the PMC, I’m very happy to announce Arvid Heise as a new Flink
> committer.
>
> Arvid has been an active community member for more than a year, with 138
> contributions includ
On 15.09.20 07:00, Xuannan Su wrote:
Thanks for your comment. I agree that we should not introduce tight coupling
with PipelineExecutor to the execution environment. With that in mind, to
distinguish the per-job and session mode, we can introduce a new method, naming
isPerJobModeExecutor, in t
Congratulations Arvid !
Best,
Jingsong
On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysakowicz
wrote:
> Congratulations Arvid! Very well deserved!
>
> Best,
>
> Dawid
>
> On 15/09/2020 04:38, Zhijiang wrote:
> > Hi all,
> >
> > On behalf of the PMC, I’m very happy to announce Arvid Heise as a new
> Fl
Dear community,
happy to share a belated update for the past week. This time with the
release of Flink 1.11.2, a couple of discussions and FLIPs on improving
Flink's APIs and dropping some baggage, most notably Scala 2.11, a new
unified sink API and a bit more.
Flink Development
==
*
On 15.09.20 01:33, Steven Wu wrote:
## concurrent checkpoints
@Aljoscha Krettek regarding the concurrent
checkpoints, let me illustrate with a simple DAG below.
[image: image.png]
Hi Steven,
images don't make it through to the mailing lists. You would need to
host the file somewhere and sen
On 15.09.20 06:05, Guowei Ma wrote:
## Using checkpointId
In the batch execution mode there would be no normal checkpoint any more.
That is why we do not introduce the checkpoint id in the API. So it is a
great thing that sink decouples its implementation from checkpointid. :)
Yes, this is a ve
> What I understand is that HiveSink's implementation might need the local
> committer(FileCommitter) because the file rename is needed.
> But the iceberg only needs to write the manifest file. Would you like to
> enlighten me why the Iceberg needs the local committer?
> Thanks
Sorry if I caused a
On 15.09.20 09:55, Dawid Wysakowicz wrote:
BTW Let's not forget about Piotr's comment. I think we could add the
isAvailable or similar method to the Writer interface in the FLIP.
I'm not so sure about this, the sinks I'm aware of would not be able to
implement this method: Kafka doesn't have t
Hi all,
It's great seeing many new Flink committers recently, and to add to that
I'd like to announce one more new committer: Igal Shilman!
Igal has been a long time member of the community. You may very likely know
Igal from the Stateful Functions sub-project, as he was the original author
of it
Congrats, Igal!
Best,
Paul Lam
> 2020年9月15日 16:14，Tzu-Li (Gordon) Tai 写道：
>
> Hi all,
>
> It's great seeing many new Flink committers recently, and to add to that
> I'd like to announce one more new committer: Igal Shilman!
>
> Igal has been a long time member of the community. You may very l
Congrats, Igal! Well deserved.
David
On Tue, Sep 15, 2020 at 10:14 AM Tzu-Li (Gordon) Tai
wrote:
> Hi all,
>
> It's great seeing many new Flink committers recently, and to add to that
> I'd like to announce one more new committer: Igal Shilman!
>
> Igal has been a long time member of the commun
Congrats, Arvid!
Best,
Paul Lam
> 2020年9月15日 15:29，Jingsong Li 写道：
>
> Congratulations Arvid !
>
> Best,
> Jingsong
>
> On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysakowicz
> wrote:
>
>> Congratulations Arvid! Very well deserved!
>>
>> Best,
>>
>> Dawid
>>
>> On 15/09/2020 04:38, Zhijiang wr
+1 (binding)
On Tue, Sep 15, 2020 at 3:26 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Aljoscha
>
Congrats! Arvid.
Best,
Leonard
> 在 2020年9月15日，16:23，Paul Lam 写道：
>
> Congrats, Arvid!
>
> Best,
> Paul Lam
>
>> 2020年9月15日 15:29，Jingsong Li 写道：
>>
>> Congratulations Arvid !
>>
>> Best,
>> Jingsong
>>
>> On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysakowicz
>> wrote:
>>
>>> Congratulations
Congrats Arvid and welcome aboard!
Cheers,
Fabian
Am Di., 15. Sept. 2020 um 10:23 Uhr schrieb Paul Lam :
> Congrats, Arvid!
>
> Best,
> Paul Lam
>
> > 2020年9月15日 15:29，Jingsong Li 写道：
> >
> > Congratulations Arvid !
> >
> > Best,
> > Jingsong
> >
> > On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysako
Congrats Igal and welcome aboard!
Cheers,
Fabian
Am Di., 15. Sept. 2020 um 10:22 Uhr schrieb David Anderson <
da...@alpinegizmo.com>:
> Congrats, Igal! Well deserved.
>
> David
>
> On Tue, Sep 15, 2020 at 10:14 AM Tzu-Li (Gordon) Tai
> wrote:
>
> > Hi all,
> >
> > It's great seeing many new F
Hi Aljoscha,
I thought about relying on the failover mechanism to re-execute the whole graph
when the cache doesn’t exist. The only concern I have is that every job that
uses the cache table in the per-job cluster will have to go through the
following process,
job submit -> job fail because of
Congratulations!
Regards,
Dian
> 在 2020年9月15日，下午4:32，Fabian Hueske 写道：
>
> Congrats Igal and welcome aboard!
>
> Cheers,
> Fabian
>
>
>
> Am Di., 15. Sept. 2020 um 10:22 Uhr schrieb David Anderson <
> da...@alpinegizmo.com>:
>
>> Congrats, Igal! Well deserved.
>>
>> David
>>
>> On Tue, S
Congrats Igal. It's good to have you among committers! :)
Best,
Dawid
On 15/09/2020 10:14, Tzu-Li (Gordon) Tai wrote:
> Hi all,
>
> It's great seeing many new Flink committers recently, and to add to that
> I'd like to announce one more new committer: Igal Shilman!
>
> Igal has been a long time
zhangyunyun created FLINK-19239:
---
Summary: FlinkKafkaProducer
Key: FLINK-19239
URL: https://issues.apache.org/jira/browse/FLINK-19239
Project: Flink
Issue Type: Bug
Components: Connec
Congratulations, Arvid! Well deserved.
Best,
David
On Tue, Sep 15, 2020 at 10:23 AM Paul Lam wrote:
> Congrats, Arvid!
>
> Best,
> Paul Lam
>
> > 2020年9月15日 15:29，Jingsong Li 写道：
> >
> > Congratulations Arvid !
> >
> > Best,
> > Jingsong
> >
> > On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysakowicz
Ryan created FLINK-19240:
Summary: Hello, I have a job with multiple Kafka sources. They all
contain certain historical data. If you use the events-time window, it will
cause sources with less data to cover more sources through water mark. Is there
a so
Congrats Arvid!
On Tue, Sep 15, 2020 at 11:12 AM David Anderson
wrote:
> Congratulations, Arvid! Well deserved.
>
> Best,
> David
>
> On Tue, Sep 15, 2020 at 10:23 AM Paul Lam wrote:
>
> > Congrats, Arvid!
> >
> > Best,
> > Paul Lam
> >
> > > 2020年9月15日 15:29，Jingsong Li 写道：
> > >
> > > Congra
Congrats Igal!
--
Best,
Matt Wang
On 09/15/2020 17:00，Dawid Wysakowicz wrote：
Congrats Igal. It's good to have you among committers! :)
Best,
Dawid
On 15/09/2020 10:14, Tzu-Li (Gordon) Tai wrote:
Hi all,
It's great seeing many new Flink committers recently, and to add to that
I'd like to a
Congratulations!
Best,
Xingbo
Igal Shilman 于2020年9月15日周二 下午5:44写道：
> Congrats Arvid!
>
> On Tue, Sep 15, 2020 at 11:12 AM David Anderson
> wrote:
>
> > Congratulations, Arvid! Well deserved.
> >
> > Best,
> > David
> >
> > On Tue, Sep 15, 2020 at 10:23 AM Paul Lam wrote:
> >
> > > Congrats, A
Congratulations!
Best,
Xingbo
Matt Wang 于2020年9月15日周二 下午5:44写道：
> Congrats Igal!
>
>
> --
>
> Best,
> Matt Wang
>
>
> On 09/15/2020 17:00，Dawid Wysakowicz wrote：
> Congrats Igal. It's good to have you among committers! :)
>
> Best,
>
> Dawid
>
> On 15/09/2020 10:14, Tzu-Li (Gordon) Tai wrote:
>
Congrats and welcome, Igal!
Best Regards,
Yu
On Tue, 15 Sep 2020 at 17:47, Xingbo Huang wrote:
> Congratulations!
>
> Best,
> Xingbo
>
> Matt Wang 于2020年9月15日周二 下午5:44写道：
>
> > Congrats Igal!
> >
> >
> > --
> >
> > Best,
> > Matt Wang
> >
> >
> > On 09/15/2020 17:00，Dawid Wysakowicz wrote：
>
Congratulations! ;-)
On Tue, Sep 15, 2020 at 11:47 AM Xingbo Huang wrote:
> Congratulations!
>
> Best,
> Xingbo
>
> Igal Shilman 于2020年9月15日周二 下午5:44写道：
>
> > Congrats Arvid!
> >
> > On Tue, Sep 15, 2020 at 11:12 AM David Anderson
> > wrote:
> >
> > > Congratulations, Arvid! Well deserved.
> >
Congrats, Igal! :-)
On Tue, Sep 15, 2020 at 11:47 AM Xingbo Huang wrote:
> Congratulations!
>
> Best,
> Xingbo
>
> Matt Wang 于2020年9月15日周二 下午5:44写道：
>
> > Congrats Igal!
> >
> >
> > --
> >
> > Best,
> > Matt Wang
> >
> >
> > On 09/15/2020 17:00，Dawid Wysakowicz wrote：
> > Congrats Igal. It's go
Congrats!
Best,
Matthias
On Tue, Sep 15, 2020 at 9:26 AM Dawid Wysakowicz
wrote:
> Welcome, Niels!
>
> Best,
>
> Dawid
>
> On 14/09/2020 11:22, Matt Wang wrote:
> > Congratulations, Niels!
> >
> >
> > --
> >
> > Best,
> > Matt Wang
> >
> >
> > On 09/14/2020 17:02，Konstantin Knauf wrote：
> > Con
On 15.09.20 10:54, Xuannan Su wrote:
One way of solving this is to let the CatalogManager probe the existence of the
IntermediateResult so that the planner can decide if the cache table should be
used.
That could be a reasonable solution, yes.
Best,
Aljoscha
Hi all,
It's great seeing many new Flink committers recently, and on behalf of the
PMC, I'd like to announce one more new committer: Yun Tang!
Yun has been an active contributor for more than two years, with 132
contributions including 72 commits and many PR reviews.
Yun mainly works on state ba
Congratulations!
Best
Matthias Pohl 于2020年9月15日周二 下午6:07写道：
> Congratulations! ;-)
>
> On Tue, Sep 15, 2020 at 11:47 AM Xingbo Huang wrote:
>
> > Congratulations!
> >
> > Best,
> > Xingbo
> >
> > Igal Shilman 于2020年9月15日周二 下午5:44写道：
> >
> > > Congrats Arvid!
> > >
> > > On Tue, Sep 15, 2020 a
Congratulations Igal! Well deserved!
Rafi
On Tue, Sep 15, 2020 at 11:14 AM Tzu-Li (Gordon) Tai
wrote:
> Hi all,
>
> It's great seeing many new Flink committers recently, and to add to that
> I'd like to announce one more new committer: Igal Shilman!
>
> Igal has been a long time member of the
Congratulations!
Thanks,
Zhu
Yu Li 于2020年9月15日周二 下午6:19写道：
> Hi all,
>
> It's great seeing many new Flink committers recently, and on behalf of the
> PMC, I'd like to announce one more new committer: Yun Tang!
>
> Yun has been an active contributor for more than two years, with 132
> contributi
Congratulations Yun Tang!
Best,
Yun Gao
--
Sender:Zhu Zhu
Date:2020/09/15 18:49:24
Recipient:dev
Cc:; Yun Tang
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang
Congratulations!
Thanks,
Zhu
Yu Li 于2020年9月15日周二 下午6:19写道
Congratulations, Igal!
Thanks,
Zhu
Rafi Aroch 于2020年9月15日周二 下午6:43写道：
> Congratulations Igal! Well deserved!
>
> Rafi
>
>
> On Tue, Sep 15, 2020 at 11:14 AM Tzu-Li (Gordon) Tai
> wrote:
>
> > Hi all,
> >
> > It's great seeing many new Flink committers recently, and to add to that
> > I'd like
Congratulations, Yun~!
Thank you~
Xintong Song
On Tue, Sep 15, 2020 at 6:50 PM Zhu Zhu wrote:
> Congratulations!
>
> Thanks,
> Zhu
>
> Yu Li 于2020年9月15日周二 下午6:19写道：
>
> > Hi all,
> >
> > It's great seeing many new Flink committers recently, and on behalf of
> the
> > PMC, I'd like to announ
Congratulations~!
Thank you~
Xintong Song
On Tue, Sep 15, 2020 at 6:43 PM Rafi Aroch wrote:
> Congratulations Igal! Well deserved!
>
> Rafi
>
>
> On Tue, Sep 15, 2020 at 11:14 AM Tzu-Li (Gordon) Tai
> wrote:
>
> > Hi all,
> >
> > It's great seeing many new Flink committers recently, and to
Congratulations! Well deserved!
Regards,
Dian
> 在 2020年9月15日，下午6:51，Yun Gao 写道：
>
> Congratulations Yun Tang!
>
>
> Best,
> Yun Gao
>
>
> --
> Sender:Zhu Zhu
> Date:2020/09/15 18:49:24
> Recipient:dev
> Cc:; Yun Tang
> Theme:Re
Congrats, Yun!
Best,
Yangze Guo
On Tue, Sep 15, 2020 at 6:58 PM Dian Fu wrote:
>
> Congratulations! Well deserved!
>
> Regards,
> Dian
>
> > 在 2020年9月15日，下午6:51，Yun Gao 写道：
> >
> > Congratulations Yun Tang!
> >
> >
> > Best,
> > Yun Gao
> >
> >
> > --
Congrats, Yun!
Best,
Leonard
> 在 2020年9月15日，19:01，Yangze Guo 写道：
>
> Congrats, Yun!
Congratulations, Yun!
Best,
Yang
Leonard Xu 于2020年9月15日周二 下午7:11写道：
> Congrats, Yun!
>
> Best,
> Leonard
> > 在 2020年9月15日，19:01，Yangze Guo 写道：
> >
> > Congrats, Yun!
>
>
Robert Metzger created FLINK-19241:
--
Summary: Forward ClusterEntrypoint ioExecutor to ResourceManager
Key: FLINK-19241
URL: https://issues.apache.org/jira/browse/FLINK-19241
Project: Flink
I
Hi, Dawid
>>I still find the merging case the most confusing. I don't necessarily
understand why do you need the "SingleFileCommit" step in this scenario.
The way I
>> understand "commit" operation is that it makes some data/artifacts
visible to the external system, thus it should be immutable fro
henvealf created FLINK-19242:
Summary: org.apache.flink.table.api.ValidationException: Cannot
resolve field
Key: FLINK-19242
URL: https://issues.apache.org/jira/browse/FLINK-19242
Project: Flink
Chesnay Schepler created FLINK-19243:
Summary: Bump Snakeyaml to 1.27
Key: FLINK-19243
URL: https://issues.apache.org/jira/browse/FLINK-19243
Project: Flink
Issue Type: Improvement
Congratulations!
Zhu Zhu 于2020年9月15日周二 下午6:51写道：
> Congratulations, Igal!
>
> Thanks,
> Zhu
>
> Rafi Aroch 于2020年9月15日周二 下午6:43写道：
>
> > Congratulations Igal! Well deserved!
> >
> > Rafi
> >
> >
> > On Tue, Sep 15, 2020 at 11:14 AM Tzu-Li (Gordon) Tai <
> tzuli...@apache.org>
> > wrote:
> >
> >
Congratulations!
Yang Wang 于2020年9月15日周二 下午7:15写道：
> Congratulations, Yun!
>
> Best,
> Yang
>
> Leonard Xu 于2020年9月15日周二 下午7:11写道：
>
> > Congrats, Yun!
> >
> > Best,
> > Leonard
> > > 在 2020年9月15日，19:01，Yangze Guo 写道：
> > >
> > > Congrats, Yun!
> >
> >
>
--
Best,
Benchao Li
Congratulations, Yun!
Best,
tison.
Benchao Li 于2020年9月15日周二 下午8:15写道：
> Congratulations!
>
> Yang Wang 于2020年9月15日周二 下午7:15写道：
>
> > Congratulations, Yun!
> >
> > Best,
> > Yang
> >
> > Leonard Xu 于2020年9月15日周二 下午7:11写道：
> >
> > > Congrats, Yun!
> > >
> > > Best,
> > > Leonard
> > > > 在 2020
Congratulations!
All the best,
Igal.
On Tue, Sep 15, 2020 at 2:17 PM tison wrote:
> Congratulations, Yun!
>
> Best,
> tison.
>
>
> Benchao Li 于2020年9月15日周二 下午8:15写道：
>
> > Congratulations!
> >
> > Yang Wang 于2020年9月15日周二 下午7:15写道：
> >
> > > Congratulations, Yun!
> > >
> > > Best,
> > > Yang
>
Congratulations!
On 15/09/2020 12:19, Yu Li wrote:
> Hi all,
>
> It's great seeing many new Flink committers recently, and on behalf of the
> PMC, I'd like to announce one more new committer: Yun Tang!
>
> Yun has been an active contributor for more than two years, with 132
> contributions includi
Congrats Igal!
On Tue, Sep 15, 2020 at 7:13 AM Benchao Li wrote:
> Congratulations!
>
> Zhu Zhu 于2020年9月15日周二 下午6:51写道：
>
> > Congratulations, Igal!
> >
> > Thanks,
> > Zhu
> >
> > Rafi Aroch 于2020年9月15日周二 下午6:43写道：
> >
> > > Congratulations Igal! Well deserved!
> > >
> > > Rafi
> > >
> > >
>
Hey Dawid,
I didn't want to break compatibility but if there is precedent and everyone
is ok with it then I'm +1.
Seth
On Tue, Sep 15, 2020 at 2:22 AM Dawid Wysakowicz
wrote:
> Sorry for joining so late.
>
> Generally speaking I like this idea very much!
>
> I have one idea about the StateBack
Ying Z created FLINK-19244:
--
Summary: CsvRowDataDeserializationSchema throws cast exception :
Row length mismatch.
Key: FLINK-19244
URL: https://issues.apache.org/jira/browse/FLINK-19244
Project: Flink
There is a good number of precedents that introduced backwards
incompatible changes to that interface (which is PublicEvolving btw). We
introduced a couple of additional arguments to the
createKeyedStateBackend method and later on removed the methods with
default implementation for backwards compat
Sounds good to me. I'll update the FLIP.
On Tue, Sep 15, 2020 at 8:35 AM Dawid Wysakowicz
wrote:
> There is a good number of precedents that introduced backwards
> incompatible changes to that interface (which is PublicEvolving btw). We
> introduced a couple of additional arguments to the
> crea
> images don't make it through to the mailing lists. You would need to host
the file somewhere and send a link.
Sorry about that. Here is the sample DAG in google drawings.
https://docs.google.com/drawings/d/1-P8F2jF9RG9HHTtAfWEBRuU_2uV9aDTdqEt5dLs2JPk/edit?usp=sharing
On Tue, Sep 15, 2020 at 4:
Stephan Ewen created FLINK-19245:
Summary: Set default queue capacity for FLIP-27 source handover
queue to 2
Key: FLINK-19245
URL: https://issues.apache.org/jira/browse/FLINK-19245
Project: Flink
Congratulations!
> -原始邮件-
> 发件人: "Dawid Wysakowicz"
> 发送时间: 2020-09-15 20:34:34 (星期二)
> 收件人: dev@flink.apache.org, tang...@apache.org, "Yun Tang"
> 抄送:
> 主题: Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang
>
> Congratulations!
>
> On 15/09/2020 12:19, Yu Li wrote:
> > Hi all,
>
Robert Metzger created FLINK-19246:
--
Summary: TableSourceITCase.testStreamScanParallelism fails on
private Azure accounts
Key: FLINK-19246
URL: https://issues.apache.org/jira/browse/FLINK-19246
Proje
congrats, Yun!
On Tue, Sep 15, 2020 at 6:19 PM Yu Li wrote:
> Hi all,
>
> It's great seeing many new Flink committers recently, and on behalf of the
> PMC, I'd like to announce one more new committer: Yun Tang!
>
> Yun has been an active contributor for more than two years, with 132
> contributi
Aljoscha Krettek created FLINK-19247:
Summary: Update Chinese documentation after removal of Kafka 0.10
and 0.11
Key: FLINK-19247
URL: https://issues.apache.org/jira/browse/FLINK-19247
Project: Fl
Welcome, Igal!
On Tue, Sep 15, 2020 at 3:18 PM Seth Wiesman wrote:
> Congrats Igal!
>
> On Tue, Sep 15, 2020 at 7:13 AM Benchao Li wrote:
>
> > Congratulations!
> >
> > Zhu Zhu 于2020年9月15日周二 下午6:51写道：
> >
> > > Congratulations, Igal!
> > >
> > > Thanks,
> > > Zhu
> > >
> > > Rafi Aroch 于2020年
Shiyu Jin created FLINK-19248:
-
Summary: The main method caused an error: No result found for job,
was execute() called before getting the result
Key: FLINK-19248
URL: https://issues.apache.org/jira/browse/FLINK-19248
Congxian Qiu(klion26) created FLINK-19249:
-
Summary: Job would wait sometime(~10 min) before failover if some
connection broken
Key: FLINK-19249
URL: https://issues.apache.org/jira/browse/FLINK-19249
Congratulations!
On Tue, Sep 15, 2020 at 4:29 PM Yuan Mei wrote:
> congrats, Yun!
>
> On Tue, Sep 15, 2020 at 6:19 PM Yu Li wrote:
>
> > Hi all,
> >
> > It's great seeing many new Flink committers recently, and on behalf of
> the
> > PMC, I'd like to announce one more new committer: Yun Tang!
>
Congratulations :)
On Tue, Sep 15, 2020 at 4:48 PM Stephan Ewen wrote:
> Welcome, Igal!
>
> On Tue, Sep 15, 2020 at 3:18 PM Seth Wiesman wrote:
>
> > Congrats Igal!
> >
> > On Tue, Sep 15, 2020 at 7:13 AM Benchao Li wrote:
> >
> > > Congratulations!
> > >
> > > Zhu Zhu 于2020年9月15日周二 下午6:51写道：
+1 (binding)
David
On Tue, Sep 15, 2020 at 10:25 AM Tzu-Li (Gordon) Tai
wrote:
> +1 (binding)
>
> On Tue, Sep 15, 2020 at 3:26 PM Aljoscha Krettek
> wrote:
>
> > +1 (binding)
> >
> > Aljoscha
> >
>
Hi everyone,
@Aljoscha, I have updated the Per-Job mode Section of the FLIP.
It seems that people involved in the discussion have reach a consensus. If
there are no more comments, I would like to start the voting thread tomorrow.
Best,
Xuannan
On Sep 15, 2020, 6:18 PM +0800, Aljoscha Krettek ,
Stephan Ewen created FLINK-19250:
Summary: SplitFetcherManager does not propagate errors correctly
Key: FLINK-19250
URL: https://issues.apache.org/jira/browse/FLINK-19250
Project: Flink
Issue
Stephan Ewen created FLINK-19251:
Summary: Avoid confusing queue handling in
"SplitReader.handleSplitsChanges()"
Key: FLINK-19251
URL: https://issues.apache.org/jira/browse/FLINK-19251
Project: Flink
> AFAIK the committer would not see the file-1-2 when ck1 happens in the
ExactlyOnce mode.
@Guowei Ma I think you are right for exactly once
checkpoint semantics. what about "at least once"? I guess we can argue that
it is fine to commit file-1-2 for at least once mode.
I still like the concept
Koala Lam created FLINK-19252:
-
Summary: Jaas file created under io.tmp.dirs - folder not created
if not exists
Key: FLINK-19252
URL: https://issues.apache.org/jira/browse/FLINK-19252
Project: Flink
Congrats, Yun! Well deserved!
Best,
Paul Lam
> 2020年9月15日 19:14，Yang Wang 写道：
>
> Congratulations, Yun!
>
> Best,
> Yang
>
> Leonard Xu 于2020年9月15日周二 下午7:11写道：
>
>> Congrats, Yun!
>>
>> Best,
>> Leonard
>>> 在 2020年9月15日，19:01，Yangze Guo 写道：
>>>
>>> Congrats, Yun!
>>
>>
Congratulations Yun!
On Wed, Sep 16, 2020 at 10:20 AM Paul Lam wrote:
> Congrats, Yun! Well deserved!
>
> Best,
> Paul Lam
>
> > 2020年9月15日 19:14，Yang Wang 写道：
> >
> > Congratulations, Yun!
> >
> > Best,
> > Yang
> >
> > Leonard Xu 于2020年9月15日周二 下午7:11写道：
> >
> >> Congrats, Yun!
> >>
> >> Best
Congratulations Igal!
Best,
Yun
--
Sender:Stephan Ewen
Date:2020/09/15 22:48:30
Recipient:dev
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Igal Shilman
Welcome, Igal!
On Tue, Sep 15, 2020 at 3:18 PM Seth Wiesman wrote:
Dian Fu created FLINK-19253:
---
Summary: SourceReaderTestBase.testAddSplitToExistingFetcher hangs
Key: FLINK-19253
URL: https://issues.apache.org/jira/browse/FLINK-19253
Project: Flink
Issue Type: Bu
Congratulations Yun!
On Wed, 16 Sep 2020 at 10:40, Rui Li wrote:
> Congratulations Yun!
>
> On Wed, Sep 16, 2020 at 10:20 AM Paul Lam wrote:
>
> > Congrats, Yun! Well deserved!
> >
> > Best,
> > Paul Lam
> >
> > > 2020年9月15日 19:14，Yang Wang 写道：
> > >
> > > Congratulations, Yun!
> > >
> > > Bes
Jun Zhang created FLINK-19254:
-
Summary: Invalid UTF-8 start byte exception
Key: FLINK-19254
URL: https://issues.apache.org/jira/browse/FLINK-19254
Project: Flink
Issue Type: Bug
Compo
Congratulations and welcome, Yun!
--
From:Jark Wu
Send Time:2020年9月16日(星期三) 11:35
To:dev
Cc:tangyun ; Yun Tang
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang
Congratulations Yun!
On Wed, 16 Sep 2020 at 10:40, Rui L
Congratulations and welcome, Igal!
--
From:Yun Gao
Send Time:2020年9月16日(星期三) 10:59
To:Stephan Ewen ; dev
Subject:Re: Re: [ANNOUNCE] New Apache Flink Committer - Igal Shilman
Congratulations Igal!
Best,
Yun
Hi all,
I'd like to start the vote for FLIP-36[1], which has been discussed in
thread[2].
The vote will be open for 72h, until September 19, 2020, 04:00 AM UTC, unless
there's an objection or not enough votes.
Best,
Xuannan
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-36%3A+Sup
Hi, Steven
Thanks you for your thoughtful ideas and concerns.
>>I still like the concept of grouping data files per checkpoint for
streaming mode. it is cleaner and probably easier to manage and deal with
commit failures. Plus, it >>can reduce dupes for the at least once
>>mode. I understand chec
Hi everyone,
It's great seeing many new Flink committers recently, and on behalf of the
PMC,
I'd like to announce one more new committer: Godfrey He.
Godfrey is a very long time contributor in the Flink community since the
end of 2016.
He has been a very active contributor in the Flink SQL compon
Hi,all
Thanks for all your valuable options and ideas.Currently there are many
topics in the mail. I try to summarize what is consensus and what is not.
Correct me if I am wrong.
## Consensus
1. The motivation of the unified sink API is to decouple the sink
implementation from the different runt
Congratulations :)
Best,
Guowei
On Wed, Sep 16, 2020 at 12:19 PM Jark Wu wrote:
> Hi everyone,
>
> It's great seeing many new Flink committers recently, and on behalf of the
> PMC,
> I'd like to announce one more new committer: Godfrey He.
>
> Godfrey is a very long time contributor in the Fli
Congratulations :)
Best,
Guowei
On Wed, Sep 16, 2020 at 11:54 AM Zhijiang
wrote:
> Congratulations and welcome, Igal!
>
>
> --
> From:Yun Gao
> Send Time:2020年9月16日(星期三) 10:59
> To:Stephan Ewen ; dev
> Subject:Re: Re: [ANNOUNCE]
Congratulations :)
Best,
Guowei
On Wed, Sep 16, 2020 at 11:54 AM Zhijiang
wrote:
> Congratulations and welcome, Yun!
>
>
> --
> From:Jark Wu
> Send Time:2020年9月16日(星期三) 11:35
> To:dev
> Cc:tangyun ; Yun Tang
> Subject:Re: [ANNO
Congratulations :)
Best,
Guowei
On Tue, Sep 15, 2020 at 6:14 PM Matthias Pohl
wrote:
> Congrats!
>
> Best,
> Matthias
>
> On Tue, Sep 15, 2020 at 9:26 AM Dawid Wysakowicz
> wrote:
>
> > Welcome, Niels!
> >
> > Best,
> >
> > Dawid
> >
> > On 14/09/2020 11:22, Matt Wang wrote:
> > > Congratulat
Congratulations :)
Best,
Guowei
On Tue, Sep 15, 2020 at 6:41 PM 刘建刚 wrote:
> Congratulations!
>
> Best
>
> Matthias Pohl 于2020年9月15日周二 下午6:07写道：
>
> > Congratulations! ;-)
> >
> > On Tue, Sep 15, 2020 at 11:47 AM Xingbo Huang
> wrote:
> >
> > > Congratulations!
> > >
> > > Best,
> > > Xingbo
Congratulations, well deserved!
Regards,
Dian
> 在 2020年9月16日，下午12:36，Guowei Ma 写道：
>
> Congratulations :)
>
> Best,
> Guowei
>
>
> On Wed, Sep 16, 2020 at 12:19 PM Jark Wu wrote:
>
>> Hi everyone,
>>
>> It's great seeing many new Flink committers recently, and on behalf of the
>> PMC,
>>
Kyle created FLINK-19255:
Summary: Add configuration to make AsyncWaitOperation Chainable
Key: FLINK-19255
URL: https://issues.apache.org/jira/browse/FLINK-19255
Project: Flink
Issue Type: Task
Congratulations!
Best,
Congxian
Guowei Ma 于2020年9月16日周三 下午12:37写道：
> Congratulations :)
>
> Best,
> Guowei
>
>
> On Wed, Sep 16, 2020 at 11:54 AM Zhijiang
> wrote:
>
> > Congratulations and welcome, Yun!
> >
> >
> > --
> > From:Ja
1 - 100 of 113 matches
Mail list logo
