From c96203ce45826c6d4d1c1a6264f8ea4ac4f3a774 Mon Sep 17 00:00:00 2001 From: Pawel Czajka Date: Tue, 21 Jan 2025 16:16:19 +0100 Subject: [PATCH] fixes --- .../kafkaschemaless/BaseKafkaJsonSchemalessItSpec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/engine/flink/tests/src/test/scala/pl/touk/nussknacker/defaultmodel/kafkaschemaless/BaseKafkaJsonSchemalessItSpec.scala b/engine/flink/tests/src/test/scala/pl/touk/nussknacker/defaultmodel/kafkaschemaless/BaseKafkaJsonSchemalessItSpec.scala index 4afe06bb747..a66cf68391f 100644 --- a/engine/flink/tests/src/test/scala/pl/touk/nussknacker/defaultmodel/kafkaschemaless/BaseKafkaJsonSchemalessItSpec.scala +++ b/engine/flink/tests/src/test/scala/pl/touk/nussknacker/defaultmodel/kafkaschemaless/BaseKafkaJsonSchemalessItSpec.scala @@ -62,7 +62,7 @@ abstract class BaseKafkaJsonSchemalessItSpec extends FlinkWithKafkaSuite { } } - def shouldRoundTripPlainMessageWithoutProvidedSchema() { + def shouldRoundTripPlainMessageWithoutProvidedSchema(): Unit = { val inputTopic = "input-topic-without-schema-plain" val outputTopic = "output-topic-without-schema-plain"