[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405554#comment-17405554
]
Yun Gao commented on FLINK-22085:
-
Since we have fix this case via
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377758#comment-17377758
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374626#comment-17374626
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374488#comment-17374488
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374211#comment-17374211
]
Yun Gao commented on FLINK-22085:
-
Very thanks [~arvid], I also agree with we could have one more
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373612#comment-17373612
]
Arvid Heise commented on FLINK-22085:
-
I think having `notifyDataAvailable` at the end of recovery
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373449#comment-17373449
]
Yun Gao commented on FLINK-22085:
-
No problem, I'll create a new issue and link it to this issue. I'll
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373128#comment-17373128
]
Dong Lin commented on FLINK-22085:
--
Thanks you [~gaoyunhaii] for the explanation!
Do you plan to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372420#comment-17372420
]
Yun Gao commented on FLINK-22085:
-
Hi all, I should have found the reason: for flush timeout = 0, the
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371822#comment-17371822
]
Yun Gao commented on FLINK-22085:
-
Thanks [~xintongsong] for the review and monitoring the tests~
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370985#comment-17370985
]
Xintong Song commented on FLINK-22085:
--
[~gaoyunhaii],
New instance found. Please take another
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370984#comment-17370984
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367908#comment-17367908
]
Xintong Song commented on FLINK-22085:
--
Logs added in db73b33538ab8b2d9edc91e6fe9795b48e3a2e4d
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367027#comment-17367027
]
Yun Gao commented on FLINK-22085:
-
Hi [~lindong] thanks for the explanation and it indeed helps a lot.
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366567#comment-17366567
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366359#comment-17366359
]
Dong Lin commented on FLINK-22085:
--
[~gaoyunhaii] Thanks for the investigation. Previously I have
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366357#comment-17366357
]
Yun Gao commented on FLINK-22085:
-
I checked the last several cases, it seems they are all failed at
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366346#comment-17366346
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366331#comment-17366331
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366330#comment-17366330
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365198#comment-17365198
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364934#comment-17364934
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364012#comment-17364012
]
Xintong Song commented on FLINK-22085:
--
Thanks a log, [~gaoyunhaii]. I've assigned you to the
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364011#comment-17364011
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363419#comment-17363419
]
Yun Gao commented on FLINK-22085:
-
[~xintongsong] OK, I'll have a look~
> KafkaSourceLegacyITCase
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363414#comment-17363414
]
Xintong Song commented on FLINK-22085:
--
[~gaoyunhaii], could you help take a look at the stacks
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363324#comment-17363324
]
Dong Lin commented on FLINK-22085:
--
[~xintongsong] Sure, please feel free to un-assign me. Thanks!
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363320#comment-17363320
]
Xintong Song commented on FLINK-22085:
--
[~lindong], thanks for the updates. I'll try to find
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363319#comment-17363319
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363298#comment-17363298
]
Dong Lin commented on FLINK-22085:
--
[~xintongsong] No... after spending 2+ hours over the weekend to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360510#comment-17360510
]
Xintong Song commented on FLINK-22085:
--
[~lindong], any updates on this one?
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360509#comment-17360509
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17357008#comment-17357008
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346656#comment-17346656
]
Robert Metzger commented on FLINK-22085:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346653#comment-17346653
]
Robert Metzger commented on FLINK-22085:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345902#comment-17345902
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333174#comment-17333174
]
Dawid Wysakowicz commented on FLINK-22085:
--
If you have concerns regarding timeouts, please
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333172#comment-17333172
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Hmm... why would the test hang in a random spot if
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333108#comment-17333108
]
Dawid Wysakowicz commented on FLINK-22085:
--
{quote}
Now that we have verifies that the test
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333085#comment-17333085
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] I see. Previously the test would be fail with
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333062#comment-17333062
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333007#comment-17333007
]
Dawid Wysakowicz commented on FLINK-22085:
--
One observation:
* some of the sub-tasks finish
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332957#comment-17332957
]
Dong Lin commented on FLINK-22085:
--
Thank you [~dwysakowicz] for the information.
For the first test
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332460#comment-17332460
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332456#comment-17332456
]
Dawid Wysakowicz commented on FLINK-22085:
--
I will remove timeouts on master to possibly get
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332455#comment-17332455
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330819#comment-17330819
]
Dawid Wysakowicz commented on FLINK-22085:
--
Thanks a lot [~lindong]. Really good job on
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330815#comment-17330815
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] After applying
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329271#comment-17329271
]
Dawid Wysakowicz commented on FLINK-22085:
--
Merge another fix in:
* 1.14 (master)
**
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327228#comment-17327228
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327224#comment-17327224
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327217#comment-17327217
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327213#comment-17327213
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327091#comment-17327091
]
Guowei Ma commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Yeah I am able to reproduce the test hang once. I
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326332#comment-17326332
]
Dawid Wysakowicz commented on FLINK-22085:
--
Any luck reproducing the issue [~lindong]?
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326196#comment-17326196
]
Yangze Guo commented on FLINK-22085:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325893#comment-17325893
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325643#comment-17325643
]
Dong Lin commented on FLINK-22085:
--
Thanks for the information [~mapohl]. Previously I have verified
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322774#comment-17322774
]
Guowei Ma commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322455#comment-17322455
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1738#comment-1738
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] I have updated this JIRA with the root cause
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321959#comment-17321959
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321305#comment-17321305
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321105#comment-17321105
]
Dong Lin commented on FLINK-22085:
--
Sounds good. I will use my personal azure account.
I am able to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321098#comment-17321098
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321055#comment-17321055
]
Dawid Wysakowicz commented on FLINK-22085:
--
I am afraid we should not increase the log level.
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321044#comment-17321044
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Sorry, I was busy with other work and didn't realize
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320760#comment-17320760
]
Roman Khachatryan commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320738#comment-17320738
]
Dawid Wysakowicz commented on FLINK-22085:
--
Any progress [~lindong] ?
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319039#comment-17319039
]
Dawid Wysakowicz commented on FLINK-22085:
--
Thx [~lindong] I will assign this to you.
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318958#comment-17318958
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Sure, I will take a look.
> KafkaSourceLegacyITCase
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318658#comment-17318658
]
Guowei Ma commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318067#comment-17318067
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317809#comment-17317809
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317709#comment-17317709
]
Dawid Wysakowicz commented on FLINK-22085:
--
[~lindong] Do you mind taking a look?
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317708#comment-17317708
]
Dawid Wysakowicz commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313622#comment-17313622
]
Guowei Ma commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313589#comment-17313589
]
Guowei Ma commented on FLINK-22085:
---
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313056#comment-17313056
]
Dawid Wysakowicz commented on FLINK-22085:
--
[~jqin] Could you take a look?
>
80 matches
Mail list logo
