diff --git a/src/sql/engine/cmd/ob_load_data_direct_impl.cpp b/src/sql/engine/cmd/ob_load_data_direct_impl.cpp
index 3ea8d493b8..cfef719c45 100644
--- a/src/sql/engine/cmd/ob_load_data_direct_impl.cpp
+++ b/src/sql/engine/cmd/ob_load_data_direct_impl.cpp
@@ -438,7 +438,7 @@ ObLoadDataDirectImpl::DataReader::DataReader()
     : allocator_("TLD_DataReader"),
       execute_ctx_(nullptr),
       file_reader_(nullptr),
-      end_offset_(0),
+      end_offset_(-1),
       read_raw_(false),
       is_iter_end_(false),
       is_inited_(false)
@@ -632,7 +632,7 @@ bool ObLoadDataDirectImpl::DataReader::is_end_file() const
   bool ret = false;
   if (file_reader_->eof()) {
     ret = true;
-  } else if (end_offset_ > 0) {
+  } else if (end_offset_ >= 0) {
     ret = file_reader_->get_offset() >= end_offset_;
   }
   return ret;