[
https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang reassigned FLINK-11326:
--
Assignee: Kezhu Wang
> Using offsets to adjust windows to timezones UTC-8 throws
>
[
https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11326:
---
Affects Version/s: 1.7.1
> Using offsets to adjust windows to timezones UTC-8 throws
>
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11409:
---
Description:
I found these functions express no opinionated demands from implementing
classes. It
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11409:
---
Description:
I found these functions express no opinionated demands from implementing
classes. It
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
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757282#comment-16757282
]
Kezhu Wang commented on FLINK-11409:
[~aljoscha] [~dawidwys] I would like to present example code
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang reassigned FLINK-11409:
--
Assignee: Kezhu Wang
> Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757541#comment-16757541
]
Kezhu Wang commented on FLINK-11409:
{quote}this is the pattern that we use/encourage users to use
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-14790:
--
Summary: Custom state backend in job graph composition without
depending on concrete state backend implementation
Key: FLINK-14790
URL:
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:
[
https://issues.apache.org/jira/browse/FLINK-14790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-14790:
---
Description:
In Flink 1.9 and before, if we want to custom state backend, we have to supply
[
https://issues.apache.org/jira/browse/FLINK-14793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974361#comment-16974361
]
Kezhu Wang commented on FLINK-14793:
[~sjwiesman] {{StateBackendProvider}} adds two additional
[
https://issues.apache.org/jira/browse/FLINK-14790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977037#comment-16977037
]
Kezhu Wang commented on FLINK-14790:
[~aljoscha] [~trohrmann] [~chesnay] Any thoughts on this ? If
[
https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190276#comment-17190276
]
Kezhu Wang commented on FLINK-18815:
Seems that recently two cases are leaking while previous cases
[
https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194971#comment-17194971
]
Kezhu Wang commented on FLINK-19212:
[~klden] Seems that this has fixed by
[
https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190870#comment-17190870
]
Kezhu Wang commented on FLINK-18815:
[~trohrmann] Your are right, I made mistake. After revise, I
[
https://issues.apache.org/jira/browse/FLINK-19427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208634#comment-17208634
]
Kezhu Wang commented on FLINK-19427:
I could image the execution steps for this failure:
1. After
[
https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208723#comment-17208723
]
Kezhu Wang commented on FLINK-19489:
Here are my imaginative execution flows for this issue, please
[
https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17207865#comment-17207865
]
Kezhu Wang commented on FLINK-19489:
After dived in, I think this could be a bug of
[
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212533#comment-17212533
]
Kezhu Wang commented on FLINK-19448:
Neither did I. But I found {{SourceReaderBase}} may shadowed
[
https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212498#comment-17212498
]
Kezhu Wang commented on FLINK-19489:
Sorry for late update. I have reported it to openjdk, seems
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:
[
https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216840#comment-17216840
]
Kezhu Wang commented on FLINK-19717:
{quote}Maybe the fix would be to always check for errors before
[
https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198874#comment-17198874
]
Kezhu Wang commented on FLINK-19266:
Hi [~hailong wang], it is already reported as
[
https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218676#comment-17218676
]
Kezhu Wang commented on FLINK-19717:
[~rmetzger] Thanks for response. Let's wait their decision.
[
https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219695#comment-17219695
]
Kezhu Wang commented on FLINK-19717:
[~sewen] I am willing to take over this.
>
[
https://issues.apache.org/jira/browse/FLINK-19665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222194#comment-17222194
]
Kezhu Wang commented on FLINK-19665:
[~pnowojski] [~rmetzger] Seems that it has been fixed in commit
[
https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173926#comment-17173926
]
Kezhu Wang commented on FLINK-18815:
I think this is caused by
[
https://issues.apache.org/jira/browse/FLINK-18571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155935#comment-17155935
]
Kezhu Wang commented on FLINK-18571:
[~JasonLee] I guess you are using 1.11 client targeting 1.10 or
[
https://issues.apache.org/jira/browse/FLINK-20523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263359#comment-17263359
]
Kezhu Wang commented on FLINK-20523:
I think it is caused by CURATOR-535.
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244654#comment-17244654
]
Kezhu Wang commented on FLINK-19435:
Seems that this problem still exist. I have pushed [a
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245245#comment-17245245
]
Kezhu Wang commented on FLINK-19435:
[~jark] I am willing to take over this.
Currently,
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245594#comment-17245594
]
Kezhu Wang edited comment on FLINK-19435 at 12/8/20, 1:09 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245593#comment-17245593
]
Kezhu Wang commented on FLINK-19435:
{quote}
Do you have use cases that show switching different
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245594#comment-17245594
]
Kezhu Wang commented on FLINK-19435:
[~roman_khachatryan] Inside {{DriverManager.getConnection}},
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245898#comment-17245898
]
Kezhu Wang commented on FLINK-19435:
[~lzljs3620320] From capability side, it is nice to have driver
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://issues.apache.org/jira/browse/FLINK-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254545#comment-17254545
]
Kezhu Wang commented on FLINK-20173:
This has been solved in 1.11.3, I checked it by download source
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252182#comment-17252182
]
Kezhu Wang edited comment on FLINK-20389 at 12/19/20, 1:23 PM:
---
Another
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252182#comment-17252182
]
Kezhu Wang commented on FLINK-20389:
Another case about {{NullPointerException}} from
[
https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252169#comment-17252169
]
Kezhu Wang commented on FLINK-20432:
Two more cases after timeout changed ?
* FLINK-20498
[
https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252554#comment-17252554
]
Kezhu Wang commented on FLINK-20658:
hmm..., the proposal I posted above actually does not work
[
https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252423#comment-17252423
]
Kezhu Wang commented on FLINK-20614:
[~chesnay] Sorry for ping you again. I thought about suggested
[
https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252893#comment-17252893
]
Kezhu Wang commented on FLINK-20657:
[~jark] [~roman_khachatryan] Seems that we have basic
[
https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250391#comment-17250391
]
Kezhu Wang commented on FLINK-20614:
[~chesnay] Sorry, I did not aware of FLINK-19005 before. Yeh,
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:
[
https://issues.apache.org/jira/browse/FLINK-20649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253554#comment-17253554
]
Kezhu Wang commented on FLINK-20649:
Should this be problem of
[
https://issues.apache.org/jira/browse/FLINK-20649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253639#comment-17253639
]
Kezhu Wang commented on FLINK-20649:
I think {{StreamTask.cancelOrFailAndCancelInvokable}} was
[
https://issues.apache.org/jira/browse/FLINK-20649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253655#comment-17253655
]
Kezhu Wang commented on FLINK-20649:
I think I get your point. I was kind of mess up the symptom
[
https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252450#comment-17252450
]
Kezhu Wang commented on FLINK-20657:
I see {{SimpleJdbcConnectionProvider}} has been shaped as some
[
https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252454#comment-17252454
]
Kezhu Wang commented on FLINK-20658:
It is a step to driver class customization discussed in
[
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228271#comment-17228271
]
Kezhu Wang commented on FLINK-19448:
[~sewen] Yes. Returning {{MORE_AVAILABLE}} is better than
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230315#comment-17230315
]
Kezhu Wang commented on FLINK-19864:
I think this is probably caused by misuse of
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233174#comment-17233174
]
Kezhu Wang commented on FLINK-19864:
How about using a combination of {{Thread.isAlive}} and
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235480#comment-17235480
]
Kezhu Wang commented on FLINK-19864:
[~AHeise] I will open a PR as soon as possible and mention you
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233772#comment-17233772
]
Kezhu Wang edited comment on FLINK-19864 at 11/19/20, 1:28 PM:
---
[~AHeise]
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233772#comment-17233772
]
Kezhu Wang commented on FLINK-19864:
[~AHeise] I think {{InputStatus}} is not enough. It only means
[
https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233643#comment-17233643
]
Kezhu Wang commented on FLINK-19864:
[~trohrmann] [~pnowojski] [~chesnay] [~AHeise] What do you
[
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225024#comment-17225024
]
Kezhu Wang commented on FLINK-19448:
[~sewen] Seems that
[
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225505#comment-17225505
]
Kezhu Wang commented on FLINK-19448:
I think I may find the cause.
First, let's see what javadoc
[
https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227464#comment-17227464
]
Kezhu Wang commented on FLINK-19448:
I think we can fix this by adding
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
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21133:
---
Affects Version/s: 1.11.3
1.12.1
> FLIP-27 Source does not work with
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276235#comment-17276235
]
Kezhu Wang edited comment on FLINK-21132 at 2/1/21, 10:29 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276235#comment-17276235
]
Kezhu Wang commented on FLINK-21132:
Hi [~roman_khachatryan], thanks for reviewing, let me detail:
[
https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278579#comment-17278579
]
Kezhu Wang commented on FLINK-21175:
[~maguowei] [~AHeise] [~roman_khachatryan] FLINK-19864 on 1.11
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273052#comment-17273052
]
Kezhu Wang commented on FLINK-21132:
I did not find an easy/viable way to distinguish truly end of
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274380#comment-17274380
]
Kezhu Wang commented on FLINK-21132:
If we agree that stop-with-savepoint should not pretending it
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272503#comment-17272503
]
Kezhu Wang commented on FLINK-21132:
[~pnowojski] For option#2, which is the current option, head
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277194#comment-17277194
]
Kezhu Wang commented on FLINK-21132:
{quote}
Keep in mind that while task is spinning inside
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277171#comment-17277171
]
Kezhu Wang commented on FLINK-21132:
You are right [~pnowojski], it depends on whether we want do
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277217#comment-17277217
]
Kezhu Wang commented on FLINK-21132:
{quote}
there will be nobody to relieve the upstream task from
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277199#comment-17277199
]
Kezhu Wang commented on FLINK-21132:
{quote}It's not ideal what we have at the moment, in the future
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21564:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
>
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
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:
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280863#comment-17280863
]
Kezhu Wang commented on FLINK-21317:
Hi [~ym], I found this in code reading not production use case.
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281563#comment-17281563
]
Kezhu Wang commented on FLINK-21132:
{quote}I saw a hole in notifyCheckpointAbortAsync where there
[
https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281568#comment-17281568
]
Kezhu Wang commented on FLINK-21323:
[~mapohl] [~roman_khachatryan] [~pnowojski] Maybe we can
[
https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281491#comment-17281491
]
Kezhu Wang commented on FLINK-17170:
I think it is problem of {{FlinkKinesisConsumer.cancel}}, it
[
https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281480#comment-17281480
]
Kezhu Wang commented on FLINK-21323:
[~mapohl] [~roman_khachatryan] FLIP-27 sources could be
[
https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281492#comment-17281492
]
Kezhu Wang commented on FLINK-17170:
{quote}
In stop-with-savepoint path,
[
https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282188#comment-17282188
]
Kezhu Wang commented on FLINK-21028:
[~trohrmann] [~pnowojski] Thanks for renew, I used to think it
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282263#comment-17282263
]
Kezhu Wang commented on FLINK-21133:
[~becket_qin] Sorry for not aware of your comment, I am writing
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282253#comment-17282253
]
Kezhu Wang commented on FLINK-21133:
Hi all, there are actually two cases for FLIP-27 sources not
[
https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282305#comment-17282305
]
Kezhu Wang commented on FLINK-21028:
{quote}but something would have to trigger SourceStreamTask
[
https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282305#comment-17282305
]
Kezhu Wang edited comment on FLINK-21028 at 2/10/21, 8:29 AM:
--
{quote}but
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282564#comment-17282564
]
Kezhu Wang commented on FLINK-21133:
{quote}I think what stop-with-savepoint should really do is
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275234#comment-17275234
]
Kezhu Wang commented on FLINK-21132:
[~aljoscha] [~pnowojski] [~roman_khachatryan] We all actually
[
https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276558#comment-17276558
]
Kezhu Wang commented on FLINK-21132:
Currently, there is no {{runSynchronousSavepointMailboxLoop}}
[
https://issues.apache.org/jira/browse/FLINK-19763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283125#comment-17283125
]
Kezhu Wang commented on FLINK-19763:
Hi all, I checked the reverted commit and think it fails
[
https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283134#comment-17283134
]
Kezhu Wang commented on FLINK-20580:
[~mapohl] [~trohrmann] May be better to not nullable but empty
[
https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283227#comment-17283227
]
Kezhu Wang commented on FLINK-20580:
[~trohrmann] Yeh, I could give it a try.
> Missing null value
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307580#comment-17307580
]
Kezhu Wang commented on FLINK-20329:
Another case:
[
https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306805#comment-17306805
]
Kezhu Wang commented on FLINK-21817:
I guess we four are probably talking about two inconsistencies:
[
https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306807#comment-17306807
]
Kezhu Wang commented on FLINK-21626:
[~roman_khachatryan] Thanks, I will.
> Consider shaping newly
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307891#comment-17307891
]
Kezhu Wang commented on FLINK-21821:
Good catch [~pnowojski]. But this would also risk to whole task
1 - 100 of 195 matches
Mail list logo
