[beam] branch lostluck-patch-1 created (now cb5a467)

[lo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a change to branch lostluck-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at cb5a467  [Go SDK] Delete spammy log in datamgr.go

This branch includes the following new commits:

     new cb5a467  [Go SDK] Delete spammy log in datamgr.go

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[beam] 01/01: [Go SDK] Delete spammy log in datamgr.go

[lo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch lostluck-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git

commit cb5a4671fc3402f1026ba63279b079ba15e8f811
Author: Robert Burke <lo...@users.noreply.github.com>
AuthorDate: Fri Oct 25 13:06:24 2019 -0700

    [Go SDK] Delete spammy log in datamgr.go
---
 sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/sdks/go/pkg/beam/core/runtime/harness/datamgr.go b/sdks/go/pkg/beam/core/runtime/harness/datamgr.go
index 42c8d73..cf74505 100644
--- a/sdks/go/pkg/beam/core/runtime/harness/datamgr.go
+++ b/sdks/go/pkg/beam/core/runtime/harness/datamgr.go
@@ -332,7 +332,6 @@ func (r *dataReader) Read(buf []byte) (int, error) {
 	if r.cur == nil {
 		b, ok := <-r.buf
 		if !ok {
-			log.Errorf(context.TODO(), "dataReader.Read %v channel closed: %v", r.id, r.err)
 			if r.err == nil {
 				return 0, io.EOF
 			}