[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770274#comment-17770274 ]
Martijn Visser commented on FLINK-33104: ---------------------------------------- [~mason6345] I don't think we have to update to JUnit5 in order to get this fixed. IIRC, we had a similar problem with the Cassandra connector on this topic and we managed to get it fixed there too. It's more because Flink 1.18 has an updated version of Archunit, while the rules that we have are still build for a lower version of Archunit in general. [~echauchot] do you recall this situation we had with the Cassandra connector? > Nightly run for Flink Kafka connector fails due to architecture tests failing > ----------------------------------------------------------------------------- > > Key: FLINK-33104 > URL: https://issues.apache.org/jira/browse/FLINK-33104 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: kafka-3.1.0 > Reporter: Martijn Visser > Priority: Blocker > > {code:java} > 2023-09-17T00:29:07.1675694Z [WARNING] Tests run: 18, Failures: 0, Errors: 0, > Skipped: 9, Time elapsed: 308.532 s - in > org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerMigrationTest > 2023-09-17T00:29:07.5171608Z [INFO] > 2023-09-17T00:29:07.5172360Z [INFO] Results: > 2023-09-17T00:29:07.5172773Z [INFO] > 2023-09-17T00:29:07.5173139Z [ERROR] Failures: > 2023-09-17T00:29:07.5174181Z [ERROR] Architecture Violation [Priority: > MEDIUM] - Rule 'ITCASE tests should use a MiniCluster resource or extension' > was violated (13 times): > 2023-09-17T00:29:07.5176050Z > org.apache.flink.connector.kafka.sink.FlinkKafkaInternalProducerITCase does > not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5177452Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5179831Z * 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 > 2023-09-17T00:29:07.5181277Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5182154Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5182951Z 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 > 2023-09-17T00:29:07.5183906Z > org.apache.flink.connector.kafka.sink.KafkaSinkITCase does not satisfy: only > one of the following predicates match: > 2023-09-17T00:29:07.5184769Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5185812Z * 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 > 2023-09-17T00:29:07.5186880Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5187929Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5189073Z 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 > 2023-09-17T00:29:07.5190076Z > org.apache.flink.connector.kafka.sink.KafkaTransactionLogITCase does not > satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5190946Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5191983Z * 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 > 2023-09-17T00:29:07.5192845Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5193532Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5194300Z 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 > 2023-09-17T00:29:07.5195091Z > org.apache.flink.connector.kafka.sink.KafkaWriterITCase does not satisfy: > only one of the following predicates match: > 2023-09-17T00:29:07.5195938Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5197014Z * 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 > 2023-09-17T00:29:07.5197882Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5198708Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5199526Z 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 > 2023-09-17T00:29:07.5200429Z > org.apache.flink.connector.kafka.source.KafkaSourceITCase does not satisfy: > only one of the following predicates match: > 2023-09-17T00:29:07.5201301Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5202422Z * 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 > 2023-09-17T00:29:07.5203294Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5203980Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5204750Z 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 > 2023-09-17T00:29:07.5205567Z > org.apache.flink.connector.kafka.source.KafkaSourceLegacyITCase does not > satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5206438Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5207478Z * 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 > 2023-09-17T00:29:07.5208345Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5209438Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5210190Z 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 > 2023-09-17T00:29:07.5211069Z > org.apache.flink.streaming.connectors.kafka.FlinkKafkaInternalProducerITCase > does not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5211998Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5213039Z * 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 > 2023-09-17T00:29:07.5213907Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5214592Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5215353Z 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 > 2023-09-17T00:29:07.5216499Z > org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase does not > satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5217439Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5218537Z * 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 > 2023-09-17T00:29:07.5219405Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5220147Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5220897Z 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 > 2023-09-17T00:29:07.5221665Z > org.apache.flink.streaming.connectors.kafka.KafkaITCase does not satisfy: > only one of the following predicates match: > 2023-09-17T00:29:07.5222482Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5223483Z * 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 > 2023-09-17T00:29:07.5224321Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5224987Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5225735Z 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 > 2023-09-17T00:29:07.5226572Z > org.apache.flink.streaming.connectors.kafka.KafkaProducerAtLeastOnceITCase > does not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5227455Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5228461Z * 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 > 2023-09-17T00:29:07.5229301Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5229947Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5244058Z 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 > 2023-09-17T00:29:07.5244923Z > org.apache.flink.streaming.connectors.kafka.KafkaProducerExactlyOnceITCase > does not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5245874Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5247073Z * 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 > 2023-09-17T00:29:07.5247979Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5251868Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5252843Z 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 > 2023-09-17T00:29:07.5254009Z > org.apache.flink.streaming.connectors.kafka.shuffle.KafkaShuffleExactlyOnceITCase > does not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5255758Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5257289Z * 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 > 2023-09-17T00:29:07.5258312Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5259141Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5260667Z 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 > 2023-09-17T00:29:07.5262234Z > org.apache.flink.streaming.connectors.kafka.shuffle.KafkaShuffleITCase does > not satisfy: only one of the following predicates match: > 2023-09-17T00:29:07.5265345Z * reside in a package > 'org.apache.flink.runtime.*' and contain any fields that are static, final, > and of type InternalMiniClusterExtension and annotated with @RegisterExtension > 2023-09-17T00:29:07.5267243Z * 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 > 2023-09-17T00:29:07.5269228Z * reside in a package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > InternalMiniClusterExtension > 2023-09-17T00:29:07.5272222Z * reside outside of package > 'org.apache.flink.runtime.*' and is annotated with @ExtendWith with class > MiniClusterExtension > 2023-09-17T00:29:07.5274887Z 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 > 2023-09-17T00:29:07.5278016Z [INFO] > 2023-09-17T00:29:07.5278347Z [ERROR] Tests run: 386, Failures: 1, Errors: 0, > Skipped: 31 > {code} > https://github.com/apache/flink-connector-kafka/actions/runs/6210384981/job/16858550802 -- This message was sent by Atlassian Jira (v8.20.10#820010)