[jira] [Assigned] (BEAM-5421) filter.Exclude is panicking

["Jack McCluskey (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jack McCluskey reassigned BEAM-5421:
------------------------------------

    Assignee: Jack McCluskey

> 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: Jack McCluskey
>            Priority: P3
>
> {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
(v8.20.1#820001)