You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2019/10/25 20:07:11 UTC
[beam] 01/01: [Go SDK] Delete spammy log in datamgr.go
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
}