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