Ryan Skraba created BEAM-1206:
-
Summary: PCollections used as a sideInput are unnecessarily
re-evaluated.
Key: BEAM-1206
URL: https://issues.apache.org/jira/browse/BEAM-1206
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-1206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated BEAM-1206:
--
Description:
The SparkRunner keeps track of "leaf" transforms in the job graph and ensures
that they
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953692#comment-15953692
]
Ryan Skraba commented on BEAM-1847:
---
My mistake, it's KafkaIO that ignores `withMaxReadTime()` when
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated BEAM-1847:
--
Description:
Some Beam IOs that expose the ability to turn an unbounded source into a
bounded source.
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated BEAM-1847:
--
Component/s: (was: beam-model)
sdk-java-extensions
> Read.Unbounded can't specify
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated BEAM-1847:
--
Summary: KafkaIO can't specify both max records and max duration. (was:
Read.Unbounded can't specify
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953692#comment-15953692
]
Ryan Skraba edited comment on BEAM-1847 at 4/3/17 3:55 PM:
---
My mistake, it's
Ryan Skraba created BEAM-1847:
-
Summary: Read.Unbounded can't specify both max records and max
duration.
Key: BEAM-1847
URL: https://issues.apache.org/jira/browse/BEAM-1847
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951159#comment-15951159
]
Ryan Skraba commented on BEAM-1847:
---
Can someone give me contributor permissions so I can assign myself
[
https://issues.apache.org/jira/browse/BEAM-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba reassigned BEAM-1847:
-
Assignee: Ryan Skraba (was: Frances Perry)
> Read.Unbounded can't specify both max records and
[
https://issues.apache.org/jira/browse/BEAM-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191085#comment-16191085
]
Ryan Skraba commented on BEAM-2993:
---
Hello -- I'm chiming in to help clarify our use case, which is a bit
[
https://issues.apache.org/jira/browse/BEAM-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192777#comment-16192777
]
Ryan Skraba edited comment on BEAM-2993 at 10/5/17 11:52 AM:
-
Very good points
[
https://issues.apache.org/jira/browse/BEAM-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192777#comment-16192777
]
Ryan Skraba commented on BEAM-2993:
---
Very good points and foreseeing some of our plans! Fortunately, I'm
[
https://issues.apache.org/jira/browse/BEAM-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192777#comment-16192777
]
Ryan Skraba edited comment on BEAM-2993 at 10/5/17 11:53 AM:
-
Very good points
[
https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145054#comment-16145054
]
Ryan Skraba commented on BEAM-2802:
---
Hello! Just to chime in -- I'm part of the team that asked Étienne
15 matches
Mail list logo
