Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-14484

Improve error message surrounding primary returns in the self-checkpointing code

Details

    • Improvement
    • Status: Resolved
    • P1
    • Resolution: Fixed
    • None
    • 2.40.0
    • sdk-go
    • None

    Description

      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. 

      Attachments

        Activity

          People

            jrmccluskey Jack McCluskey
            jrmccluskey Jack McCluskey
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 8h 10m
                8h 10m