Congratulations, Xintong!
Best,
Yun
--
Sender:Jingsong Li
Date:2021/06/17 10:41:22
Recipient:dev
Theme:Re: [ANNOUNCE] New PMC member: Xintong Song
Congratulations, Xintong!
Best,
Jingsong
On Thu, Jun 17, 2021 at 10:26 AM Yun
Congratulations, Arvid!
Best,
Yun
--
Sender:Jingsong Li
Date:2021/06/17 10:41:29
Recipient:dev
Theme:Re: [ANNOUNCE] New PMC member: Arvid Heise
Congratulations, Arvid!
Best,
Jingsong
On Thu, Jun 17, 2021 at 6:52 AM Matthias J.
Hi,
Very thanks @Yangze for bringing up this discuss. Overall +1 for
exposing the fine-grained resource requirements in the DataStream API.
One similar issue as Arvid has pointed out is that users may also creating
different SlotSharingGroup objects, with different names but with different
makes sense to add `flush`, as most of them
> >>> > shouldn't buffer any data. Apart from Sinks, it's usually an operator
> >>> that
> >>> > is buffering the data (that holds true for AsyncFunction,
> >>> ReduceFunction,
> >>
Yun Gao created FLINK-22929:
---
Summary: Change the default failover strategy to
FixDelayRestartStrategy
Key: FLINK-22929
URL: https://issues.apache.org/jira/browse/FLINK-22929
Project: Flink
Issue
Yun Gao created FLINK-22928:
---
Summary: Unexpected exception happens in RecordWriter when
stopping-with-savepoint
Key: FLINK-22928
URL: https://issues.apache.org/jira/browse/FLINK-22928
Project: Flink
; his colleagues at Kuaishou maintain an internal version of Flink.
One of their custom features is allowing dynamically changing operator
behaviors via the REST APIs. He's willing to contribute this feature to the
community, and came to Yun Gao and me for suggestions. After discussion, we
feel
input.
Very thanks for all the deep insights and discussions!
Best,
Yun
--
From:Dawid Wysakowicz
Send Time:2021 Jun. 3 (Thu.) 21:21
To:dev ; Till Rohrmann ; Yun Gao
Cc:Piotr Nowojski ; Guowei Ma ;
Stephan Ewen
Subject:Re: [D
Hi,
Logically using zk HA on k8s cluster is supported.
Attaching files is not support by apache mail server, could
you update the files into some file server and paste the
connections ?
Best,
Yun
--
Sender:bhagi@R
Congratulations Rui!
Best,
Yun
--
Sender:Nicholas Jiang
Date:2021/04/22 11:26:05
Recipient:
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Rui Li
Congrats, Rui!
Best,
Nicholas Jiang
--
Sent from:
Yun Gao created FLINK-22301:
---
Summary: Statebackend and CheckpointStorage type is not shown in
the Web UI
Key: FLINK-22301
URL: https://issues.apache.org/jira/browse/FLINK-22301
Project: Flink
Yun Gao created FLINK-22117:
---
Summary: Not print stack trace for checkpoint trigger failure if
not all tasks are started.
Key: FLINK-22117
URL: https://issues.apache.org/jira/browse/FLINK-22117
Project
Hi Lu,
The image seems not be able to shown due to the mail server limitation, could
you upload it somewhere and paste the link here ?
Logically, I think zigzag usually due to there are some small object get
created and eliminated soon in the heap. Are you running a SQL job or a
DataStream
Yun Gao created FLINK-22088:
---
Summary: CheckpointCoordinator might not be able to abort
triggering checkpoint if failover happens during triggering
Key: FLINK-22088
URL: https://issues.apache.org/jira/browse/FLINK
Yun Gao created FLINK-22087:
---
Summary: CheckpointPlanCalculator should abort checkpoint if tasks
is in canceling/canceled and so on
Key: FLINK-22087
URL: https://issues.apache.org/jira/browse/FLINK-22087
Yun Gao created FLINK-21967:
---
Summary: Add document on the operation of blocking result partition
Key: FLINK-21967
URL: https://issues.apache.org/jira/browse/FLINK-21967
Project: Flink
Issue Type
Yun Gao created FLINK-21952:
---
Summary: Make all the "Connection reset by peer" exception wrapped
as RemoteTransportException
Key: FLINK-21952
URL: https://issues.apache.org/jira/browse/FLINK-21952
totally agree with that the
two are separate and we could think on them
distinctly. Regarding the order, I would still tend to we support the ordered
case, since the sinks' implementation seem to depend
on this functionality.
Best,
Yun
------
i
Send Time:2021 Mar. 4 (Thu.) 17:16
To:Kezhu Wang
Cc:dev ; Yun Gao ;
jingsongl...@gmail.com ; Guowei Ma
; Till Rohrmann
Subject:Re: Re: Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
Hi Kezhu,
What do you mean by “end-flushing”? I was suggesting to just keep
`endOfInput()
the
job finish again, it would re-emit the MAX_WATERMARK?
Best,
Yun
--
From:Kezhu Wang
Send Time:2021 Mar. 1 (Mon.) 01:26
To:Till Rohrmann
Cc:Piotr Nowojski ; Guowei Ma ;
dev ; Yun Gao ;
jingsongl...@gmail.com
Subject:
From:Kezhu Wang
Send Time:2021 Mar. 1 (Mon.) 01:26
To:Till Rohrmann
Cc:Piotr Nowojski ; Guowei Ma ;
dev ; Yun Gao ;
jingsongl...@gmail.com
Subject:Re: Re: Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
In “stop-with-savepoint —drain”, MAX_WATERMARK is not an issue.
hu Wang
On February 24, 2021 at 23:47:36, Piotr Nowojski (piotr.nowoj...@gmail.com)
wrote:
Thanks for the reponses Guowei and Yun,
Could you elaborate more/remind me, what does it mean to replace emitting
results from the `notifyCheckpointComplete` with `OperatorCoordinator`
approach
`OperatorCoordinator` to avoid sending the element to the downstream
> > operator.
> > But I agree we could not limit the users not to emit records in the
> > `notiyCheckpointComplete`.
> >
> > Best,
> > Guowei
> >
> >
> > On Tue
Congratulations Wei and Xingbo!
Best,
Yun
--Original Mail --
Sender:Roman Khachatryan
Send Date:Tue Feb 23 00:59:22 2021
Recipients:dev
Subject:Re: [ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang
Congratulations!
Regards,
Roman
On Mon,
sh`, operators would be forbidden from emitting more records, so that
> we can replace step 4. with this `flush` call, and then having a single
> checkpoint to finish 2pc for all of the operators inside the chain, doesn't
> work. Sheer fact of adding this `flush` method and changing the con
Congratulations Roman!
Best,
Yun
--Original Mail --
Sender:Till Rohrmann
Send Date:Wed Feb 10 20:53:21 2021
Recipients:dev
CC:Khachatryan Roman , Roman Khachatryan
Subject:Re: [ANNOUNCE] Welcome Roman Khachatryan a new Apache Flink Committer
Congratulations
Yun Gao created FLINK-21246:
---
Summary: Decline Checkpoint if some tasks finished before get
triggered
Key: FLINK-21246
URL: https://issues.apache.org/jira/browse/FLINK-21246
Project: Flink
Issue
Yun Gao created FLINK-21127:
---
Summary: Stores finished status for fully finished operators
Key: FLINK-21127
URL: https://issues.apache.org/jira/browse/FLINK-21127
Project: Flink
Issue Type: Sub
Yun Gao created FLINK-21088:
---
Summary: CheckpointCoordinator pass the flag about whether a
operator is fully finished on recovery
Key: FLINK-21088
URL: https://issues.apache.org/jira/browse/FLINK-21088
Yun Gao created FLINK-21087:
---
Summary: StreamTask waits for all the asynchronous step of pending
checkpoint to finish
Key: FLINK-21087
URL: https://issues.apache.org/jira/browse/FLINK-21087
Project: Flink
Yun Gao created FLINK-21086:
---
Summary: CheckpointBarrierHandler Insert barriers into channels
received EndOfPartition
Key: FLINK-21086
URL: https://issues.apache.org/jira/browse/FLINK-21086
Project: Flink
Yun Gao created FLINK-21085:
---
Summary: Refactor StreamTask hierarchy to support triggering
checkpoint via RPC for non-source tasks
Key: FLINK-21085
URL: https://issues.apache.org/jira/browse/FLINK-21085
Yun Gao created FLINK-21084:
---
Summary: Allows tasks to report operator subtask finish state
Key: FLINK-21084
URL: https://issues.apache.org/jira/browse/FLINK-21084
Project: Flink
Issue Type: Sub
Yun Gao created FLINK-21081:
---
Summary: Re-compute tasks to trigger when tasks get triggered
before finished
Key: FLINK-21081
URL: https://issues.apache.org/jira/browse/FLINK-21081
Project: Flink
Yun Gao created FLINK-21080:
---
Summary: Identify JobVertex containing legacy source operators and
abort checkpoint with legacy source operators partially finished
Key: FLINK-21080
URL: https://issues.apache.org/jira
Yun Gao created FLINK-21067:
---
Summary: Modify the logic of computing tasks to
trigger/wait/commit to consider finished tasks
Key: FLINK-21067
URL: https://issues.apache.org/jira/browse/FLINK-21067
Project
Yun Gao created FLINK-21066:
---
Summary: Refactor the CheckpointCoordinator to compute the tasks
to trigger/wait/commit dynamically
Key: FLINK-21066
URL: https://issues.apache.org/jira/browse/FLINK-21066
(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 sup
Congratulations Guowei!
Best,
Yun--
Sender:Yangze Guo
Date:2021/01/20 13:48:52
Recipient:dev
Theme:Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer
Congratulations, Guowei! Well deserved.
Best,
Yangze Guo
On Wed,
Hi,
Very thanks for @Timo to initiate the discussion!
I would also +1 for providing some informations to users via annotations
or documents in advanced to not suprise users before we actually remove the
legacy code.
If we finally decide to change one functionality that user could sense,
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
voting process.
thanks,
Yun
[1]
: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
Thanks for the summary! I think we can now move towards a [VOTE] thread,
right?
On 2021/01/15 13:43, Yun Gao wrote:
>1) For the problem that the "new" root task coincidently finished
>before getting triggered succe
Hi all,
We have some offline discussion together with @Arvid, @Roman and @Aljoscha and
I'd
like to post some points we discussed:
1) For the problem that the "new" root task coincidently finished before
getting triggered
successfully, we have listed two options in the FLIP-147[1], for the
Hi all,
I updated the FLIP[1] to reflect the major discussed points in the ML thread:
1) For the "new" root tasks finished before it received trigger message,
previously we proposed
to let JM re-compute and re-trigger the descendant tasks, but after the
discussion we realized that
it might
Congratulations, Danny!
Best,
Yun
--
From:Xintong Song
Send Time:2021 Jan. 13 (Wed.) 15:29
To:dev
Subject:Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer
Congratulations, Danny.
Welcome aboard.
Thank you~
Hi Roman,
Very thanks for the feedbacks and suggestions!
> I think UC will be the common case with multiple sources each with
DoP > 1.
> IIUC, waiting for EoP will be needed on each subtask each time one of
it's source subtask finishes.
Yes, waiting for
Hi Roman,
Very thanks for the feedbacks !
> Probably it would be simpler to just decline the RPC-triggered
checkpoint
> if not all inputs of this task are finished (with
CHECKPOINT_DECLINED_TASK_NOT_READY).
> But I wonder how significantly this waiting
Hi Roman,
Very thanks for the feedbacks! I'll try to answer the issues inline:
> 1. Option 1 is said to be not preferable because it wastes resources and adds
> complexity (new event).
> However, the resources would be wasted for a relatively short time until the
> job finishes completely.
Yun Gao created FLINK-20888:
---
Summary: ContinuousFileReaderOperator should not close the output
on close()
Key: FLINK-20888
URL: https://issues.apache.org/jira/browse/FLINK-20888
Project: Flink
.
Best,
Yun
--Original Mail --
Sender:Arvid Heise
Send Date:Thu Jan 7 00:52:27 2021
Recipients:Aljoscha Krettek
CC:dev , Yun Gao
Subject:Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
Okay then at least you guys are in sync ;) (Although I'
Hi Arvid,
Very thanks for the feedbacks! I'll try to answer the questions inline:
> I'm also concerned about the notion of a final checkpoint. What happens
> when this final checkpoint times out (checkpoint timeout > async timeout)
> or fails for a different reason? I'm currently more inclined
xamples if you go beyond chained operators and
fully connected exchanges. Think of any fan-in, let's assume you have
source S1...S4, with S1+S2->M1, and S3+S4->M2. If S1 is finished, S2 and M1
is still running. Or I didn't get your question ;).
On Tue, Jan 5, 2021 at 5:00 PM Yun G
Hi Aljoscha,
Very thanks for the feedbacks!
For the second issue, I'm indeed thinking the race condition between
deciding to trigger and operator get finished. And for this point,
> One thought here is this: will there ever be intermediate operators that
> should be
rained on OperatorSubtaskState. Maybe we
can store the flag inside managed or raw state without changing the format?
On Fri, Dec 25, 2020 at 8:39 AM Yun Gao wrote:
Hi all,
I tested the previous PoC with the current tests and I found some new
issues that might cause divergence, and
he thorough update! I'll answer inline.
On 14.12.20 16:33, Yun Gao wrote:
> 1. To include EndOfPartition into consideration for barrier alignment at
> the TM side, we now tend to decouple the logic for EndOfPartition with the
> normal alignment behaviors to avoid the complex interference (whic
d Time:2020 Dec. 15 (Tue.) 18:11
To:dev
Subject:Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
Thanks for the thorough update! I'll answer inline.
On 14.12.20 16:33, Yun Gao wrote:
> 1. To include EndOfPartition into consideration for barrier alignment at
> t
Hi all,
I would like to resume this discussion for supporting checkpoints after
tasks Finished :) Based on the previous discussion, we now implement a version
of PoC [1] to try the idea. During the PoC we also met with some possible
issues:
1. To include EndOfPartition into
Yun Gao created FLINK-20315:
---
Summary: Optimize the compaction section for the document of table
filesystem sink.
Key: FLINK-20315
URL: https://issues.apache.org/jira/browse/FLINK-20315
Project: Flink
Yun Gao created FLINK-20295:
---
Summary: File Source lost data when reading from directories
created by FileSystemTableSink with JSON format
Key: FLINK-20295
URL: https://issues.apache.org/jira/browse/FLINK-20295
Yun Gao created FLINK-20292:
---
Summary: Avro format conflicts with Parquet and Orc
Key: FLINK-20292
URL: https://issues.apache.org/jira/browse/FLINK-20292
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-20291:
---
Summary: Optimize the exception message of FileSystemTableSink
when missing format dependencies
Key: FLINK-20291
URL: https://issues.apache.org/jira/browse/FLINK-20291
Project
Yun Gao created FLINK-20180:
---
Summary: Translation the FileSink Document into Chinese
Key: FLINK-20180
URL: https://issues.apache.org/jira/browse/FLINK-20180
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-20172:
---
Summary: Unify the behavior for file committers when the source or
dest files are not exists
Key: FLINK-20172
URL: https://issues.apache.org/jira/browse/FLINK-20172
Project
Yun Gao created FLINK-20032:
---
Summary: Make FileSink support processing time
Key: FLINK-20032
URL: https://issues.apache.org/jira/browse/FLINK-20032
Project: Flink
Issue Type: Sub-task
Congratulations Congxian !
Best,
Yun
--
Sender:Leonard Xu
Date:2020/10/29 21:19:56
Recipient:dev
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu
Congratulations! Congxian
Best,
Leonard
> 在 2020年10月29日，20:55，Stephan
Yun Gao created FLINK-19850:
---
Summary: Add E2E tests for the new streaming case of the new
FileSink
Key: FLINK-19850
URL: https://issues.apache.org/jira/browse/FLINK-19850
Project: Flink
Issue
Yun Gao created FLINK-19758:
---
Summary: Implement a new unified File Sink based on the new Sink
API
Key: FLINK-19758
URL: https://issues.apache.org/jira/browse/FLINK-19758
Project: Flink
Issue
Yun Gao created FLINK-19701:
---
Summary: Unaligned Checkpoint might misuse the number of buffers
to persist from the previous barrier
Key: FLINK-19701
URL: https://issues.apache.org/jira/browse/FLINK-19701
Yun Gao created FLINK-19653:
---
Summary: HiveCatalogITCase fails on azure
Key: FLINK-19653
URL: https://issues.apache.org/jira/browse/FLINK-19653
Project: Flink
Issue Type: Improvement
nd Time:2020 Oct. 13 (Tue.) 17:25
To:Yun Gao
Cc:Arvid Heise ; Flink Dev ;
User-Flink
Subject:Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished
Thanks for starting this discussion Yun Gao,
I have three comments/questions:
1) When restarting all tasks independent of the status at ch
ore the problem on how to store and restore output buffers of a completed
task (also important for the next point).
5) I think we are on the same page and I completely agree that for the
MVP/first version, it's completely fine to start and immediately stop. A tad
better would be even to
first time that we
recover an incomplete DAG. Afaik the subtasks are deployed before the state is
recovered, so at some point, the subtasks either need to be removed again or
maybe we could even avoid them being created in the first place.
[1] https://issues.apache.org/jira/browse/FLINK-
Hi, devs & users
Very sorry for the spoiled formats, I resent the discussion as follows.
As discussed in FLIP-131[1], Flink will make DataStream the unified API for
processing bounded and unbounded data in both streaming and blocking modes.
However, one long-standing problem for the streaming
Hi, devs & users
As discussed in FLIP-131 [1], Flink will make DataStream the unified API for
processing bounded and unbounded data in both streaming and blocking modes.
However, one long-standing problem for the streaming mode is that currently
Flink does not support checkpoints after some
Congratulations Zhu!
Best,
Yun--
Sender:Arvid Heise
Date:2020/10/05 15:53:01
Recipient:dev
Cc:
Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
Congratulations Zhu Zhu!
On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann wrote:
> Congrats
Congratulations Godfrey!
Best,
Yun
--Original Mail --
Sender:Dawid Wysakowicz
Send Date:Thu Sep 17 14:45:55 2020
Recipients:Flink Dev , 贺小令
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He
Congratulations!
On 16/09/2020 06:19, Jark Wu wrote:
>
Great! Very thanks @ZhuZhu for driving this and thanks for all contributed to
the release!
Best,
Yun
--Original Mail --
Sender:Jingsong Li
Send Date:Thu Sep 17 13:31:41 2020
Recipients:user-zh
CC:dev , user , Apache Announce
List
Subject:Re: [ANNOUNCE]
+1 (non-binding)
Very thanks for bring this up! And the FLIP is indeed necessary for stream &
batch unification.
--
Sender:Dawid Wysakowicz
Date:2020/09/16 15:01:08
Recipient:; Aljoscha Krettek
Theme:Re: [VOTE] FLIP-134: Batch
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 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写
Very thanks for bring this up!
+1 (non-binding)
Best,
Yun
--
Sender:Seth Wiesman
Date:2020/09/14 21:56:55
Recipient:dev
Theme:Re: [VOTE] FLIP-140: Introduce bounded style execution for keyed streams
+1 (binding)
Seth
On Thu,
Congratulations Niels!
Best,
Yun
--
Sender:Congxian Qiu
Date:2020/09/15 13:33:31
Recipient:dev@flink.apache.org
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Niels Basjes
Congratulations
Best,
Congxian
Yang Wang
Congratulations Arvid !
Best,
Yun
--Original Mail --
Sender:Yangze Guo
Send Date:Tue Sep 15 13:39:56 2020
Recipients:dev
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise
Congrats! Arvid.
Best,
Yangze Guo
On Tue, Sep 15, 2020 at 1:31 PM
Very thanks for bring this up! +1 for deprecating the DataSet API and
providing a unified streaming/batch programming model to users.
Best,
Yun
--
Sender:Aljoscha Krettek
Date:2020/09/02 19:22:51
Recipient:Flink Dev
Congratulations Dian !
Best
Yun
--
Sender:Marta Paes Moreira
Date:2020/08/27 17:42:34
Recipient:Yuan Mei
Cc:Xingbo Huang; jincheng sun;
dev; Dian Fu;
user; user-zh
Theme:Re: [ANNOUNCE] New PMC member: Dian Fu
Congrats, Dian!
Hi Prasanna,
1) Semantically both a) and b) would be Ok. If the Custom sink could be
chained with the map operator (I assume the map operator is the "Processing" in
the graph), there should be also no much difference physically, if they could
not chain, then writting a custom sink would
Hi,
Very thanks for bringing up this discussion!
One more question is that does the BATCH and STREAMING mode also decides
the shuffle types and operators? I'm asking so because that even for blocking
mode, it should also benefit from keeping some edges to be pipeline if the
resources
+1 for removing the methods that are deprecated for a while & have alternative
methods.
One specific thing is that if we remove the DataStream#split, do we consider
enabling side-output in more operators in the future ? Currently it should be
only available in ProcessFunctions, but not
Congratulations Piotr !
Best,
Yun
--
Sender:Austin Bennett
Date:2020/07/07 10:06:15
Recipient:
Theme:Re: [ANNOUNCE] New PMC member: Piotr Nowojski
Thanks for what you do, Piotr!
On Mon, Jul 6, 2020, 7:02 PM Matt Wang wrote:
>
Hi Dhurandar,
With my understand I think what you need is to get notified when a file is
written successfully (committed) on the S3 FileSystem. However, currently there
is no public API for the listener and there an issue tracking it [1].
With the current version, one possible method
Congratulations Yu!
Best,
Yun
--
Sender:Zhijiang
Date:2020/06/17 11:18:35
Recipient:Dian Fu; dev
Cc:Haibo Sun; user;
user-zh
Theme:Re: [ANNOUNCE] Yu Li is now part of the Flink PMC
Congratulations Yu! Well deserved!
Best,
+1 for have a editorconfig file that is more consistent with Flink's code
sytle.
From my own experience, whenever I open the Flink repo for the first time, I
have to manually change the continuation indent to 4 and disable the wildcard
imports. I also think that it should be more nice to new
Yun Gao created FLINK-18269:
---
Summary: ContinuousFileReaderOperator also supports monitoring
subdirectories
Key: FLINK-18269
URL: https://issues.apache.org/jira/browse/FLINK-18269
Project: Flink
Congratulations, Benchao!
Best,
Yun
--
Sender:Danny Chan
Date:2020/06/10 20:01:01
Recipient:
Theme:Re: [ANNOUNCE] New Flink Committer: Benchao Li
Congrats Benchao!
Best,
Danny Chan
在 2020年6月10日 +0800
Congratulates Xintong !
Best
Yun
--
Sender:Leonard Xu
Date:2020/06/05 12:51:20
Recipient:dev
Cc:Xintong Song
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song
Congratulates Xintong !
Best,
Leonard Xu
> 在
Yun Gao created FLINK-18110:
---
Summary: Bucket Listener in StreamingFileSink should notify for
buckets detected to be inactive at recovery
Key: FLINK-18110
URL: https://issues.apache.org/jira/browse/FLINK-18110
Yun Gao created FLINK-18089:
---
Summary: Add the zero-copy test into the azure E2E pipeline
Key: FLINK-18089
URL: https://issues.apache.org/jira/browse/FLINK-18089
Project: Flink
Issue Type: Test
Yun Gao created FLINK-18056:
---
Summary: Hive file sink throws exception when the target
in-progress file exists.
Key: FLINK-18056
URL: https://issues.apache.org/jira/browse/FLINK-18056
Project: Flink
Yun Gao created FLINK-17872:
---
Summary: Update StreamingFileSink documents to add avro formats
Key: FLINK-17872
URL: https://issues.apache.org/jira/browse/FLINK-17872
Project: Flink
Issue Type
Yun Gao created FLINK-17711:
---
Summary: Support hadoop OutputCommitter based file committer
Key: FLINK-17711
URL: https://issues.apache.org/jira/browse/FLINK-17711
Project: Flink
Issue Type: Sub
401 - 500 of 559 matches
Mail list logo
