[
https://issues.apache.org/jira/browse/BEAM-11104?focusedWorklogId=752488&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-752488
]
ASF GitHub Bot logged work on BEAM-11104:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 04/Apr/22 20:05
Start Date: 04/Apr/22 20:05
Worklog Time Spent: 10m
Work Description: jrmccluskey commented on code in PR #17265:
URL: https://github.com/apache/beam/pull/17265#discussion_r842097283
##########
sdks/go/pkg/beam/core/funcx/fn.go:
##########
@@ -631,6 +647,8 @@ func nextRetState(cur retState, transition ReturnKind)
(retState, error) {
return -1, errEventTimeRetPrecedence
case RetValue, RetRTracker:
return rsOutput, nil
+ case RetProcessContinuation:
+ return rsProcessContinuation, nil
Review Comment:
I think these two lines and the unit tests? I'll comment them out before the
merge but leave them intact while we're in review so we are confident that any
changes don't break anything
Issue Time Tracking
-------------------
Worklog Id: (was: 752488)
Time Spent: 2h 50m (was: 2h 40m)
> [Go SDK] DoFn Self Checkpointing
> --------------------------------
>
> Key: BEAM-11104
> URL: https://issues.apache.org/jira/browse/BEAM-11104
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-go
> Reporter: Robert Burke
> Priority: P3
> Time Spent: 2h 50m
> Remaining Estimate: 0h
>
> Allow SplittableDoFns to self checkpoint.
> (To be updated once [https://github.com/apache/beam/pull/13160] is merged and
> the programming guide updated with SDF content.)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
