Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25165

CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

Details

    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

      Attachments

        Issue Links

          Activity

            martijnvisser Martijn Visser added a comment -

            The Cassandra tests are all unstable and would probably benefit from migrating to testcontainers. I've linked that ticket to this one.

            martijnvisser Martijn Visser added a comment - The Cassandra tests are all unstable and would probably benefit from migrating to testcontainers. I've linked that ticket to this one.
            martijnvisser Martijn Visser added a comment -

            As can be seen in the umbrella ticket https://issues.apache.org/jira/browse/FLINK-25147 that Cassandra tests are now using the testcontainers. We're going to monitor the Cassandra tests until the new year and if no new occurences are popping up, we are closing this (and the other subtasks) as resolved

            martijnvisser Martijn Visser added a comment - As can be seen in the umbrella ticket https://issues.apache.org/jira/browse/FLINK-25147 that Cassandra tests are now using the testcontainers. We're going to monitor the Cassandra tests until the new year and if no new occurences are popping up, we are closing this (and the other subtasks) as resolved
            trohrmann Till Rohrmann added a comment -

            Fixed via FLINK-25147.

            trohrmann Till Rohrmann added a comment - Fixed via FLINK-25147 .
            echauchot Etienne Chauchot added a comment - - edited

            All pojo tests suffer from the same flakiness that should be fixed with 

            master: 153bb9b5fa04ae7de8aef22c346a1c342a376c59
            1.14: a03343682f2ca99b3b97572246c9b4a634752fa4

            Reopening, to monitor the flakiness after the above change

            echauchot Etienne Chauchot added a comment - - edited All pojo tests suffer from the same flakiness that should be fixed with  master: 153bb9b5fa04ae7de8aef22c346a1c342a376c59 1.14: a03343682f2ca99b3b97572246c9b4a634752fa4 Reopening, to monitor the flakiness after the above change

            People

              echauchot Etienne Chauchot
              gaoyunhaii Yun Gao
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: