[
https://issues.apache.org/jira/browse/FLINK-38213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-38213:
-------------------------------
Description:
Refer to
https://github.com/apache/flink-cdc/actions/runs/16805137983/job/47644291132?pr=4082.
Error message:
Error: FlussE2eITCase.testMySqlToFluss:191->validateSinkResult:323
{code:java}
Expecting actual:
[]
to contain exactly in any order:
["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
{"coordinates":[1,1],"type":"Point","srid":0}",
"102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
{"coordinates":[2,2],"type":"Point","srid":0}",
"103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from #40
to #3, 0.8, red, {"key3": "value3"},
{"coordinates":[3,3],"type":"Point","srid":0}",
"104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
{"coordinates":[4,4],"type":"Point","srid":0}",
"105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
"v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
"106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
"107, rocks, box of assorted rocks, 5.3, null, null, null",
"108, jacket, water resistent black wind breaker, 0.1, null, null, null",
"109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
but could not find the following elements:
["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
{"coordinates":[1,1],"type":"Point","srid":0}",
"102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
{"coordinates":[2,2],"type":"Point","srid":0}",
"103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from #40
to #3, 0.8, red, {"key3": "value3"},
{"coordinates":[3,3],"type":"Point","srid":0}",
"104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
{"coordinates":[4,4],"type":"Point","srid":0}",
"105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
"v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
"106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
"107, rocks, box of assorted rocks, 5.3, null, null, null",
"108, jacket, water resistent black wind breaker, 0.1, null, null, null",
"109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
{code}
was:
Refer to
https://github.com/apache/flink-cdc/actions/runs/16805137983/job/47644291132?pr=4082.
Error message:
Error: FlussE2eITCase.testMySqlToFluss:191->validateSinkResult:323
Expecting actual:
[]
to contain exactly in any order:
["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
{"coordinates":[1,1],"type":"Point","srid":0}",
"102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
{"coordinates":[2,2],"type":"Point","srid":0}",
"103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from #40
to #3, 0.8, red, {"key3": "value3"},
{"coordinates":[3,3],"type":"Point","srid":0}",
"104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
{"coordinates":[4,4],"type":"Point","srid":0}",
"105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
"v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
"106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
"107, rocks, box of assorted rocks, 5.3, null, null, null",
"108, jacket, water resistent black wind breaker, 0.1, null, null, null",
"109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
but could not find the following elements:
["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
{"coordinates":[1,1],"type":"Point","srid":0}",
"102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
{"coordinates":[2,2],"type":"Point","srid":0}",
"103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from #40
to #3, 0.8, red, {"key3": "value3"},
{"coordinates":[3,3],"type":"Point","srid":0}",
"104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
{"coordinates":[4,4],"type":"Point","srid":0}",
"105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
"v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
"106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
"107, rocks, box of assorted rocks, 5.3, null, null, null",
"108, jacket, water resistent black wind breaker, 0.1, null, null, null",
"109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
> Failed case: FlussE2eITCase.testMySqlToFluss
> --------------------------------------------
>
> Key: FLINK-38213
> URL: https://issues.apache.org/jira/browse/FLINK-38213
> Project: Flink
> Issue Type: Sub-task
> Components: Flink CDC
> Affects Versions: cdc-3.4.0
> Reporter: Yanquan Lv
> Priority: Major
>
> Refer to
> https://github.com/apache/flink-cdc/actions/runs/16805137983/job/47644291132?pr=4082.
> Error message:
> Error: FlussE2eITCase.testMySqlToFluss:191->validateSinkResult:323
> {code:java}
> Expecting actual:
> []
> to contain exactly in any order:
> ["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
> {"coordinates":[1,1],"type":"Point","srid":0}",
> "102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
> {"coordinates":[2,2],"type":"Point","srid":0}",
> "103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from
> #40 to #3, 0.8, red, {"key3": "value3"},
> {"coordinates":[3,3],"type":"Point","srid":0}",
> "104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
> {"coordinates":[4,4],"type":"Point","srid":0}",
> "105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
> "v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
> "106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
> "107, rocks, box of assorted rocks, 5.3, null, null, null",
> "108, jacket, water resistent black wind breaker, 0.1, null, null, null",
> "109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
> but could not find the following elements:
> ["101, scooter, Small 2-wheel scooter, 3.14, red, {"key1": "value1"},
> {"coordinates":[1,1],"type":"Point","srid":0}",
> "102, car battery, 12V car battery, 8.1, white, {"key2": "value2"},
> {"coordinates":[2,2],"type":"Point","srid":0}",
> "103, 12-pack drill bits, 12-pack of drill bits with sizes ranging from
> #40 to #3, 0.8, red, {"key3": "value3"},
> {"coordinates":[3,3],"type":"Point","srid":0}",
> "104, hammer, 12oz carpenter's hammer, 0.75, white, {"key4": "value4"},
> {"coordinates":[4,4],"type":"Point","srid":0}",
> "105, hammer, 14oz carpenter's hammer, 0.875, red, {"k1": "v1", "k2":
> "v2"}, {"coordinates":[5,5],"type":"Point","srid":0}",
> "106, hammer, 16oz carpenter's hammer, 1.0, null, null, null",
> "107, rocks, box of assorted rocks, 5.3, null, null, null",
> "108, jacket, water resistent black wind breaker, 0.1, null, null, null",
> "109, spare tire, 24 inch spare tire, 22.2, null, null, null"]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
