This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch beam24931
in repository https://gitbox.apache.org/repos/asf/beam.git
from 0aeed95d6a8 return checkpoint list
add 88644eabc3d Fix formating
add a862f3ccdf2 increase coverage, fix return path
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 5 +-
.../pkg/beam/core/runtime/exec/datasource_test.go | 90 +++++++++++++++-------
sdks/go/pkg/beam/core/runtime/exec/sdf.go | 24 +++---
sdks/go/pkg/beam/core/runtime/exec/sdf_test.go | 30 ++++++++
4 files changed, 106 insertions(+), 43 deletions(-)
