fixed a bug

Kyligence · Oct 24, 2022 · ff62961 · ff62961
1 parent ab41ba7
commit ff62961
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/utils/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp b/utils/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp
@@ -66,7 +66,7 @@ SubstraitFileSource::SubstraitFileSource(DB::ContextPtr context_, const DB::Bloc
 
 DB::Chunk SubstraitFileSource::generate()
 {
-    while(current_file_index < files.size())
+    while(true)
     {
         if (!tryPrepareReader())
         {