[
https://issues.apache.org/jira/browse/BEAM-11417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Mills updated BEAM-11417:
Issue Type: Bug (was: Improvement)
> StreamingDataflowWorker can leak UnboundedSource finalization
Daniel Mills created BEAM-11417:
---
Summary: StreamingDataflowWorker can leak UnboundedSource
finalization callbacks
Key: BEAM-11417
URL: https://issues.apache.org/jira/browse/BEAM-11417
Project: Beam
Daniel Mills created BEAM-10984:
---
Summary: Dataflow's UnboundedReaderIterator should support
overriding default bundle size targets
Key: BEAM-10984
URL: https://issues.apache.org/jira/browse/BEAM-10984
Daniel Mills created BEAM-9627:
--
Summary: KafkaIO needs better support for SSL
Key: BEAM-9627
URL: https://issues.apache.org/jira/browse/BEAM-9627
Project: Beam
Issue Type: Improvement
Daniel Mills created BEAM-9320:
--
Summary: Add an annotation to State to indicate it should always
be fetched
Key: BEAM-9320
URL: https://issues.apache.org/jira/browse/BEAM-9320
Project: Beam
Is
[
https://issues.apache.org/jira/browse/BEAM-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Mills reassigned BEAM-9320:
--
Assignee: Reuven Lax
> Add an annotation to State to indicate it should always be fetched
> ---
Daniel Mills created BEAM-7932:
--
Summary: GcsFileSystem should validate directories and file names
for \n chars
Key: BEAM-7932
URL: https://issues.apache.org/jira/browse/BEAM-7932
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873723#comment-16873723
]
Daniel Mills commented on BEAM-7642:
There's at least one example pipeline in the beam
[
https://issues.apache.org/jira/browse/BEAM-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873721#comment-16873721
]
Daniel Mills commented on BEAM-7642:
Looks like the issue is a seconds/milliseconds mi