[FLINK-25851] CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP

• Type: Technical Debt
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.14.4, 1.15.0, 1.13.7
• Component/s: Connectors / Cassandra
• Labels: pull-request-available test-stability
• Assignee: Etienne Chauchot
• Reporter: Etienne Chauchot
• Created: 27/Jan/22 10:52
• Updated: 22/Feb/22 10:06
• Resolved: 21/Feb/22 17:34

Description

It happens even if the whole keyspace is dropped in a BeforeClass method and the table noticed in the stacktrace is dropped in an After method and this after method is executed even in case of retrials through the Rule.

Jan 24 20:21:33 com.datastax.driver.core.exceptions.AlreadyExistsException: Table flink.batches already exists
Jan 24 20:21:33 at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:111)
Jan 24 20:21:33 at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
Jan 24 20:21:33 at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
Jan 24 20:21:33 at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
Jan 24 20:21:33 at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
Jan 24 20:21:33 at org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testRetrialAndDropTables(CassandraConnectorITCase.java:554)
Jan 24 20:21:33 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
Jan 24 20:21:33 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Jan 24 20:21:33 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Jan 24 20:21:33 at java.lang.reflect.Method.invoke(Method.java:498)
Jan 24 20:21:33 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Jan 24 20:21:33 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Jan 24 20:21:33 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
Jan 24 20:21:33 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Jan 24 20:21:33 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Jan 24 20:21:33 at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Jan 24 20:21:33 at org.apache.flink.testutils.junit.RetryRule$RetryOnExceptionStatement.evaluate(RetryRule.java:192)
Jan 24 20:21:33 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Jan 24 20:21:33 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
Jan 24 20:21:33 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
Jan 24 20:21:33 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
Jan 24 20:21:33 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
Jan 24 20:21:33 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
Jan 24 20:21:33 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
Jan 24 20:21:33 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
Jan 24 20:21:33 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
Jan 24 20:21:33 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
Jan 24 20:21:33 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
Jan 24 20:21:33 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
Jan 24 20:21:33 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
 
cf: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30050&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&s=ae4f8708-9994-57d3-c2d7-b892156e7812&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d&l=11999

Issue Links

• depends upon: FLINK-25147 Migrate cassandra tests to test containers
• is duplicated by: FLINK-24844 CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
• is duplicated by: FLINK-25165 CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure
• is duplicated by: FLINK-25674 CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP
• is related to: FLINK-24844 CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
• is related to: FLINK-25165 CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure
• is related to: FLINK-25674 CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP
• links to: GitHub Pull Request #18544