beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kenneth Knowles (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-1724) ApexRunner should deduplicate when an UnboundedSource requires Deduping
Date Mon, 22 May 2017 20:12:04 GMT

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

Kenneth Knowles commented on BEAM-1724:
---------------------------------------

I removed the release version just to avoid having all issues float along from release to
release without explicit decision to do so. If it helps your own tracking, please feel free
to re-add a future release.

> 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
>
> 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)

Mime
View raw message