remove redundant cast

apache · Sep 27, 2023 · db787b3 · db787b3
1 parent d4af947
commit db787b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rg/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerTest.java b/...rg/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerTest.java
@@ -84,7 +84,7 @@ public void testLatestOffsetsInitializer() {
         assertThat(offsets).hasSameSizeAs(partitions);
         assertThat(offsets.keySet()).containsAll(partitions);
         for (long offset : offsets.values()) {
-            assertThat(offset).isEqualTo((long) KafkaSourceTestEnv.NUM_RECORDS_PER_PARTITION);
+            assertThat(offset).isEqualTo(KafkaSourceTestEnv.NUM_RECORDS_PER_PARTITION);
         }
         assertThat(initializer.getAutoOffsetResetStrategy()).isEqualTo(OffsetResetStrategy.LATEST);
     }