fixed issue #2129 , Negative seek offset

2026-11-04 00:30:15 +08:00 · 2019-09-03 08:51:21 +08:00
parent 403fdf997c
commit ecdab76705
1 changed files with 4 additions and 1 deletions
--- a/common/src/main/java/com/alibaba/otter/canal/common/utils/FileUtils.java
+++ b/common/src/main/java/com/alibaba/otter/canal/common/utils/FileUtils.java
@@ -28,10 +28,13 @@ public class FileUtils {
                minIndex = 0;
            }

-            String line;
+            if (readIndex < 0) {
+                readIndex = 0;
+            }
            rf.seek(readIndex);
            int k = 0;
            int c = -1;
+            String line = null;
            while (readIndex > start) {
                if (k == l) {
                    break;