diff --git a/internal/datanode/importv2/scheduler.go b/internal/datanode/importv2/scheduler.go
index 9e9b8e61d4..edbd92f001 100644
--- a/internal/datanode/importv2/scheduler.go
+++ b/internal/datanode/importv2/scheduler.go
@@ -98,7 +98,7 @@ func (s *scheduler) Start() {
 			for taskID, fs := range futures {
 				err := conc.AwaitAll(fs...)
 				if err != nil {
-					return
+					continue
 				}
 				s.manager.Update(taskID, UpdateState(datapb.ImportTaskStateV2_Completed))
 				log.Info("preimport/import done", zap.Int64("taskID", taskID))
diff --git a/internal/util/importutilv2/parquet/util.go b/internal/util/importutilv2/parquet/util.go
index 6accba57c5..766f94419f 100644
--- a/internal/util/importutilv2/parquet/util.go
+++ b/internal/util/importutilv2/parquet/util.go
@@ -76,6 +76,9 @@ func CreateFieldReaders(ctx context.Context, fileReader *pqarrow.FileReader, sch
 			}
 		}
 		if !isConvertible(arrowType, dataType, isList) {
+			if isList {
+				return nil, WrapTypeErr(dataType.String(), pqField.Type.(*arrow.ListType).ElemField().Type.Name(), field)
+			}
 			return nil, WrapTypeErr(dataType.String(), pqField.Type.Name(), field)
 		}