[
https://issues.apache.org/jira/browse/BEAM-4152?focusedWorklogId=216957&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-216957
]
ASF GitHub Bot logged work on BEAM-4152:
----------------------------------------
Author: ASF GitHub Bot
Created on: 21/Mar/19 19:07
Start Date: 21/Mar/19 19:07
Worklog Time Spent: 10m
Work Description: lostluck commented on issue #8111: [BEAM-4152] Kinds &
URNs for Session Windows
URL: https://github.com/apache/beam/pull/8111#issuecomment-475364203
OK! So the panic is because the type isn't registered with
beam.RegisterType(), which is an error message that will be improving with the
following PR https://github.com/apache/beam/pull/8064
The next session windowing error you'll run into will be on the "exec" side
that happens on the workers. It's unaware of Session windows. You'll note this
is where the harder bit of assigning windows happens.
https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/core/runtime/exec/window.go#L57
I found the outstanding JIRA issue for session windowing,
https://issues.apache.org/jira/browse/BEAM-4152
Merging windows is not handled on the SDK side yet either (otherwise this
would be done already), but the answer here is "see what Java and/python are
doing, and do that in the Go way".
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 216957)
Time Spent: 1h (was: 50m)
> Support Go session windowing
> ----------------------------
>
> Key: BEAM-4152
> URL: https://issues.apache.org/jira/browse/BEAM-4152
> Project: Beam
> Issue Type: Improvement
> Components: sdk-go
> Reporter: Henning Rohde
> Priority: Major
> Time Spent: 1h
> Remaining Estimate: 0h
>
> Support session windowing and how to handle merging windows.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
