Enable checkstyle for test sources (#41)

Signed-off-by: David Kornel <[email protected]>
streamshub · Sep 10, 2024 · ebf1539 · ebf1539
1 parent d26aa0b
commit ebf1539
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -351,6 +351,7 @@
                         <configuration>
                             <consoleOutput>true</consoleOutput>
                             <failsOnError>true</failsOnError>
+                            <includeTestSourceDirectory>true</includeTestSourceDirectory>
                             <configLocation>.checkstyle/checkstyle.xml</configLocation>
                             <suppressionsLocation>.checkstyle/suppressions.xml</suppressionsLocation>
                         </configuration>

diff --git a/src/test/java/io/streams/e2e/Abstract.java b/src/test/java/io/streams/e2e/Abstract.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright streamshub authors.
+ * License: Apache License 2.0 (see the file LICENSE or http://apache.org/licenses/LICENSE-2.0.html).
+ */
 package io.streams.e2e;
 
 import io.skodjob.testframe.annotations.ResourceManager;

diff --git a/src/test/java/io/streams/e2e/dummy/DummyST.java b/src/test/java/io/streams/e2e/dummy/DummyST.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright streamshub authors.
+ * License: Apache License 2.0 (see the file LICENSE or http://apache.org/licenses/LICENSE-2.0.html).
+ */
 package io.streams.e2e.dummy;
 
 import io.fabric8.kubernetes.api.model.NamespaceBuilder;

diff --git a/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java b/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright streamshub authors.
+ * License: Apache License 2.0 (see the file LICENSE or http://apache.org/licenses/LICENSE-2.0.html).
+ */
 package io.streams.e2e.flink.sql;
 
 import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
@@ -130,8 +134,10 @@ void testFlinkSqlExample() throws IOException {
         KubeResourceManager.getInstance().createResourceWithWait(
             strimziKafkaClients.consumerStrimzi()
         );
-        JobUtils.waitForJobSuccess(namespace, strimziKafkaClients.getConsumerName(), TestFrameConstants.GLOBAL_TIMEOUT_MEDIUM);
-        String consumerPodName = KubeResourceManager.getKubeClient().listPodsByPrefixInName(namespace, consumerName).get(0).getMetadata().getName();
+        JobUtils.waitForJobSuccess(namespace, strimziKafkaClients.getConsumerName(),
+            TestFrameConstants.GLOBAL_TIMEOUT_MEDIUM);
+        String consumerPodName = KubeResourceManager.getKubeClient().listPodsByPrefixInName(namespace, consumerName)
+            .get(0).getMetadata().getName();
 
         String log = KubeResourceManager.getKubeClient().getLogsFromPod(namespace, consumerPodName);
         assertTrue(log.contains("user-9"));