Skip to content

Commit

Permalink
Add call-out for future error
Browse files Browse the repository at this point in the history
  • Loading branch information
jrmccluskey committed May 23, 2022
1 parent ec9bd58 commit 16ad294
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sdks/go/pkg/beam/pardo.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func TryParDo(s Scope, dofn interface{}, col PCollection, opts ...Option) ([]PCo
}
if (sideWfn.Kind == window.GlobalWindows) && !sideNode.Bounded() {
// TODO(BEAM-14501): Replace this warning with an error return when proper streaming test functions have been added.
log.Warnf(context.Background(), "side input %v is global windowed in DoFn %v but is unbounded, DoFn will block until end of Global Window. Consider windowing your unbounded side input PCollection before use", i, fn)
log.Warnf(context.Background(), "side input %v is global windowed in DoFn %v but is unbounded, DoFn will block until end of Global Window. Consider windowing your unbounded side input PCollection before use. This will cause your pipeline to fail in a future release, see BEAM-14501 for details", i, fn)
}
in = append(in, s.Input.n)
}
Expand Down

0 comments on commit 16ad294

Please sign in to comment.