This is an automated email from the ASF dual-hosted git repository. lostluck pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 58ad984 Merge pull request #9782: [BEAM-8390] Allow specifying useCorrelationId for RabbitMqIO.Read add cc533c1 [Go SDK] Fix subtle split error. Add more tests. (#9750) No new revisions were added by this update. Summary of changes: sdks/go/pkg/beam/core/runtime/exec/datasource.go | 3 +- .../pkg/beam/core/runtime/exec/datasource_test.go | 83 +++++++++++++++++++++- sdks/go/pkg/beam/core/runtime/exec/unit_test.go | 58 +++++++++++++++ 3 files changed, 142 insertions(+), 2 deletions(-)