Vadym created BEAM-5421:
---------------------------
Summary: filter.Exclude is panicking
Key: BEAM-5421
URL: https://issues.apache.org/jira/browse/BEAM-5421
Project: Beam
Issue Type: Bug
Components: sdk-go
Affects Versions: 2.6.0
Environment: Mac, Linux
Reporter: Vadym
Assignee: Robert Burke
{code:java}
package main
import (
"context"
"github.com/apache/beam/sdks/go/pkg/beam"
"github.com/apache/beam/sdks/go/pkg/beam/io/textio"
"github.com/apache/beam/sdks/go/pkg/beam/log"
"github.com/apache/beam/sdks/go/pkg/beam/transforms/filter"
"github.com/apache/beam/sdks/go/pkg/beam/x/beamx"
)
func islongWord(s string) bool {
return len(s) < 3
}
func main() {
beam.Init()
ctx := context.Background()
p, s := beam.NewPipelineWithRoot()
words := beam.Create(s, "a", "b", "long", "alsolong")
long := filter.Exclude(s, words, islongWord)
textio.Write(s, "long.txt", long)
if err := beamx.Run(ctx, p); err != nil {
log.Exitf(ctx, "Failed to execute job: %v", err)
}
}
{code}
The code above fails with the error message:
{{2018/09/18 15:47:23 Failed to execute job: panic: reflect: Call using []uint8
as type string goroutine 1 [running]:}}
The code was taken from Exclude example in the documentation:
https://godoc.org/github.com/apache/beam/sdks/go/pkg/beam/transforms/filter#Exclude
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
