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/09/19 17:04:23 UTC
[beam] branch master updated: Fix wrong comment (#23272)
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 485b94356fd Fix wrong comment (#23272)
485b94356fd is described below
commit 485b94356fd8b9e488c9a97825cbe48a7ebcd265
Author: coldWater <25...@qq.com>
AuthorDate: Tue Sep 20 01:04:16 2022 +0800
Fix wrong comment (#23272)
---
sdks/go/pkg/beam/runners/direct/gbk.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/go/pkg/beam/runners/direct/gbk.go b/sdks/go/pkg/beam/runners/direct/gbk.go
index f1edb812924..c1dc97bb876 100644
--- a/sdks/go/pkg/beam/runners/direct/gbk.go
+++ b/sdks/go/pkg/beam/runners/direct/gbk.go
@@ -186,7 +186,7 @@ func (n *CoGBK) String() string {
}
// Inject injects the predecessor index into each FullValue, effectively
-// converting KV<X,Y> into KV<X,KV<int,Y>>. Used to prime CoGBK.
+// converting KV<X,Y> into KV<int,KV<X,Y>>. Used to prime CoGBK.
type Inject struct {
UID exec.UnitID
N int