add more consumer related code #1078
3AceShowHandintegration_test_mysql.yaml
on: pull_request
E2E Test Group 1
6m 6s
E2E Test Group 1 on 7.5
6m 10s
E2E Test Group 2
6m 1s
E2E Test Group 3
6m 0s
Failover E2E Test
6m 21s
Annotations
45 errors and 5 warnings
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3:
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
|
|
E2E Test Group 3
Process completed with exit code 2.
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2:
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
|
|
E2E Test Group 2
Process completed with exit code 2.
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1:
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
|
|
E2E Test Group 1
Process completed with exit code 2.
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5:
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
|
|
E2E Test Group 1 on 7.5
Process completed with exit code 2.
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test:
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
|
|
Failover E2E Test
Process completed with exit code 2.
|
|
E2E Test Group 3
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|
|
E2E Test Group 2
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|
|
E2E Test Group 1
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|
|
E2E Test Group 1 on 7.5
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|
|
Failover E2E Test
No files were found with the provided path: ./logs.tar.gz. No artifacts will be uploaded.
|