[FLINK-25165] CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.15.0
• Component/s: Connectors / Cassandra
• Labels: test-stability
• Assignee: Etienne Chauchot
• Reporter: Yun Gao
• Created: 04/Dec/21 08:51
• Updated: 21/Feb/22 17:34
• Resolved: 21/Feb/22 17:34

Description

Dec 03 15:44:22 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
Dec 03 15:44:22 	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
Dec 03 15:44:22 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
Dec 03 15:44:22 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
Dec 03 15:44:22 	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
Dec 03 15:44:22 	at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
Dec 03 15:44:22 	at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475)
Dec 03 15:44:22 	at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
Dec 03 15:44:22 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
Dec 03 15:44:22 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
Dec 03 15:44:22 	at java.lang.Thread.run(Thread.java:748)
Dec 03 15:44:22 Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Table flink.test already exists
Dec 03 15:44:22 	at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:85)
Dec 03 15:44:22 	at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
Dec 03 15:44:22 	at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:266)
Dec 03 15:44:22 	at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:246)
Dec 03 15:44:22 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:88)
Dec 03 15:44:22 	... 18 more
Dec 03 15:44:22 
Dec 03 15:44:24 [INFO] 
Dec 03 15:44:24 [INFO] Results:
Dec 03 15:44:24 [INFO] 
Dec 03 15:44:24 [ERROR] Errors: 
Dec 03 15:44:24 [ERROR]   CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink:469 » AlreadyExists ...
Dec 03 15:44:24 [INFO] 
Dec 03 15:44:24 [ERROR] Tests run: 17, Failures: 0, Errors: 1, Skipped: 0
Dec 03 15:44:24 [INFO] 
 

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27539&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d&l=11550

Issue Links

• depends upon: FLINK-25147 Migrate cassandra tests to test containers
• duplicates: FLINK-25851 CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP
• relates to: FLINK-24844 CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
• relates to: FLINK-25674 CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP
• relates to: FLINK-25851 CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP