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 2022/05/24 16:51:12 UTC
[beam] branch master updated: Fix -- linting issue (#17738)
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new d9436c41b32 Fix -- linting issue (#17738)
d9436c41b32 is described below
commit d9436c41b3235a08bf8da693a562599b08039bf8
Author: Danny McCormick <da...@google.com>
AuthorDate: Tue May 24 12:51:03 2022 -0400
Fix -- linting issue (#17738)
---
sdks/go/pkg/beam/io/textio/textio.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/go/pkg/beam/io/textio/textio.go b/sdks/go/pkg/beam/io/textio/textio.go
index 315487840b5..7c4a8d3b725 100644
--- a/sdks/go/pkg/beam/io/textio/textio.go
+++ b/sdks/go/pkg/beam/io/textio/textio.go
@@ -208,7 +208,7 @@ func (fn *readFn) ProcessElement(ctx context.Context, rt *sdf.LockRTracker, file
// scanning to the byte just before the restriction and then reading
// until the next newline, leaving the reader at the start of a new
// line past restriction.Start.
- i -= 1
+ i--
n, err := rd.Discard(int(i)) // Scan to just before restriction.
if err == io.EOF {
return errors.Errorf("TextIO restriction lies outside the file being read. "+