Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[hotfix] fix ci failure. #3846

Merged
merged 2 commits into from
Jan 10, 2025
Merged

[hotfix] fix ci failure. #3846

merged 2 commits into from
Jan 10, 2025

Conversation

lvyanquan
Copy link
Contributor

Fix CI failure caused by #3644 which didn't contain the fix of #3760.

@lvyanquan lvyanquan mentioned this pull request Jan 9, 2025
Merged
@lvyanquan
Copy link
Contributor Author

Hi @leonardBang can you help to check about this?

@yuxiqian
Copy link
Contributor

yuxiqian commented Jan 9, 2025 •
edited
Loading

Seems there are some implicit conflicts between #3815 and #3826... Could @lvyanquan please fix this, too?

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=()

@lvyanquan
Copy link
Contributor Author

Seems there are some implicit conflicts between #3815 and #3826...

fixed.

@leonardBang leonardBang merged commit 7b01d9c into apache:master Jan 10, 2025
26 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@leonardBang leonardBang leonardBang approved these changes

Assignees
No one assigned
Labels
approved composer paimon-pipeline-connector reviewed
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
3 participants
@lvyanquan @yuxiqian @leonardBang