yuxiqian commented on PR #3846:
URL: https://github.com/apache/flink-cdc/pull/3846#issuecomment-2579451321
Seems there are some implicit conflicts between #3815 and #3826.
```
inkPipelineComposerITCase
2025-01-09T08:28:20.4048553Z [ERROR]
org.apache.flink.cdc.composer.flink.FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder(SinkApi)[1]
Time elapsed: 3.333 s <<< FAILURE!
2025-01-09T08:28:20.4049940Z org.opentest4j.AssertionFailedError:
2025-01-09T08:28:20.4050135Z
2025-01-09T08:28:20.4050503Z expected: columns={`id` BIGINT,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4051315Z but was: columns={`id` BIGINT NOT NULL,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4052337Z at
sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
2025-01-09T08:28:20.4053350Z at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
2025-01-09T08:28:20.4054581Z at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
2025-01-09T08:28:20.4056716Z at
org.apache.flink.cdc.composer.flink.FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder(FlinkPipelineComposerITCase.java:1242)
2025-01-09T08:28:20.4058040Z at
java.lang.reflect.Method.invoke(Method.java:498)
2025-01-09T08:28:20.4058712Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4059680Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4060504Z at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2025-01-09T08:28:20.4061325Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4062120Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4062914Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4063721Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4064520Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4065320Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4066108Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4066815Z at
java.util.Iterator.forEachRemaining(Iterator.java:116)
2025-01-09T08:28:20.4067616Z at
java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
2025-01-09T08:28:20.4068510Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4074761Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4077893Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4078808Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4079858Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4080675Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4081572Z at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2025-01-09T08:28:20.4082520Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4083411Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4084420Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4085351Z at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2025-01-09T08:28:20.4086267Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4087427Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4088392Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4089531Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4090622Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4091480Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4092272Z at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2025-01-09T08:28:20.4093175Z at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2025-01-09T08:28:20.4094067Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4094976Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4095923Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4096870Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4097779Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4098638Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4099619Z at
java.util.ArrayList.forEach(ArrayList.java:1259)
2025-01-09T08:28:20.4100202Z at
java.util.ArrayList.forEach(ArrayList.java:1259)
2025-01-09T08:28:20.4100567Z
2025-01-09T08:28:20.4101651Z [ERROR]
org.apache.flink.cdc.composer.flink.FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder(SinkApi)[2]
Time elapsed: 3.322 s <<< FAILURE!
2025-01-09T08:28:20.4103104Z org.opentest4j.AssertionFailedError:
2025-01-09T08:28:20.4103420Z
2025-01-09T08:28:20.4104036Z expected: columns={`id` BIGINT,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4105440Z but was: columns={`id` BIGINT NOT NULL,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4106625Z at
sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
2025-01-09T08:28:20.4107579Z at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
2025-01-09T08:28:20.4108313Z at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
2025-01-09T08:28:20.4109468Z at
org.apache.flink.cdc.composer.flink.FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder(FlinkPipelineComposerITCase.java:1242)
2025-01-09T08:28:20.4110221Z at
java.lang.reflect.Method.invoke(Method.java:498)
2025-01-09T08:28:20.4110618Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4111093Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4111578Z at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2025-01-09T08:28:20.4112046Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4112500Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4112950Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4113430Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4113911Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4114366Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2025-01-09T08:28:20.4114947Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4115385Z at
java.util.Iterator.forEachRemaining(Iterator.java:116)
2025-01-09T08:28:20.4115915Z at
java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
2025-01-09T08:28:20.4116490Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4116988Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4117497Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4118075Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4118869Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4119854Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4120350Z at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2025-01-09T08:28:20.4120822Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4121289Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4121781Z at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2025-01-09T08:28:20.4122664Z at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2025-01-09T08:28:20.4123755Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4124659Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4125480Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4126008Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4126512Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4126993Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4127477Z at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2025-01-09T08:28:20.4127983Z at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2025-01-09T08:28:20.4128477Z at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2025-01-09T08:28:20.4128970Z at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2025-01-09T08:28:20.4130052Z at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2025-01-09T08:28:20.4130579Z at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2025-01-09T08:28:20.4131077Z at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2025-01-09T08:28:20.4131553Z at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2025-01-09T08:28:20.4131957Z at
java.util.ArrayList.forEach(ArrayList.java:1259)
2025-01-09T08:28:20.4132278Z at
java.util.ArrayList.forEach(ArrayList.java:1259)
2025-01-09T08:28:20.4132483Z
2025-01-09T08:28:20.4477722Z [INFO]
2025-01-09T08:28:20.4478070Z [INFO] Results:
2025-01-09T08:28:20.4478384Z [INFO]
2025-01-09T08:28:20.4478678Z [ERROR] Failures:
2025-01-09T08:28:20.4480411Z [ERROR]
FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder:1242
2025-01-09T08:28:20.4481519Z expected: columns={`id` BIGINT,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4482804Z but was: columns={`id` BIGINT NOT NULL,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4483580Z [ERROR]
FlinkPipelineComposerITCase.testTransformMergingWithRouteChangeOrder:1242
2025-01-09T08:28:20.4484456Z expected: columns={`id` BIGINT,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
2025-01-09T08:28:20.4485274Z but was: columns={`id` BIGINT NOT NULL,`name`
STRING,`age` INT,`last_name` STRING,`description` STRING,`gender` STRING},
primaryKeys=id, options=()
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
