[ https://issues.apache.org/jira/browse/BEAM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee reassigned BEAM-1723: ---------------------------------- Assignee: Jingsong Lee > FlinkRunner should deduplicate when an UnboundedSource requires Deduping > ------------------------------------------------------------------------ > > Key: BEAM-1723 > URL: https://issues.apache.org/jira/browse/BEAM-1723 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Thomas Groh > Assignee: Jingsong Lee > > UnboundedSource implementations can require deduping, and the FlinkRunner > currently logs a warning that this is not supported. > https://github.com/apache/beam/blob/master/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapper.java#L139 -- This message was sent by Atlassian JIRA (v6.3.15#6346)