[
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)
