[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590911#comment-16590911
]
Thomas Weise commented on BEAM-5190:
It turns out that the issue in streaming mode was different:
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589865#comment-16589865
]
Ankur Goenka commented on BEAM-5190:
Yes, The more interesting stack is on the Python SDK side where
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589097#comment-16589097
]
Thomas Weise commented on BEAM-5190:
Here is the stack trace that I see several operators stuck at:
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588862#comment-16588862
]
Thomas Weise commented on BEAM-5190:
Yep, options need to be rewritten during submission because the
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588549#comment-16588549
]
Ankur Goenka commented on BEAM-5190:
Options are rewritten to URN causing the issue.
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588483#comment-16588483
]
Ankur Goenka commented on BEAM-5190:
cc: [~thw] This blocks the worker_thread option on python
