Thomas Groh created BEAM-1724: --------------------------------- Summary: 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)