Fixes and cleaning

TouK · Nov 4, 2024 · c700736 · c700736
1 parent a1ab027
commit c700736
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...pl/touk/nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordSerializerSpec.scala b/...pl/touk/nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordSerializerSpec.scala
@@ -70,7 +70,7 @@ class ConsumerRecordSerializerSpec extends AnyFunSuite with Matchers with TableD
   }
 
   private def createConsumerRecord[K, V](key: K, value: V): ConsumerRecord[K, V] = {
-    val timestampTypes = List.from(TimestampType.values())
+    val timestampTypes = TimestampType.values().toList
     val timestampType  = timestampTypes(Random.nextInt(timestampTypes.length))
 
     val leaderEpoch =
@@ -82,8 +82,6 @@ class ConsumerRecordSerializerSpec extends AnyFunSuite with Matchers with TableD
       headers
     }
 
-    val t = Random.nextString()
-
     new ConsumerRecord[K, V](
       Random.nextString(),
       Random.nextInt(),