[ https://issues.apache.org/jira/browse/BEAM-11005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17549027#comment-17549027 ]
Danny McCormick commented on BEAM-11005: ---------------------------------------- This issue has been migrated to https://github.com/apache/beam/issues/20637 > Can't use side inputs with Combine.PerKeyWithHotKeyFanout > --------------------------------------------------------- > > Key: BEAM-11005 > URL: https://issues.apache.org/jira/browse/BEAM-11005 > Project: Beam > Issue Type: Bug > Components: sdk-java-core > Reporter: Mia Gil Epner > Priority: P3 > Labels: Clarified, starter > > PerKeyWithHotKeyFanout doesn't allow a user to specify a side input and > access it in the CombineFn. When the function `withHotKeyFanout` is called, > any sideinputs stored in the Combine.PerKey are dropped. > ([https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java#L1571]): > > {code:java} > public PerKeyWithHotKeyFanout<K, InputT, OutputT> withHotKeyFanout( > SerializableFunction<? super K, Integer> hotKeyFanout) { > return new PerKeyWithHotKeyFanout<>(fn, fnDisplayData, hotKeyFanout); > } > {code} > We would like to be able to use side inputs and hot key fanout. -- This message was sent by Atlassian Jira (v8.20.7#820007)