[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305035#comment-17305035
]
Kyle Weaver commented on FLINK-10672:
-
I tried upgrading to Flink 1.12.1 and this problem no longer
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158504#comment-17158504
]
Yun Gao commented on FLINK-10672:
-
Hi [~ibzib], very sorry to disturb, do you have any updates from you
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148271#comment-17148271
]
Peidian Li commented on FLINK-10672:
I'm sorry for the misinformation. Although I found the same
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147486#comment-17147486
]
Yun Gao commented on FLINK-10672:
-
[~lipeidian], very thanks for the reporting, are you also using Beam
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147323#comment-17147323
]
Peidian Li commented on FLINK-10672:
I met the same problem with Flink 1.9. Is there any conclusion
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101381#comment-17101381
]
Yun Gao commented on FLINK-10672:
-
Hi [~ibzib], sorry that the environment has been freed by the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097696#comment-17097696
]
Kyle Weaver commented on FLINK-10672:
-
Hi Yun, sorry I haven't had much time to look at this lately.
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070745#comment-17070745
]
Yun Gao commented on FLINK-10672:
-
Hi [~ibzib] I have deploy an environment with Beam 2.14 and tfx 0.14
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065410#comment-17065410
]
Yun Gao commented on FLINK-10672:
-
Hi Kyle, very sorry that I still have some problem reproducing the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065414#comment-17065414
]
Yun Gao commented on FLINK-10672:
-
Hi [~ibzib], very sorry that I still have some problems when
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065155#comment-17065155
]
Kyle Weaver commented on FLINK-10672:
-
Hi [~gaoyunhaii], any updates on this?
> Task stuck while
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973391#comment-16973391
]
venkata subbarao chunduri commented on FLINK-10672:
---
Thank you, Yun.
Yes, the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970692#comment-16970692
]
Yun Gao commented on FLINK-10672:
-
Hi venkata, very thanks for the reporting! From my side I think by
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970360#comment-16970360
]
venkata subbarao chunduri commented on FLINK-10672:
---
Could it be due to local channel?
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953107#comment-16953107
]
Kyle Weaver commented on FLINK-10672:
-
This bug was initially filed when stuckness became an issue
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953016#comment-16953016
]
Yun Gao commented on FLINK-10672:
-
Hi Kyle, very thanks for the input! I still have two confusions, the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952809#comment-16952809
]
Kyle Weaver commented on FLINK-10672:
-
You will need to set the task parallelism to reproduce the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951507#comment-16951507
]
Yun Gao commented on FLINK-10672:
-
Hi [~angoenka], very sorry for the long delay because of meeting with
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946410#comment-16946410
]
Yun Gao commented on FLINK-10672:
-
Hi [~angoenka] Very thanks for the input and very sorry for
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942291#comment-16942291
]
Ankur Goenka commented on FLINK-10672:
--
I don't have the original graph as the code has changed.
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16941796#comment-16941796
]
Maximilian Michels commented on FLINK-10672:
[~angoenka] Do you think you could provide
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940226#comment-16940226
]
Yun Gao commented on FLINK-10672:
-
Hi [~mxm], very thanks for the explanation. Besides, is it possible
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939220#comment-16939220
]
Maximilian Michels commented on FLINK-10672:
Yes, it is one possible explanation that the
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939094#comment-16939094
]
Yun Gao commented on FLINK-10672:
-
Hi [~ibzib], very sorry for not very familiar with Beam, but I see
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938443#comment-16938443
]
zhijiang commented on FLINK-10672:
--
I think [~gaoyunhaii] would continue helping trace this issue .
>
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938147#comment-16938147
]
Kyle Weaver commented on FLINK-10672:
-
[~zjwang] I have tested the pipeline on Flink 1.8.1 and Flink
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897491#comment-16897491
]
zhijiang commented on FLINK-10672:
--
Could you also test the release-1.8.1 or current master branch
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897101#comment-16897101
]
Maximilian Michels commented on FLINK-10672:
[~zjwang] From the testing that [~angoenka]
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887642#comment-16887642
]
zhijiang commented on FLINK-10672:
--
[~ibzib] I think it is the case of back pressure. The producer is
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887283#comment-16887283
]
Kyle Weaver commented on FLINK-10672:
-
[~zjwang] I was on Flink 1.5.6 before. I upgraded to 1.8.1
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887201#comment-16887201
]
zhijiang commented on FLINK-10672:
--
[~ibzib] which fix do you mean?
In addition which flink version
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886547#comment-16886547
]
Kyle Weaver commented on FLINK-10672:
-
[~zjwang] [~pnowojski] I saw you had made previous fixes to
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882538#comment-16882538
]
Kyle Weaver commented on FLINK-10672:
-
This is still an issue with the TFX preprocess Beam pipeline
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724901#comment-16724901
]
Maximilian Michels commented on FLINK-10672:
No, [~thw] just set the Fix Version to empty
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724576#comment-16724576
]
Ankur Goenka commented on FLINK-10672:
--
Is this fixed in 1.5.6?
> Task stuck while writing output
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671319#comment-16671319
]
Maximilian Michels commented on FLINK-10672:
Thanks for investigating the matter
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669502#comment-16669502
]
Ankur Goenka commented on FLINK-10672:
--
Investigation notes:
* Pipeline seems to be waiting on
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662937#comment-16662937
]
Ankur Goenka commented on FLINK-10672:
--
cc: [~mxm] [~robertwb]
> Task stuck while writing output
38 matches
Mail list logo