[
https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836540#comment-15836540
]
Amit Sela commented on BEAM-302:
[~davor] where are we with Scio integration ?
> Add Scio Scala DSL to Beam
[
https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836535#comment-15836535
]
Amit Sela commented on BEAM-302:
Scio currently supports the Dataflow SDK (sort of Beam predecessor), and
Amit Sela created BEAM-1294:
---
Summary: Long running UnboundedSource Readers via Broadcasts
Key: BEAM-1294
URL: https://issues.apache.org/jira/browse/BEAM-1294
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela resolved BEAM-1291.
-
Resolution: Fixed
Fix Version/s: 0.5.0
> KafkaIO: don't log warning in offset fetcher while closing
[
https://issues.apache.org/jira/browse/BEAM-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela closed BEAM-1214.
---
Resolution: Fixed
Fix Version/s: 0.5.0
> fail to run on SparkRunner with VerifyError
>
[
https://issues.apache.org/jira/browse/BEAM-648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela updated BEAM-648:
---
Assignee: Aviem Zur (was: Jean-Baptiste Onofré)
> Persist and restore Aggergator values in case of recovery
[
https://issues.apache.org/jira/browse/BEAM-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829944#comment-15829944
]
Amit Sela edited comment on BEAM-1214 at 1/19/17 1:56 PM:
--
Sorry for taking so
[
https://issues.apache.org/jira/browse/BEAM-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829944#comment-15829944
]
Amit Sela commented on BEAM-1214:
-
[~mingmxu] could you share your pom please ? I'm wondering if you're
[
https://issues.apache.org/jira/browse/BEAM-979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela resolved BEAM-979.
Resolution: Fixed
Fix Version/s: 0.5.0
Resolved by BEAM-1177
> ConcurrentModificationException
[
https://issues.apache.org/jira/browse/BEAM-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela resolved BEAM-921.
Resolution: Fixed
Fix Version/s: 0.5.0
> Register Coders and Sources to serialize with JavaSerializer
[
https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820729#comment-15820729
]
Amit Sela commented on BEAM-849:
So in the "spirit" of the unified model, would you agree that bounded
Amit Sela created BEAM-1256:
---
Summary: SparkPipelineResult.StreamingMode should not return null
on awaitTermination()
Key: BEAM-1256
URL: https://issues.apache.org/jira/browse/BEAM-1256
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-1177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela closed BEAM-1177.
---
> Input DStream "bundles" should be in serialized form and include relevant
> metadata.
>
[
https://issues.apache.org/jira/browse/BEAM-1250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela closed BEAM-1250.
---
Resolution: Fixed
Fix Version/s: 0.5.0
> Remove leaf when materializing PCollection to avoid
[
https://issues.apache.org/jira/browse/BEAM-1250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela updated BEAM-1250:
Description:
When materializing a {{PCollection}} (implemented as {{RDD}}), to create a
{{PCollectionView}}
Amit Sela created BEAM-1250:
---
Summary: Remove leaf when materializing PCollection to avoid
re-evaluation.
Key: BEAM-1250
URL: https://issues.apache.org/jira/browse/BEAM-1250
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela updated BEAM-649:
---
Description:
Currently, the runner will cache any {{PCollection}} implementation - {{RDD}}
or {{DStream}} - if
[
https://issues.apache.org/jira/browse/BEAM-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela updated BEAM-649:
---
Summary: Cache any PCollection implementation if accessed more than once
(was: Pipeline "actions" should use
[
https://issues.apache.org/jira/browse/BEAM-18?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15799073#comment-15799073
]
Amit Sela commented on BEAM-18:
---
Since {{Sink}} is not a {{PTransform}}, but made of several {{Par.Do}}s, it is
[
https://issues.apache.org/jira/browse/BEAM-1145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela resolved BEAM-1145.
-
Resolution: Fixed
Fix Version/s: 0.5.0
> Remove classifier from shaded spark runner artifact
>
[
https://issues.apache.org/jira/browse/BEAM-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Sela resolved BEAM-1146.
-
Resolution: Fixed
Fix Version/s: 0.5.0
> Decrease spark runner startup overhead
>
101 - 121 of 121 matches
Mail list logo
