feat: Session Window and Reduce Streaming #4429
Annotations
6 errors
|
Install Numaflow:
pkg/sources/udsource/utils/offset.go#L60
cannot use offset.PartitionIdx() (value of type int32) as string value in struct literal
|
|
Install Numaflow:
pkg/sources/udsource/utils/offset.go#L66
cannot use offset.GetPartitionId() (value of type string) as int32 value in argument to NewSimpleSourceOffset
|
|
Install Numaflow:
pkg/sdkclient/source/client/interface.go#L39
undefined: sourcepb.PartitionsResponse
|
|
Install Numaflow:
pkg/sdkclient/source/client/client.go#L129
undefined: sourcepb.PartitionsResponse
|
|
Install Numaflow:
pkg/sdkclient/source/client/client.go#L130
c.grpcClt.PartitionsFn undefined (type "github.com/numaproj/numaflow-go/pkg/apis/proto/source/v1".SourceClient has no field or method PartitionsFn)
|
|
Install Numaflow
Process completed with exit code 2.
|
The logs for this run have expired and are no longer available.
Loading