Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.15.0
-
None
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]
Attachments
Issue Links
- depends upon
-
FLINK-25147 Migrate cassandra tests to test containers
- Closed
- duplicates
-
FLINK-25851 CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP
- Closed
- relates to
-
FLINK-24844 CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
- Closed
-
FLINK-25674 CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP
- Closed
-
FLINK-25851 CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP
- Closed
The Cassandra tests are all unstable and would probably benefit from migrating to testcontainers. I've linked that ticket to this one.