[
https://issues.apache.org/jira/browse/FLINK-25851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-25851:
-------------------------------------
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]
was:
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]
> CassandraConnectorITCase.testRetrialAndDropTables shows table already exists
> errors on AZP
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-25851
> URL: https://issues.apache.org/jira/browse/FLINK-25851
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Cassandra
> Affects Versions: 1.15.0
> Reporter: Etienne Chauchot
> Assignee: Etienne Chauchot
> Priority: Major
> Labels: test-stability
>
> 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]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
