search

brimdata / zync

Kafka connector to sync Zed lakes to and from Kafka topics
BSD 3-Clause "New" or "Revised" License
17 stars 3 forks source link

doneType ptr compare failing #31

Open mccanne opened 2 years ago

mccanne commented 2 years ago

In etl/pipeline.go, the commented out code cannot replace the code below for some reason...

        //XXX This still doesn't work with the bug fix.  See issue #
        //if vals[k].Type == p.doneType {
        //  out.Append(&vals[k])
        //}
        if typedef, ok := vals[k].Type.(*zed.TypeAlias); ok && typedef.Name == "done" {
            out.Append(&vals[k])
        }