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 <[email protected]>
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
                        }

Reply via email to