Martijn Visser created FLINK-32353:
--------------------------------------
Summary: Make Cassandra connector compatible with Flink 1.18
Key: FLINK-32353
URL: https://issues.apache.org/jira/browse/FLINK-32353
Project: Flink
Issue Type: Improvement
Components: Connectors / Cassandra
Reporter: Martijn Visser
The current Cassandra connector in {{main}} fails when testing against Flink
1.18-SNAPSHOT
{code:java}
Error: Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 8.1 s
<<< FAILURE! - in org.apache.flink.architecture.rules.ITCaseRules
Error: ITCaseRules.ITCASE_USE_MINICLUSTER Time elapsed: 0.025 s <<< FAILURE!
java.lang.AssertionError:
Architecture Violation [Priority: MEDIUM] - Rule 'ITCASE tests should use a
MiniCluster resource or extension' was violated (1 times):
org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase does
not satisfy: only one of the following predicates match:
* reside in a package 'org.apache.flink.runtime.*' and contain any fields that
are static, final, and of type InternalMiniClusterExtension and annotated with
@RegisterExtension
* reside outside of package 'org.apache.flink.runtime.*' and contain any fields
that are static, final, and of type MiniClusterExtension and annotated with
@RegisterExtension or are , and of type MiniClusterTestEnvironment and
annotated with @TestEnv
* reside in a package 'org.apache.flink.runtime.*' and is annotated with
@ExtendWith with class InternalMiniClusterExtension
* reside outside of package 'org.apache.flink.runtime.*' and is annotated with
@ExtendWith with class MiniClusterExtension
or contain any fields that are public, static, and of type
MiniClusterWithClientResource and final and annotated with @ClassRule or
contain any fields that is of type MiniClusterWithClientResource and public and
final and not static and annotated with @Rule
{code}
https://github.com/apache/flink-connector-cassandra/actions/runs/5276835802/jobs/9544092571#step:13:811
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
