add more consumer related code #1078
Annotations
9 errors and 1 warning
|
Integration Build:
pkg/sink/codec/canal/canal_json_decoder.go#L202
cannot use b.NextRowChangedEvent() (value of type *event.DMLEvent) as *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/canal/canal_json_decoder.go#L296
cannot use b.NextRowChangedEvent() (value of type *event.DMLEvent) as *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/canal/canal_json_decoder.go#L357
cannot use b.assembleHandleKeyOnlyRowChangedEvent(ctx, message) (value of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/canal/canal_json_decoder.go#L360
cannot use b.assembleClaimCheckRowChangedEvent(ctx, message.Extensions.ClaimCheckLocation) (value of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/canal/canal_json_decoder.go#L368
cannot use result (variable of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/canal/canal_json_txn_decoder.go#L111
cannot use result (variable of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/open/decoder.go#L212
cannot use b.assembleEventFromClaimCheckStorage(ctx) (value of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build:
pkg/sink/codec/open/decoder.go#L221
cannot use event (variable of type *"github.com/pingcap/tiflow/cdc/model".RowChangedEvent) as *event.DMLEvent value in return statement
|
|
Integration Build
Process completed with exit code 2.
|
|
Upload test logs
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|
Loading