Hey all,
I am using the KeyedCoProcessFunction class in Flink DataStream APIs to
implement a timeout like use case. The scenario is as follows: I have an
input kafka topic and an output Kafka topic, a service reads from the input
topic processes it (for variable amount of time) and then publishes
Congratulations Igal and welcome!
Kostas
On Wed, Sep 16, 2020 at 6:37 AM Guowei Ma wrote:
>
> Congratulations :)
> Best,
> Guowei
>
>
> On Wed, Sep 16, 2020 at 11:54 AM Zhijiang
> wrote:
>
> > Congratulations and welcome, Igal!
> >
> >
> > ---
liufangliang created FLINK-19257:
Summary: HBase ConnectorDescriptor can not work in Table API of
release-1.11
Key: FLINK-19257
URL: https://issues.apache.org/jira/browse/FLINK-19257
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-19256:
---
Summary: Validate Stateful Functions configuration only where
necessary
Key: FLINK-19256
URL: https://issues.apache.org/jira/browse/FLINK-19256
Project:
Congrats, Arvid! ☺
On Wed, Sep 16, 2020 at 12:37 PM Guowei Ma wrote:
> 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
Congrats!
Best,
PengchengLiu
在 2020/9/16 下午2:23，“Benchao Li” 写入:
Congratulations!
Zhu Zhu 于2020年9月16日周三 下午1:36写道：
> Congratulations!
>
> Thanks,
> Zhu
>
> Leonard Xu 于2020年9月16日周三 下午1:32写道：
>
> > Congratulations! Godfrey
> >
> > Best,
> >
Congratulations!
Zhu Zhu 于2020年9月16日周三 下午1:36写道：
> Congratulations!
>
> Thanks,
> Zhu
>
> Leonard Xu 于2020年9月16日周三 下午1:32写道：
>
> > Congratulations! Godfrey
> >
> > Best,
> > Leonard
> >
> > > 在 2020年9月16日，13:12，Yangze Guo 写道：
> > >
> > > Congratulations! Xiaoling.
> > >
> > > Best,
> > > Yangz
Sorry for jump late in.
I like the separation here, this separation makes more user friendly now.
I just wonder how the configuration such as 'state.backend.incremental',
'state.backend.async' and
`state.backend.rocksdb.checkpoint.transfer.thred.num` will be configured
after the separation, I thi
Congratulations!
Thanks,
Zhu
Leonard Xu 于2020年9月16日周三 下午1:32写道：
> Congratulations! Godfrey
>
> Best,
> Leonard
>
> > 在 2020年9月16日，13:12，Yangze Guo 写道：
> >
> > Congratulations! Xiaoling.
> >
> > Best,
> > Yangze Guo
> >
> > On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote:
> >>
> >> Congratulati
+1 (binding)
Nice work! :-)
Aljoscha
On 16.09.20 06:00, Xuannan Su wrote:
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,
Congratulations! Godfrey
Best,
Leonard
> 在 2020年9月16日，13:12，Yangze Guo 写道：
>
> Congratulations! Xiaoling.
>
> Best,
> Yangze Guo
>
> On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote:
>>
>> Congratulations, well deserved!
>>
>> Regards,
>> Dian
>>
>>> 在 2020年9月16日，下午12:36，Guowei Ma 写道：
>>>
Congratulations! Xiaoling.
Best,
Yangze Guo
On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote:
>
> 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
Congratulations :)
Best,
Jingsong
On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote:
> 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:
> >
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
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, 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,
>>
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 :)
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 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 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
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
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, 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 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
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
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
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 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
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 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:
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
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!
>>
>>
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
> 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
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
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
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 ,
+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
> >
>
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写道：
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!
>
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
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
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年
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
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
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
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,
>
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
> 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:
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
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
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
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
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
> > >
> > >
>
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
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, 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!
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!
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:
> >
> >
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
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
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
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
Congratulations, Yun!
Best,
Yang
Leonard Xu 于2020年9月15日周二 下午7:11写道：
> Congrats, Yun!
>
> Best,
> Leonard
> > 在 2020年9月15日，19:01，Yangze Guo 写道：
> >
> > Congrats, Yun!
>
>
Congrats, Yun!
Best,
Leonard
> 在 2020年9月15日，19:01，Yangze Guo 写道：
>
> Congrats, Yun!
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
> >
> >
> > --
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
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 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!
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 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!
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
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
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
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
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
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 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!
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 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
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
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
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!
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
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
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
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
+1 (binding)
On Tue, Sep 15, 2020 at 3:26 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Aljoscha
>
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
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, 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
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
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
1 - 100 of 113 matches
Mail list logo
