diff --git a/pom.xml b/pom.xml
index a9ca8c3..e09e671 100644
--- 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
index cc9fd9a..afe3ddb 100644
--- 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
index 8b5b363..0d3660e 100644
--- 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
index 8f72650..bdc4149 100644
--- 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"));