[EXPORTER] fix typo: targeOffset -> targetOffset (#1831)

opensource4you · Jul 13, 2023 · d647b4c · d647b4c
1 parent 55c83d0
commit d647b4c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/connector/src/main/java/org/astraea/connector/backup/Exporter.java b/connector/src/main/java/org/astraea/connector/backup/Exporter.java
@@ -373,7 +373,7 @@ protected void put(List<Record<byte[], byte[]>> records) {
     }
 
     protected boolean isValid(Record<byte[], byte[]> r) {
-      var targetOffset = targeOffset(r);
+      var targetOffset = targetOffset(r);
 
       // If the target offset exists and the record's offset is less than the target offset,
       // set the seek offset to the target offset and return false.
@@ -394,7 +394,7 @@ protected boolean isValid(Record<byte[], byte[]> r) {
      *     is not found.
      */
     // visible for test
-    protected Optional<Long> targeOffset(Record<byte[], byte[]> r) {
+    protected Optional<Long> targetOffset(Record<byte[], byte[]> r) {
       var topicMap = this.offsetForTopicPartition.get(r.topic());
 
       // If we are unable to obtain the target offset from the 'offsetForTopicPartition' map,

diff --git a/connector/src/test/java/org/astraea/connector/backup/ExporterTest.java b/connector/src/test/java/org/astraea/connector/backup/ExporterTest.java
@@ -937,11 +937,11 @@ void testIsValid() {
               .timestamp(System.currentTimeMillis())
               .build();
 
-      Assertions.assertFalse(task.targeOffset(record1).isPresent());
-      Assertions.assertEquals(100, task.targeOffset(record2).orElse(null));
-      Assertions.assertEquals(200, task.targeOffset(record3).orElse(null));
-      Assertions.assertEquals(200, task.targeOffset(record4).orElse(null));
-      Assertions.assertFalse(task.targeOffset(record5).isPresent());
+      Assertions.assertFalse(task.targetOffset(record1).isPresent());
+      Assertions.assertEquals(100, task.targetOffset(record2).orElse(null));
+      Assertions.assertEquals(200, task.targetOffset(record3).orElse(null));
+      Assertions.assertEquals(200, task.targetOffset(record4).orElse(null));
+      Assertions.assertFalse(task.targetOffset(record5).isPresent());
 
       Assertions.assertTrue(task.isValid(record1));
       Assertions.assertFalse(task.isValid(record2));