Great news! Thanks Gordon and Kurt!Best,
Haibo
At 2019-08-22 20:03:26, "Tzu-Li (Gordon) Tai" wrote:
>The Apache Flink community is very happy to announce the release of Apache
>Flink 1.9.0, which is the latest major release.
>
>Apache Flink® is an open-source stream processing framework for
>dist
+1 (non-binding)Best,
Haibo
At 2019-10-23 09:07:41, "Becket Qin" wrote:
>+1 (binding)
>
>Thanks,
>
>Jiangjie (Becket) Qin
>
>On Tue, Oct 22, 2019 at 11:44 PM Tzu-Li (Gordon) Tai
>wrote:
>
>> +1 (binding)
>>
>> Gordon
>>
>> On Tue, Oct 22, 2019, 10:58 PM Zhijiang > .invalid>
>> wrote:
>>
>> > +1
Congrats Becket!
Best,
Haibo
在 2019-10-29 09:52:50，"Congxian Qiu" 写道：
>Congratulations Becket!
>
>Best,
>Congxian
>
>
>Wei Zhong 于2019年10月29日周二 上午9:42写道：
>
>> Congratulations Becket!
>>
>> Best,
>> Wei
>>
>> > 在 2019年10月29日，09:36，Paul Lam 写道：
>> >
>> > Congrats Becket!
>> >
>> > Best,
>> > Pau
Hi, guys
I noticed that all of the Travis tests reported a number of failures as
following. Is anyone working on this problem?
__ CatalogTestBase.test_table_exists ___
self =
def test_table_exists(self):
> self.catalog.create_database(self.
Thanks a lot for report this bug. I guess it's caused by this PR:
>>>> https://github.com/apache/flink/pull/8786 <
>>>> https://github.com/apache/flink/pull/8786> @Bowen. I think we'd better
>>>> merge the code ONLY after the travis passed, especi
Congratulations!
Best,
Haibo
At 2019-06-24 23:08:54, "Robert Metzger" wrote:
>Hi all,
>
>On behalf of the Flink PMC, I'm happy to announce that Jincheng Sun is now
>part of the Apache Flink Project Management Committee (PMC).
>
>Jincheng has been a committer since July 2017. He has been very ac
+1. Thank Chesnay for pushing this forward.
Best,
Haibo
At 2019-07-04 17:58:28, "Kurt Young" wrote:
>+1 and great thanks Chesnay for pushing this.
>
>Best,
>Kurt
>
>
>On Thu, Jul 4, 2019 at 5:44 PM Aljoscha Krettek wrote:
>
>> +1
>>
>> Aljoscha
>>
>> > On 4. Jul 2019, at 11:09, Stephan Ewen w
Congrats Rong!Best,
Haibo
At 2019-07-12 09:40:26, "JingsongLee" wrote:
Congratulations Rong.
Rong Rong has done a lot of nice work in the past time to the flink community.
Best, JingsongLee
--
From:Rong Rong
Send Time:2019年7月1
`flink-tests_2.11:jar:tests:1.10-SNAPSHOT` was not deployed because the JIRA
(https://issues.apache.org/jira/browse/FLINK-12602) changed the `artifactId` of
`flink-tests` from `flink-tests_${scala.binary.version}` to `flink-tests`.
I have created a PR (https://github.com/dataArtisans/flink-b
Hi, folks
I noticed that all of the Travis tests reported the following failure. Is
anyone working on this issue?
___ summary
ERROR: py27: InvocationError for command
/home/travis/build/flink-ci/flink/flink-python/dev/.co
Congratulations Becket!Best,
Haibo
在 2019-07-18 17:51:06，"Hequn Cheng" 写道：
>Congratulations Becket!
>
>Best, Hequn
>
>On Thu, Jul 18, 2019 at 5:34 PM vino yang wrote:
>
>> Congratulations!
>>
>> Best,
>> Vino
>>
>> Yun Gao 于2019年7月18日周四 下午5:31写道：
>>
>> > Congratulations!
>> >
>> > Best,
>> > Yun
+1. Sounds good.Letting the PR creators know the build results of the master
branch can help to determine more quickly whether Travis failures of their PR
are an exact failure or because of the instability of test case. By the way, if
the PR creator can abort their own Travis build, I think it c
Congrats, Zhejiang!
Best,
Haibo
在 2019-07-23 10:26:20，"Yun Tang" 写道：
>Congratulations Zhijiang, well deserved.
>
>Best
>
>From: Yingjie Cao
>Sent: Tuesday, July 23, 2019 10:23
>To: dev@flink.apache.org
>Subject: Re: [ANNOUNCE] Zhijiang Wang has been added as a c
Congrats Kurt!
Best,
Haibo
At 2019-07-23 17:24:18, "Robert Metzger" wrote:
>Hi all,
>
>On behalf of the Flink PMC, I'm happy to announce that Kete Young is now
>part of the Apache Flink Project Management Committee (PMC).
>
>Kete has been a committer since February 2017, working a lot on Table A
Congratulations!
Best,
Haibo
At 2019-08-08 02:08:21, "Yun Tang" wrote:
>Congratulations Hequn.
>
>Best
>Yun Tang
>
>From: Rong Rong
>Sent: Thursday, August 8, 2019 0:41
>Cc: dev ; user
>Subject: Re: [ANNOUNCE] Hequn becomes a Flink committer
>
>Congratulations H
Thanks, zhijiang.
For the optimization, such as cost-based estimation, we still want to keep it
in the data set layer,
but your suggestion is also a thought that can be considered.
As I know, currently these batch scenarios have been contained in DataSet, such
as
the sort-merge join algorit
Hi all,
Thank Kurt, you see more benefits of the unification than I do.
I quite agree Kurt's views. DataStream, DataSet and Table are remained
independent for now, and subsumed DataSet in data stream in the future. The
collection execution mode is replaced by mini cluster. The high-level
semantic
7;s special for batch.
>
> There's some interdependencies, i.e. 2 depends on 5. and maybe 1.
>
> Best,
> Aljoscha
>
>> On 7. Dec 2018, at 10:00, Shuai Xu <
> chiggics@
> > wrote:
>>
>> Hi all
>> Glad to see the discussion, we are now de
Hi guys,
Could anyone kindly give me contributor permission? My JIRA username is
sunhaibotb.
Thanks,
Haibo
at
>> > context data is very late.
>> >
>> > Because we do not support side inputs at the moment, we may want to defer
>> > this for now. Let's not over-design for problems that are not well
>> > understood at this point.
>> >
>> > *
Congratulations, Zhu Zhu!
Best,
Haibo
在 2019-12-16 11:16:55，"Yun Tang" 写道：
>Congratulations ZZ
>
>Best
>Yun Tang
>
>From: Guowei Ma
>Sent: Monday, December 16, 2019 11:15
>To: dev
>Subject: Re: [ANNOUNCE] Zhu Zhu becomes a Flink committer
>
>Congrats Zhuzhu!
>Be
Hi, all
I want to bring up a discussion about how to deal with the pending(registered
but not scheduled for execution)
timers better before closing operator.
Introduction: From my understanding, there are two types of timers in Flink: 1)
One is one-shot or periodic
timers registered with Pro
I found that the format of the mail was out of order. Please look at the
document:
https://docs.google.com/document/d/1jCKan5LGlkBZr2seUdwTsy-biu8Sz0xyQwqizCUZ2uk/edit?usp=sharing
Best,
Haibo
At 2019-12-16 21:29:15, "Haibo Sun" wrote:
>Hi, all
>
>
>I want to bring up
+1 (non-binding)
Best,
Haibo
At 2020-01-13 11:36:12, "Yun Gao" wrote:
>+1 (non-binding).
>
>Very thanks for introducing this topic back, and it should be able to bring
>improvements in the discussed scenarios.
>
>Best,
>Yun
>
>
>
Thanks Gary & Yu. Great work!
Best,
Haibo
At 2020-02-12 21:31:00, "Yu Li" wrote:
>The Apache Flink community is very happy to announce the release of Apache
>Flink 1.10.0, which is the latest major release.
>
>Apache Flink® is an open-source stream processing framework for
>distributed, high-p
Congratulations Dian !
Best,
Haibo
At 2020-08-27 18:03:38, "Zhijiang" wrote:
>Congrats, Dian!
>
>
>--
>From:Yun Gao
>Send Time:2020年8月27日(星期四) 17:44
>To:dev ; Dian Fu ; user
>; user-zh
>Subject:Re: Re: [ANNOUNCE] New PMC member
Congratulations!
Best,
Haibo
在 2020-09-18 01:46:59，"Piotr Nowojski" 写道：
>Congratulations :)
>
>czw., 17 wrz 2020 o 15:20 godfrey he napisał(a):
>
>> Congratulations!
>>
>> Regards,
>> Godfrey
>>
>> Yun Tang 于2020年9月17日周四 下午2:22写道：
>>
>> > Thanks for all your kind welcome and very glad to be
Congratulations Yu!
Best,
Haibo
At 2020-06-17 09:15:02, "jincheng sun" wrote:
>Hi all,
>
>On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
>part of the Apache Flink Project Management Committee (PMC).
>
>Yu Li has been very active on Flink's Statebackend component, working
Haibo Sun created FLINK-14228:
-
Summary: The runtime support for Bounded[One|Multi]Input#endInput
does not properly implement their semantics
Key: FLINK-14228
URL: https://issues.apache.org/jira/browse/FLINK-14228
Haibo Sun created FLINK-14229:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14229
URL: https://issues.apache.org/jira/browse/FLINK-14229
Haibo Sun created FLINK-14230:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14230
URL: https://issues.apache.org/jira/browse/FLINK-14230
Haibo Sun created FLINK-14231:
-
Summary: Support the timers of the upstream operator with endInput
properly
Key: FLINK-14231
URL: https://issues.apache.org/jira/browse/FLINK-14231
Project: Flink
Haibo Sun created FLINK-14239:
-
Summary: Emitting the max watermark in StreamSource#run may cause
it to arrive the downstream early
Key: FLINK-14239
URL: https://issues.apache.org/jira/browse/FLINK-14239
Haibo Sun created FLINK-12291:
-
Summary: Add benchmarks for the input processors
Key: FLINK-12291
URL: https://issues.apache.org/jira/browse/FLINK-12291
Project: Flink
Issue Type: Task
Haibo Sun created FLINK-12292:
-
Summary: Add benchmarks for the input processors
Key: FLINK-12292
URL: https://issues.apache.org/jira/browse/FLINK-12292
Project: Flink
Issue Type: Sub-task
Haibo Sun created FLINK-12529:
-
Summary: Release buffers of the record deserializer timely to
improve the efficiency of heap memory usage on taskmanager
Key: FLINK-12529
URL: https://issues.apache.org/jira/browse
Haibo Sun created FLINK-12547:
-
Summary: Deadlock when the task thread downloads jars using
BlobClient
Key: FLINK-12547
URL: https://issues.apache.org/jira/browse/FLINK-12547
Project: Flink
Haibo Sun created FLINK-12895:
-
Summary:
TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure
failed on travis
Key: FLINK-12895
URL: https://issues.apache.org/jira/browse/FLINK-12895
Haibo Sun created FLINK-12967:
-
Summary: Change the input selection switching in
StreamTwoInputSelectableProcessor#checkFinished to invoking the nextSelection
method of the stream operator
Key: FLINK-12967
URL
Haibo Sun created FLINK-13014:
-
Summary: ChainBreakTest failed on Travis
Key: FLINK-13014
URL: https://issues.apache.org/jira/browse/FLINK-13014
Project: Flink
Issue Type: Bug
Haibo Sun created FLINK-13051:
-
Summary: Drop the non-selectable two-input StreamTask and Processor
Key: FLINK-13051
URL: https://issues.apache.org/jira/browse/FLINK-13051
Project: Flink
Issue
Haibo Sun created FLINK-13299:
-
Summary: flink-python failed on Travis
Key: FLINK-13299
URL: https://issues.apache.org/jira/browse/FLINK-13299
Project: Flink
Issue Type: Bug
Reporter
Haibo Sun created FLINK-11875:
-
Summary: Enhance stream operator API to support selective reading
and EndOfInput event
Key: FLINK-11875
URL: https://issues.apache.org/jira/browse/FLINK-11875
Project
Haibo Sun created FLINK-11876:
-
Summary: Introduce the new interfaces TwoInputSelectable,
BoundedOneInput and BoundedTwoInput
Key: FLINK-11876
URL: https://issues.apache.org/jira/browse/FLINK-11876
Haibo Sun created FLINK-11879:
-
Summary: Add JobGraph validators for the uses of
TwoInputSelectable, BoundedOneInput and BoundedTwoInput
Key: FLINK-11879
URL: https://issues.apache.org/jira/browse/FLINK-11879
Haibo Sun created FLINK-11880:
-
Summary: Add JobGraph validators for the uses of
TwoInputSelectable, BoundedOneInput and BoundedTwoInput
Key: FLINK-11880
URL: https://issues.apache.org/jira/browse/FLINK-11880
Haibo Sun created FLINK-11877:
-
Summary: Implement the runtime handling of TwoInputSelectable
Key: FLINK-11877
URL: https://issues.apache.org/jira/browse/FLINK-11877
Project: Flink
Issue Type
Haibo Sun created FLINK-11878:
-
Summary: Implement the runtime handling of BoundedOneInput and
BoundedTwoInput
Key: FLINK-11878
URL: https://issues.apache.org/jira/browse/FLINK-11878
Project: Flink
Haibo Sun created FLINK-16174:
-
Summary: Add a better tryYield() method to MailboxExecutor to
return the lowest priority of the remaining mails
Key: FLINK-16174
URL: https://issues.apache.org/jira/browse/FLINK-16174
49 matches
Mail list logo
