From 60e1d1e529334c795c5bc37b5fbda40e33b78e67 Mon Sep 17 00:00:00 2001 From: David Kornel Date: Tue, 10 Sep 2024 09:39:56 +0200 Subject: [PATCH] Enable checkstyle for test sources Signed-off-by: David Kornel --- pom.xml | 1 + src/test/java/io/streams/e2e/Abstract.java | 4 ++++ src/test/java/io/streams/e2e/dummy/DummyST.java | 4 ++++ .../java/io/streams/e2e/flink/sql/SqlExampleST.java | 10 ++++++++-- 4 files changed, 17 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index a9ca8c3..e09e671 100644 --- a/pom.xml +++ b/pom.xml @@ -351,6 +351,7 @@ true true + true .checkstyle/checkstyle.xml .checkstyle/suppressions.xml 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"));