[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855488#comment-15855488
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
The collector can be made thread-
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855478#comment-15855478
]
Haohui Mai commented on FLINK-5583:
---
The interface looks good to me. It looks like that
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Ah, I see what you mean. For your
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855424#comment-15855424
]
Haohui Mai commented on FLINK-5583:
---
The pseudo-code looks like the following:
{code}
v
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855313#comment-15855313
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Regarding breaking user code when
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855251#comment-15855251
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Hi [~wheat9],
I'm not quite sure
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854944#comment-15854944
]
Haohui Mai commented on FLINK-5583:
---
In general (1) sounds good to me. Taking a closer l
