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