[ https://issues.apache.org/jira/browse/BEAM-2930?focusedWorklogId=134783&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-134783 ]
ASF GitHub Bot logged work on BEAM-2930: ---------------------------------------- Author: ASF GitHub Bot Created on: 14/Aug/18 23:14 Start Date: 14/Aug/18 23:14 Worklog Time Spent: 10m Work Description: tweise commented on issue #6208: [WIP] [BEAM-2930] Side input support for Flink portable streaming. URL: https://github.com/apache/beam/pull/6208#issuecomment-413045243 @lukecwik thanks for taking a look. I wonder how droppably late can be evaluated in this case: The side input handler won't have received an input and the window is "ready" based on the watermark? In the old runner we have a separate combine operator, here I'm trying to accumulate the iterable in state. Regarding refactor, my goal is to get this functional correct in first pass. Hope to then discuss/work with @aljoscha on how to extract common base operator for both runners. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking ------------------- Worklog Id: (was: 134783) Time Spent: 2h 50m (was: 2h 40m) > Flink support for portable side input > ------------------------------------- > > Key: BEAM-2930 > URL: https://issues.apache.org/jira/browse/BEAM-2930 > Project: Beam > Issue Type: Sub-task > Components: runner-flink > Reporter: Henning Rohde > Priority: Major > Labels: portability > Time Spent: 2h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian JIRA (v7.6.3#76005)