[
https://issues.apache.org/jira/browse/BEAM-14484?focusedWorklogId=772493&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-772493
]
ASF GitHub Bot logged work on BEAM-14484:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 19/May/22 15:17
Start Date: 19/May/22 15:17
Worklog Time Spent: 10m
Work Description: jrmccluskey commented on PR #17716:
URL: https://github.com/apache/beam/pull/17716#issuecomment-1131858030
The Flink breakage is surprisingly tied to PR #17681 as the TestStream tests
are passing an unwindowed, unbounded side input into our passert functions that
make them side inputs. Will be looking into fixing that next
Issue Time Tracking
-------------------
Worklog Id: (was: 772493)
Time Spent: 2h (was: 1h 50m)
> Improve error message surrounding primary returns in the self-checkpointing
> code
> --------------------------------------------------------------------------------
>
> Key: BEAM-14484
> URL: https://issues.apache.org/jira/browse/BEAM-14484
> Project: Beam
> Issue Type: Improvement
> Components: sdk-go
> Reporter: Jack McCluskey
> Assignee: Jack McCluskey
> Priority: P1
> Time Spent: 2h
> Remaining Estimate: 0h
>
> The error message in the Go SDK harness around returned primaries in the
> self-checkpointing code
> ([https://github.com/apache/beam/blob/ea1f292e9cf31fc8c4803b10d811f0d3ee184ae7/sdks/go/pkg/beam/core/runtime/exec/datasource.go#L375)]
> is unclear and should be made more explicit. It should also guide the user
> towards making sure that the restriction behaves properly in the
> self-checkpointing case.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
