You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2022/08/19 20:08:29 UTC
[beam] branch master updated: Fix lint issues (#22800)
This is an automated email from the ASF dual-hosted git repository.
damccorm 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 f921a2f1996 Fix lint issues (#22800)
f921a2f1996 is described below
commit f921a2f1996cf906d994a9d62aeb6978bab09dd5
Author: Danny McCormick <da...@google.com>
AuthorDate: Fri Aug 19 13:08:23 2022 -0700
Fix lint issues (#22800)
---
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/sdks/go/pkg/beam/core/runtime/graphx/translate.go b/sdks/go/pkg/beam/core/runtime/graphx/translate.go
index a5ef6d75e5d..975fdf4f13d 100644
--- a/sdks/go/pkg/beam/core/runtime/graphx/translate.go
+++ b/sdks/go/pkg/beam/core/runtime/graphx/translate.go
@@ -833,7 +833,7 @@ func (m *marshaller) expandReshuffle(edge NamedEdge) (string, error) {
if err != nil {
return handleErr(err)
}
- windowCoderId, err := m.coders.AddWindowCoder(coderID)
+ windowCoderID, err := m.coders.AddWindowCoder(coderID)
if err != nil {
return handleErr(err)
}
@@ -856,7 +856,7 @@ func (m *marshaller) expandReshuffle(edge NamedEdge) (string, error) {
// TODO(BEAM-3304): migrate to user side operations once trigger support is in.
EnvironmentId: m.addDefaultEnv(),
MergeStatus: pipepb.MergeStatus_NON_MERGING,
- WindowCoderId: windowCoderId,
+ WindowCoderId: windowCoderID,
ClosingBehavior: pipepb.ClosingBehavior_EMIT_IF_NONEMPTY,
AllowedLateness: int64(in.From.WindowingStrategy().AllowedLateness),
OnTimeBehavior: pipepb.OnTimeBehavior_FIRE_ALWAYS,
@@ -1058,7 +1058,7 @@ func MarshalWindowingStrategy(c *CoderMarshaller, w *window.WindowingStrategy) (
if err != nil {
return nil, err
}
- windowCoderId, err := c.AddWindowCoder(coderID)
+ windowCoderID, err := c.AddWindowCoder(coderID)
if err != nil {
return nil, err
}
@@ -1072,7 +1072,7 @@ func MarshalWindowingStrategy(c *CoderMarshaller, w *window.WindowingStrategy) (
ws := &pipepb.WindowingStrategy{
WindowFn: windowFn,
MergeStatus: mergeStat,
- WindowCoderId: windowCoderId,
+ WindowCoderId: windowCoderID,
Trigger: makeTrigger(w.Trigger),
AccumulationMode: makeAccumulationMode(w.AccumulationMode),
OutputTime: pipepb.OutputTime_END_OF_WINDOW,