From e585f4f25da0822fe1ae7bc7acd290c063b2a8df Mon Sep 17 00:00:00 2001
From: Jin Diao <jin.diao@ericsson.com>
Date: Sat, 16 Apr 2022 00:55:07 +0800
Subject: [PATCH] [FLUME-3423]:Taildir source will throw unnecessay exception
 when restart agent

---
 .../flume/source/taildir/ReliableTaildirEventReader.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java b/flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java
index ae9583620a..d31111ba0c 100644
--- a/flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java
+++ b/flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java
@@ -92,8 +92,11 @@ private ReliableTaildirEventReader(Map<String, String> filePaths,
     this.fileNameHeader = fileNameHeader;
     updateTailFiles(skipToEnd);
 
-    logger.info("Updating position from position file: " + positionFilePath);
-    loadPositionFile(positionFilePath);
+    File positionFile = new File(positionFilePath);
+    if (positionFile.exists() && positionFile.isFile() && positionFile.length() != 0) {
+      logger.info("Updating position from position file: " + positionFilePath);
+      loadPositionFile(positionFilePath);
+    }
   }
 
   /**