[jira] [Comment Edited] (BEAM-1724) ApexRunner should deduplicate when an UnboundedSource requires Deduping

["Daniel Halperin (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BEAM-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997051#comment-15997051 ] 

Daniel Halperin edited comment on BEAM-1724 at 5/4/17 4:49 PM:
---------------------------------------------------------------

It looks like this issue is not being worked on, and will not be worked on, so it's at risk of being cut from First Stable Release.

Obviously, we want assurances that every runner behaves correctly when using unbounded sources. But at the same time, the lack of available community members to contribute to this issue may reveal that the user base is small enough that it's not that important to fix.


was (Author: dhalperi@google.com):
It looks like this issue is not being worked on, and will not be worked on, so it's at risk of being cut from First Stable Release.

Obviously, we want assurances that every runner is properly tested. But at the same time, the lack of available community members to contribute to this issue may reveal that the user base is small enough that it's not that important to fix.

> ApexRunner should deduplicate when an UnboundedSource requires Deduping
> -----------------------------------------------------------------------
>
>                 Key: BEAM-1724
>                 URL: https://issues.apache.org/jira/browse/BEAM-1724
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-apex
>            Reporter: Thomas Groh
>             Fix For: First stable release
>
>
> The Apex implementation of UnboundedRead does not inspect the requiresDeduping property of an Unbounded Source. It should do so.
> https://github.com/apache/beam/blob/master/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/operators/ApexReadUnboundedInputOperator.java



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)