Skip to content

Commit 0ce238d

Browse files
committed
fix failing lint and avro coverage test
1 parent 271f445 commit 0ce238d

2 files changed

Lines changed: 9 additions & 1 deletion

File tree

flow/connectors/mysql/qvalue_convert_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ func TestQkindFromMysqlColumnType_Set(t *testing.T) {
6767
}{
6868
{"with metadata maps SET to String", true, shared.InternalVersion_Latest, types.QValueKindString},
6969
{"without metadata, before gate maps SET to String", false, shared.InternalVersion_MySQL5ConvertSetsToInts - 1, types.QValueKindString},
70-
{"without metadata, gating version maps SET to Uint64Set", false, shared.InternalVersion_MySQL5ConvertSetsToInts, types.QValueKindUint64Set},
70+
{"without metadata, gate maps SET to Uint64Set", false, shared.InternalVersion_MySQL5ConvertSetsToInts, types.QValueKindUint64Set},
7171
{"without metadata, latest maps SET to Uint64Set", false, shared.InternalVersion_Latest, types.QValueKindUint64Set},
7272
} {
7373
t.Run(tc.name, func(t *testing.T) {

flow/model/qrecord_avro_size_test.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,14 @@ func TestAvroSizeComputation(t *testing.T) {
275275
return types.QValueUint16Enum{Val: uint16(rand.IntN(65536))}
276276
},
277277
},
278+
{
279+
name: "uint64set",
280+
kind: types.QValueKindUint64Set,
281+
numRecords: 10_000,
282+
genValue: func() types.QValue {
283+
return types.QValueUint64Set{Val: rand.Uint64()}
284+
},
285+
},
278286
{
279287
name: "timestamp",
280288
kind: types.QValueKindTimestamp,

0 commit comments

Comments
 (0)