Add import flushed field for bulk insert to catch flush done state

issue: milvus-io#65 Signed-off-by: Yuchen Gao <[email protected]>
soothing-rain · Dec 13, 2022 · 1734dfa · 1734dfa
1 parent 537b49f
commit 1734dfa
Show file tree

Hide file tree

Showing 4 changed files with 43 additions and 45 deletions.
diff --git a/go-api/commonpb/common.pb.go b/go-api/commonpb/common.pb.go
diff --git a/go-api/milvuspb/milvus.pb.go b/go-api/milvuspb/milvus.pb.go
diff --git a/go-api/schemapb/schema.pb.go b/go-api/schemapb/schema.pb.go
diff --git a/proto/common.proto b/proto/common.proto
@@ -281,7 +281,8 @@ enum ImportState {
     ImportPending = 0;              // the task in in pending list of rootCoord, waiting to be executed
     ImportFailed = 1;               // the task failed for some reason, get detail reason from GetImportStateResponse.infos
     ImportStarted = 2;              // the task has been sent to datanode to execute
-    ImportPersisted = 5;            // all data files have been parsed and data already persisted
+    ImportPersisted = 5;            // all data files have been parsed and all meta data already persisted, ready to be flushed.
+    ImportFlushed = 8;              // all segments are successfully flushed.
     ImportCompleted = 6;            // all indexes are successfully built and segments are able to be compacted as normal.
     ImportFailedAndCleaned = 7;     // the task failed and all segments it generated are cleaned up.
 }