Kezhu Wang created FLINK-22108:
--
Summary: Ephemeral socket address was checkpointed to state and
restored back in CollectSinkOperatorCoordinator
Key: FLINK-22108
URL: https://issues.apache.org/jira/browse/FLINK
Kezhu Wang created FLINK-21821:
--
Summary: StreamTask.cancelables was closed concurrent between task
canceler and task thread
Key: FLINK-21821
URL: https://issues.apache.org/jira/browse/FLINK-21821
Kezhu Wang created FLINK-21817:
--
Summary: FLIP-27 Source might break subtask and split assignment
upon rescale
Key: FLINK-21817
URL: https://issues.apache.org/jira/browse/FLINK-21817
Project: Flink
Kezhu Wang created FLINK-21806:
--
Summary: ContinuousEventTimeTrigger should register its first
timer base on current watermark
Key: FLINK-21806
URL: https://issues.apache.org/jira/browse/FLINK-21806
Kezhu Wang created FLINK-21753:
--
Summary: Cycle references between memory manager and gc cleaner
action
Key: FLINK-21753
URL: https://issues.apache.org/jira/browse/FLINK-21753
Project: Flink
Kezhu Wang created FLINK-21635:
--
Summary: Driver name is optional for DriverManager.getConnection
but a must in JdbcConnectionOptions
Key: FLINK-21635
URL: https://issues.apache.org/jira/browse/FLINK-21635
Kezhu Wang created FLINK-21626:
--
Summary: Consider shaping newly introduced RuntimeContext.getJobId
to return JobID with no Optional wrapper
Key: FLINK-21626
URL: https://issues.apache.org/jira/browse/FLINK-21626
les` is not part of checkpoint.
Checkpoint will complete and persist as before. The changed parts are after
checkpoint considered completed.
Best,
Kezhu Wang
On March 4, 2021 at 17:15:53, Piotr Nowojski (pnowoj...@apache.org) wrote:
Hi Kezhu,
What do you mean by “end-flushing”? I was suggest
coordinator should
be easy.
It will definitely complicate currently complex checkpoint coordinator as
@Till mentioned in FLINK-21133.
Best,
Kezhu Wang
On March 3, 2021 at 01:09:50, Piotr Nowojski (pnowoj...@apache.org) wrote:
Hi,
Thanks for reminding me. I think FLIP-147 will have to deal
Kezhu Wang created FLINK-21578:
--
Summary: Closeable Sink Committer/GlobalCommitter were created to
function in onestep during job graph composition
Key: FLINK-21578
URL: https://issues.apache.org/jira/browse/FLINK
Kezhu Wang created FLINK-21564:
--
Summary: CommonTestUtils.waitUntilCondition could fail with
condition meets before
Key: FLINK-21564
URL: https://issues.apache.org/jira/browse/FLINK-21564
Project: Flink
/flink/commit/1aaa80fb0afad13a314b06783c61c01b9414f91b#diff-d4568b34060bc589cd1354bd125c35aca993dd0c9fe9e4460dfed73501116459R177
Best,
Kezhu Wang
On February 28, 2021 at 21:23:31, Till Rohrmann (trohrm...@apache.org)
wrote:
I think you are right with the problem of endOfInput. endOfInput
Kezhu Wang created FLINK-21522:
--
Summary: Iterative stream could not work with stop-with-savepoint
Key: FLINK-21522
URL: https://issues.apache.org/jira/browse/FLINK-21522
Project: Flink
Issue
m not wrong.
PR#14831: https://github.com/apache/flink/pull/14831
FLINK-21467: https://issues.apache.org/jira/browse/FLINK-21467
Best,
Kezhu Wang
On February 27, 2021 at 18:12:20, Till Rohrmann (trohrm...@apache.org)
wrote:
Thanks for all your thoughts. I think we should further think throu
ait for a specific savepoint
For stop-with-savepoint, the checkpoint barrier is already created or
received there.
Best,
Kezhu Wang
On February 25, 2021 at 21:02:30, Yun Gao (yungao...@aliyun.com) wrote:
Hi all,
Very thanks for the discussions!
A. Regarding how to avoid emitting reco
to lose.
Then, we could recommend users to migrate possible “end-of-stream-flushing”
from “close" to “finish”.
Best,
Kezhu 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 m
Kezhu Wang created FLINK-21467:
--
Summary: Document possible recommended usage of
Bounded{One/Multi}Input.endInput and emphasize that they could be called
multiple times
Key: FLINK-21467
URL: https
Congratulations!
Best,
Kezhu Wang
On February 10, 2021 at 21:53:52, Dawid Wysakowicz (dwysakow...@apache.org)
wrote:
Congratulations Roman! Glad to have you on board!
Best,
Dawid
On 10/02/2021 14:44, Igal Shilman wrote:
> Welcome Roman!
> Top-notch stuff! :)
>
> All the
Kezhu Wang created FLINK-21320:
--
Summary: Stream from FlinkKafkaShuffle.persistentKeyBy does not
end if upstream ends
Key: FLINK-21320
URL: https://issues.apache.org/jira/browse/FLINK-21320
Project
Kezhu Wang created FLINK-21317:
--
Summary: Downstream keyed state not work after FlinkKafkaShuffle
Key: FLINK-21317
URL: https://issues.apache.org/jira/browse/FLINK-21317
Project: Flink
Issue
Hi all,
Thanks for starting the discussion!
I think there are differences between start-position and checkpoint-state.
Checkpoint states
are actually intermediate progress-capture in reading data. Source clients
don't care about it
in coding phase, there are purely implementation details. While
chaining”.
Best,
Kezhu Wang
On Thu, Feb 4, 2021 at 13:22 Xintong Song wrote:
> Hi Kezhu,
>
> Maybe let me share some backgrounds first.
>
>- We at Alibaba have been using fine-grained resource management for
>many years, with Blink (an internal version of Flink).
>
Hi Till,
Based on what I understood, if not wrong, the door is not closed after SSG
resource specifying. So, hope it could be useful in potential future
improvement.
Best,
Kezhu Wang
On February 3, 2021 at 18:07:21, Till Rohrmann (trohrm...@apache.org) wrote:
Thanks for sharing your thoughts
or development purposes.
We might consider to keep that option after the feature is completed, to
allow disable the feature without having to touch the job codes.
Thank you~
Xintong Song
On Wed, Feb 3, 2021 at 1:28 PM Kezhu Wang wrote:
> Hi all, sorry for join discussion even after voting s
Hi all, sorry for join discussion even after voting started.
I want to share my thoughts on this after reading above discussions.
I think Flink *runtime* already has an ideal granularity for resource
management 'task'. If there is
a slot shared by multiple tasks, that slot's resource requirement
Kezhu Wang created FLINK-21133:
--
Summary: FLIP-27 Source does not work with synchronous savepoint
Key: FLINK-21133
URL: https://issues.apache.org/jira/browse/FLINK-21133
Project: Flink
Issue
Kezhu Wang created FLINK-21132:
--
Summary: BoundedOneInput.endInput is called when taking
synchronous savepoint
Key: FLINK-21132
URL: https://issues.apache.org/jira/browse/FLINK-21132
Project: Flink
Kezhu Wang created FLINK-20658:
--
Summary: Make sure jdbc connection is established by target driver
Key: FLINK-20658
URL: https://issues.apache.org/jira/browse/FLINK-20658
Project: Flink
Issue
Kezhu Wang created FLINK-20657:
--
Summary: Migrate jdbc connection code of JdbcInputFormat,
JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider
Key: FLINK-20657
URL: https
Kezhu Wang created FLINK-20614:
--
Summary: Registered sql drivers not deregistered after task
finished in session cluster
Key: FLINK-20614
URL: https://issues.apache.org/jira/browse/FLINK-20614
Project
Kezhu Wang created FLINK-19717:
--
Summary: SourceReaderBase.pollNext may return END_OF_INPUT if
SplitReader.fetch throws
Key: FLINK-19717
URL: https://issues.apache.org/jira/browse/FLINK-19717
Project
Kezhu Wang created FLINK-14793:
--
Summary: Add SPI interface to discovery state backend and
establish well-known names
Key: FLINK-14793
URL: https://issues.apache.org/jira/browse/FLINK-14793
Project
Kezhu Wang created FLINK-14790:
--
Summary: Custom state backend in job graph composition without
depending on concrete state backend implementation
Key: FLINK-14790
URL: https://issues.apache.org/jira/browse/FLINK
Kezhu Wang created FLINK-12491:
--
Summary: Incorrect documentation for directory path separators of
CoreOptions.TMP_DIRS
Key: FLINK-12491
URL: https://issues.apache.org/jira/browse/FLINK-12491
Project
Kezhu Wang created FLINK-11409:
--
Summary: Make `ProcessFunction`, `ProcessWindowFunction` and etc.
pure interfaces
Key: FLINK-11409
URL: https://issues.apache.org/jira/browse/FLINK-11409
Project: Flink
Hi guys:
Could someone give me contributor permission?
My JIRA username is kezhuw
Thanks,
Kezhu Wang
36 matches
Mail list logo
