Pablo Estrada created BEAM-4786: ----------------------------------- Summary: Distinct has bad parallelism characteristics Key: BEAM-4786 URL: https://issues.apache.org/jira/browse/BEAM-4786 Project: Beam Issue Type: Bug Components: sdk-java-core Reporter: Pablo Estrada Assignee: Pablo Estrada
Distinct groups first and then drops extra elements. Should drop elements in the mappers, and later in reducers. https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Distinct.java#L100 -- This message was sent by Atlassian JIRA (v7.6.3#76005)