From 1734dfabe33a07f373f4f01a0c51958f4b02c4bc Mon Sep 17 00:00:00 2001 From: Yuchen Gao Date: Tue, 13 Dec 2022 22:15:15 +0800 Subject: [PATCH] Add import flushed field for bulk insert to catch flush done state issue: #65 Signed-off-by: Yuchen Gao --- go-api/commonpb/common.pb.go | 79 +++++++++++++++++++----------------- go-api/milvuspb/milvus.pb.go | 2 - go-api/schemapb/schema.pb.go | 4 -- proto/common.proto | 3 +- 4 files changed, 43 insertions(+), 45 deletions(-) diff --git a/go-api/commonpb/common.pb.go b/go-api/commonpb/common.pb.go index 7580df0..e585c3a 100644 --- a/go-api/commonpb/common.pb.go +++ b/go-api/commonpb/common.pb.go @@ -673,6 +673,7 @@ const ( ImportState_ImportFailed ImportState = 1 ImportState_ImportStarted ImportState = 2 ImportState_ImportPersisted ImportState = 5 + ImportState_ImportFlushed ImportState = 8 ImportState_ImportCompleted ImportState = 6 ImportState_ImportFailedAndCleaned ImportState = 7 ) @@ -682,6 +683,7 @@ var ImportState_name = map[int32]string{ 1: "ImportFailed", 2: "ImportStarted", 5: "ImportPersisted", + 8: "ImportFlushed", 6: "ImportCompleted", 7: "ImportFailedAndCleaned", } @@ -691,6 +693,7 @@ var ImportState_value = map[string]int32{ "ImportFailed": 1, "ImportStarted": 2, "ImportPersisted": 5, + "ImportFlushed": 8, "ImportCompleted": 6, "ImportFailedAndCleaned": 7, } @@ -1474,12 +1477,12 @@ func init() { func init() { proto.RegisterFile("common.proto", fileDescriptor_555bd8c177793206) } var fileDescriptor_555bd8c177793206 = []byte{ - // 2661 bytes of a gzipped FileDescriptorProto + // 2667 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x58, 0x49, 0x70, 0x63, 0x47, 0x19, 0x9e, 0x27, 0xc9, 0x8b, 0x5a, 0xb2, 0xdc, 0x6e, 0x7b, 0x3c, 0xca, 0x2c, 0x19, 0xc7, 0x24, 0x30, 0x88, 0x8c, 0x27, 0x99, 0x54, 0x01, 0x45, 0x55, 0x28, 0x6c, 0xc9, 0xf6, 0xa8, 0xe2, 0x0d, 0xc9, 0x13, 0x28, 0xaa, 0x60, 0xaa, 0xf5, 0xde, 0x6f, 0xa9, 0x67, 0x9e, 0x5e, 0x3f, 0x5e, 0xb7, - 0x3c, 0x56, 0x4e, 0x21, 0x40, 0x2e, 0x14, 0x55, 0x2c, 0x55, 0x9c, 0x39, 0x53, 0x90, 0x62, 0x87, + 0x3c, 0x56, 0x4e, 0x21, 0x40, 0x6e, 0x54, 0xb1, 0x54, 0x71, 0xa4, 0x38, 0x53, 0x90, 0x62, 0x87, 0x23, 0x3b, 0x09, 0xdb, 0x99, 0x1d, 0x8e, 0x70, 0x67, 0xcd, 0x4a, 0xfd, 0xdd, 0x6f, 0x93, 0x67, 0x02, 0x07, 0x6e, 0xaf, 0xbf, 0xff, 0xef, 0xff, 0xff, 0xfb, 0xef, 0x7f, 0xeb, 0x47, 0xaa, 0xae, 0x1c, 0x0e, 0x65, 0xb0, 0x16, 0x46, 0x52, 0x4b, 0xb6, 0x38, 0x14, 0xfe, 0xf1, 0x48, 0xd9, 0xd5, @@ -1512,8 +1515,8 @@ var fileDescriptor_555bd8c177793206 = []byte{ 0xf5, 0xec, 0x1b, 0x3e, 0xe3, 0x5a, 0x22, 0xd3, 0x6f, 0xb6, 0x4f, 0x68, 0x2c, 0x21, 0x4c, 0x04, 0xff, 0xd7, 0x70, 0xb4, 0x62, 0x52, 0x23, 0x3a, 0xf3, 0x72, 0x12, 0x60, 0x0d, 0xb2, 0x10, 0x0b, 0x0c, 0xf8, 0x10, 0x6e, 0x89, 0xc0, 0x83, 0x13, 0x73, 0x41, 0x53, 0x09, 0x2f, 0x1e, 0xa5, 0x8d, - 0x30, 0x7b, 0x94, 0xb0, 0x7b, 0x78, 0x95, 0xb9, 0xb0, 0xa9, 0x0e, 0x3d, 0xc5, 0xac, 0x1a, 0x5f, - 0x28, 0x93, 0x72, 0x5a, 0x0f, 0x58, 0x85, 0xcc, 0x74, 0x47, 0xae, 0x0b, 0x4a, 0xd1, 0x33, 0x6c, + 0x30, 0x7b, 0x94, 0xb0, 0x7b, 0x78, 0x95, 0xb9, 0xb0, 0xa9, 0x0e, 0x3d, 0xc5, 0xac, 0x1a, 0x9f, + 0x2f, 0x93, 0x72, 0x5a, 0x0f, 0x58, 0x85, 0xcc, 0x74, 0x47, 0xae, 0x0b, 0x4a, 0xd1, 0x33, 0x6c, 0x91, 0xcc, 0xdf, 0x0c, 0xe0, 0x24, 0x04, 0x57, 0x83, 0x67, 0x78, 0xa8, 0xc3, 0x16, 0xc8, 0x5c, 0x53, 0x06, 0x01, 0xb8, 0x7a, 0x8b, 0x0b, 0x1f, 0x3c, 0x5a, 0x60, 0x4b, 0x84, 0x1e, 0x40, 0x34, 0x14, 0x4a, 0x09, 0x19, 0xb4, 0x20, 0x10, 0xe0, 0xd1, 0x22, 0x3b, 0x47, 0x16, 0x9b, 0xd2, 0xf7, @@ -1558,7 +1561,7 @@ var fileDescriptor_555bd8c177793206 = []byte{ 0x1f, 0x17, 0xc8, 0x36, 0x85, 0x24, 0x0c, 0xa7, 0x10, 0x3c, 0x3a, 0x8d, 0x2e, 0xb2, 0x49, 0x84, 0xb4, 0x99, 0xc6, 0x7b, 0xc9, 0xfc, 0xa9, 0x79, 0x84, 0xcd, 0x92, 0x52, 0xac, 0x9a, 0x92, 0xea, 0x86, 0x08, 0x78, 0x34, 0xb6, 0x95, 0x8a, 0x7a, 0xe8, 0xbd, 0x2d, 0x5f, 0x72, 0x1d, 0x03, 0xd0, - 0xf8, 0xf4, 0x9c, 0x19, 0x08, 0xcc, 0xc6, 0x39, 0x52, 0xbe, 0x19, 0x78, 0x70, 0x24, 0x02, 0xf0, + 0xf8, 0xd4, 0x9c, 0x19, 0x08, 0xcc, 0xc6, 0x39, 0x52, 0xbe, 0x19, 0x78, 0x70, 0x24, 0x02, 0xf0, 0xe8, 0x19, 0x53, 0x41, 0x6c, 0xee, 0x65, 0xa9, 0x8c, 0xee, 0xae, 0xa1, 0x31, 0x39, 0x0c, 0xb0, 0x0c, 0xdc, 0xe0, 0x2a, 0x07, 0x1d, 0x61, 0x14, 0xb4, 0xcc, 0xb8, 0xd9, 0xcb, 0x6f, 0xef, 0x9b, 0x28, 0x18, 0xc8, 0xbb, 0x19, 0xa6, 0xe8, 0x00, 0x35, 0x6d, 0x83, 0xee, 0x8e, 0x95, 0x86, 0x61, @@ -1574,9 +1577,9 @@ var fileDescriptor_555bd8c177793206 = []byte{ 0xc9, 0xa3, 0xa3, 0x14, 0x7d, 0xdd, 0x61, 0x75, 0xb2, 0x88, 0xdb, 0x37, 0xb8, 0xcf, 0x03, 0x37, 0xe3, 0x7f, 0xc3, 0x61, 0x67, 0x09, 0x3d, 0xa5, 0x4e, 0xd1, 0x67, 0x0b, 0x8c, 0x26, 0x4e, 0x37, 0xc9, 0x45, 0xbf, 0x5c, 0x30, 0xbe, 0x8a, 0x19, 0x2d, 0xf6, 0x95, 0x02, 0xab, 0xd9, 0x9b, 0xb0, - 0xeb, 0x17, 0x0a, 0xac, 0x42, 0xa6, 0xdb, 0x81, 0x82, 0x48, 0xd3, 0xcf, 0x60, 0xd0, 0x4f, 0xdb, - 0x22, 0x4d, 0x3f, 0x8b, 0x69, 0x36, 0x65, 0x82, 0x9e, 0x7e, 0x0e, 0x07, 0x00, 0xd6, 0x01, 0x05, - 0x81, 0x97, 0x4b, 0x28, 0x45, 0x3f, 0x6f, 0x76, 0xd8, 0x0e, 0x4b, 0xff, 0x56, 0x34, 0xae, 0xc9, + 0xeb, 0x17, 0x0a, 0xac, 0x42, 0xa6, 0xdb, 0x81, 0x82, 0x48, 0xd3, 0x4f, 0x63, 0xd0, 0x4f, 0xdb, + 0x22, 0x4d, 0x3f, 0x83, 0x69, 0x36, 0x65, 0x82, 0x9e, 0x7e, 0x16, 0x07, 0x00, 0xd6, 0x01, 0x05, + 0x81, 0x97, 0x4b, 0x28, 0x45, 0x3f, 0x67, 0x76, 0xd8, 0x0e, 0x4b, 0xff, 0x56, 0x34, 0xae, 0xc9, 0xb7, 0xdb, 0xbf, 0x17, 0xd1, 0x84, 0x6d, 0xd0, 0x59, 0xba, 0xd3, 0x7f, 0x14, 0xd9, 0x79, 0x72, 0x36, 0xc1, 0x4c, 0xf3, 0x4b, 0x13, 0xfd, 0x9f, 0x45, 0x76, 0x91, 0x9c, 0xc3, 0x4e, 0x90, 0xc6, 0x01, 0x6e, 0x12, 0x4a, 0x0b, 0x57, 0xd1, 0x7f, 0x15, 0xd9, 0x05, 0xb2, 0xbc, 0x0d, 0x3a, 0xbd, @@ -1610,36 +1613,36 @@ var fileDescriptor_555bd8c177793206 = []byte{ 0x85, 0xc6, 0x07, 0x09, 0x6d, 0xca, 0x40, 0x09, 0xa5, 0x21, 0x70, 0xc7, 0x3b, 0x70, 0x0c, 0xbe, 0x69, 0xc7, 0x3a, 0x92, 0x41, 0x9f, 0x9e, 0x31, 0x8f, 0x19, 0x30, 0x8f, 0x12, 0xdb, 0xb4, 0x37, 0x70, 0x60, 0x31, 0x2f, 0x96, 0x1a, 0x21, 0x9b, 0xc7, 0x10, 0xe8, 0x11, 0xf7, 0xfd, 0x31, 0x2d, - 0xe2, 0xba, 0x39, 0x52, 0x5a, 0x0e, 0xc5, 0x33, 0xd8, 0xbb, 0x1b, 0x9f, 0x72, 0x48, 0xc5, 0x76, + 0xe2, 0xba, 0x39, 0x52, 0x5a, 0x0e, 0xc5, 0x33, 0xd8, 0xbb, 0x1b, 0x5f, 0x70, 0x48, 0xc5, 0x76, 0xe8, 0xd4, 0x34, 0xbb, 0x3c, 0x80, 0xc0, 0x13, 0x46, 0x38, 0x0e, 0xdc, 0x06, 0x8a, 0xc7, 0x0a, 0x27, 0x63, 0xea, 0x6a, 0x1e, 0x19, 0x0b, 0xcd, 0x3b, 0x23, 0xde, 0x17, 0x19, 0x3b, 0x3d, 0x3a, - 0x95, 0x81, 0xd9, 0x59, 0xa6, 0x71, 0xb2, 0xcc, 0x8b, 0x5b, 0x0f, 0xbc, 0xa6, 0x0f, 0x1c, 0x9b, - 0xf8, 0x4c, 0xe3, 0x3a, 0x21, 0xd9, 0x3b, 0xd3, 0xd8, 0x9a, 0xb5, 0xbc, 0x33, 0x78, 0xe2, 0x6d, - 0x5f, 0xf6, 0xb8, 0x4f, 0x1d, 0x1c, 0x1b, 0xcc, 0x85, 0x17, 0x1a, 0xcf, 0x4f, 0x91, 0xf9, 0x53, - 0xaf, 0x4a, 0x34, 0x39, 0x5d, 0xac, 0xfb, 0x78, 0x2b, 0x97, 0xc8, 0x03, 0x29, 0x72, 0xcf, 0x9c, - 0xe0, 0xe0, 0x24, 0x9a, 0x92, 0x4f, 0x0d, 0x0c, 0x05, 0x76, 0x99, 0x5c, 0xc8, 0x88, 0xf7, 0x8e, - 0x09, 0x58, 0x96, 0xeb, 0x29, 0xc3, 0xe9, 0x79, 0xa1, 0x84, 0xde, 0x4a, 0xa9, 0x98, 0xe9, 0xf6, - 0x0d, 0x98, 0x3d, 0x81, 0x6d, 0xcb, 0xa3, 0xd3, 0xf8, 0x2c, 0xcb, 0x6c, 0x4c, 0x43, 0x86, 0xce, - 0xa0, 0x1f, 0x53, 0x42, 0xdc, 0x8e, 0x66, 0x27, 0xc0, 0xb8, 0x2d, 0x95, 0xd1, 0xb9, 0x29, 0x88, - 0xf5, 0x28, 0x2b, 0x05, 0x04, 0x1f, 0x0b, 0xa7, 0x5c, 0x60, 0x6b, 0x4e, 0x65, 0x82, 0x62, 0xb0, - 0x16, 0x68, 0x2e, 0x7c, 0x5a, 0xc5, 0xc1, 0x68, 0xc2, 0x2f, 0x76, 0xc7, 0xdc, 0x84, 0xf2, 0xb8, - 0xc3, 0xd5, 0x70, 0x04, 0xca, 0xe6, 0x78, 0xd3, 0x1b, 0xe7, 0x27, 0x30, 0x53, 0xfb, 0x28, 0x9d, - 0x50, 0x97, 0x6b, 0xe2, 0x74, 0x61, 0xf2, 0xa0, 0x26, 0x48, 0x28, 0x9b, 0xf0, 0xae, 0xb5, 0x7b, - 0xff, 0x6e, 0x00, 0x91, 0x1a, 0x88, 0x90, 0x2e, 0x4e, 0x38, 0xcd, 0x96, 0x1f, 0x13, 0x17, 0x4b, - 0x13, 0xae, 0x40, 0xd3, 0xb3, 0x4d, 0x67, 0x27, 0x2f, 0xcc, 0x14, 0x80, 0x8c, 0xba, 0x3c, 0x41, - 0xdd, 0xe5, 0x01, 0xef, 0xe7, 0x14, 0x9e, 0x9b, 0x50, 0x98, 0xab, 0x3c, 0xf5, 0x46, 0x97, 0x94, - 0x4d, 0x0e, 0x99, 0xdf, 0x0b, 0x98, 0x34, 0x81, 0xc0, 0x1a, 0x28, 0x9e, 0x11, 0x49, 0x8e, 0xde, - 0x00, 0xee, 0xeb, 0xc1, 0x98, 0x3a, 0x38, 0x32, 0xaf, 0xf7, 0x02, 0x19, 0x0d, 0xb9, 0x4f, 0x0b, - 0x26, 0x7d, 0x35, 0x0f, 0xbc, 0x0d, 0xcc, 0xd0, 0x2a, 0x99, 0xed, 0x6a, 0x19, 0x86, 0xb8, 0xab, - 0xd4, 0x70, 0x6d, 0x77, 0xb0, 0xc9, 0x89, 0xef, 0x9a, 0x64, 0x91, 0x4e, 0xe9, 0x66, 0xf4, 0xcd, - 0xc3, 0x26, 0xc6, 0x9c, 0x09, 0x14, 0x3f, 0xec, 0x10, 0xbf, 0x48, 0xe6, 0x27, 0x50, 0x9c, 0xe6, - 0xdf, 0x23, 0xc9, 0x42, 0xfa, 0xf7, 0xe6, 0x16, 0x9c, 0xe8, 0x5b, 0xb2, 0x77, 0x9b, 0x5d, 0x5e, - 0xb3, 0x7f, 0x64, 0xd7, 0x92, 0x3f, 0xb2, 0x6b, 0xbb, 0xa0, 0x14, 0x3a, 0x23, 0x34, 0x91, 0x5d, - 0xff, 0xeb, 0x8c, 0xf9, 0x2d, 0xf5, 0xd0, 0xfd, 0x7f, 0x04, 0xe6, 0x7e, 0x33, 0x75, 0xe6, 0xc3, - 0xdc, 0x6a, 0xbf, 0x77, 0x7b, 0xe3, 0x88, 0xd4, 0x84, 0x4c, 0xf6, 0xf5, 0xa3, 0xd0, 0xdd, 0xa8, - 0x34, 0xcd, 0xbe, 0x03, 0x94, 0x71, 0xe0, 0x7c, 0xe8, 0xf1, 0xbe, 0xd0, 0x83, 0x51, 0x0f, 0xa5, - 0x5d, 0xb3, 0x6c, 0x57, 0x85, 0x4c, 0xbe, 0x8c, 0xa2, 0x6b, 0x7d, 0x79, 0x95, 0x87, 0xe2, 0x9a, - 0xd5, 0x17, 0xf6, 0xbe, 0xe8, 0x38, 0x5f, 0x2a, 0xd4, 0xda, 0xfb, 0x6b, 0xbb, 0x56, 0xea, 0x76, - 0x14, 0xba, 0xbd, 0x69, 0xc3, 0xfa, 0xc4, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x9e, 0x25, 0xcd, - 0xda, 0x80, 0x16, 0x00, 0x00, + 0x95, 0xf1, 0x25, 0xb3, 0xc2, 0x6c, 0xc6, 0x97, 0x1d, 0x6f, 0x1a, 0x87, 0xcd, 0xbc, 0x86, 0xf5, + 0xc0, 0x6b, 0xfa, 0xc0, 0xb1, 0xaf, 0xcf, 0x34, 0xae, 0x13, 0x92, 0x3d, 0x3d, 0x8d, 0xf9, 0x59, + 0x17, 0x3c, 0x83, 0x4e, 0xd8, 0xf6, 0x65, 0x8f, 0xfb, 0xd4, 0xc1, 0x49, 0xc2, 0xc4, 0x40, 0xa1, + 0xf1, 0xfc, 0x14, 0x99, 0x3f, 0xf5, 0xd0, 0xc4, 0x53, 0xa4, 0x8b, 0x75, 0x1f, 0x2f, 0xea, 0x12, + 0x79, 0x20, 0x45, 0xee, 0x19, 0x1d, 0x1c, 0x1c, 0x4e, 0x53, 0xf2, 0xa9, 0x19, 0xa2, 0xc0, 0x2e, + 0x93, 0x0b, 0x19, 0xf1, 0xde, 0xc9, 0x01, 0x2b, 0x75, 0x3d, 0x65, 0x38, 0x3d, 0x42, 0x94, 0xd0, + 0x31, 0x29, 0x15, 0x93, 0xdf, 0x3e, 0x0b, 0xb3, 0x57, 0xb1, 0xed, 0x82, 0x74, 0x1a, 0x5f, 0x6a, + 0x99, 0x8d, 0x69, 0x14, 0xd1, 0x19, 0xf4, 0x63, 0x4a, 0x88, 0x3b, 0xd4, 0xec, 0x04, 0x18, 0x77, + 0xaa, 0x32, 0x3a, 0x37, 0x05, 0xb1, 0x44, 0x65, 0xd5, 0x81, 0xe0, 0xfb, 0xe1, 0x94, 0x0b, 0x6c, + 0x19, 0xaa, 0x4c, 0x50, 0x0c, 0xd6, 0x02, 0xcd, 0x85, 0x4f, 0xab, 0x38, 0x2b, 0x4d, 0xf8, 0xc5, + 0xee, 0x98, 0x9b, 0x50, 0x1e, 0x37, 0xbd, 0x1a, 0x4e, 0x45, 0xd9, 0x68, 0x6f, 0xda, 0xe5, 0xfc, + 0x04, 0x66, 0xca, 0x21, 0xa5, 0x13, 0xea, 0x72, 0x7d, 0x9d, 0x2e, 0x4c, 0x1e, 0xd4, 0x04, 0x09, + 0x65, 0x13, 0xde, 0xb5, 0x76, 0xef, 0xdf, 0x0d, 0x20, 0x52, 0x03, 0x11, 0xd2, 0xc5, 0x09, 0xa7, + 0xd9, 0x8a, 0x64, 0xe2, 0x62, 0x69, 0xc2, 0x15, 0x68, 0x7a, 0xb6, 0xe9, 0xec, 0xe4, 0x85, 0x99, + 0x9a, 0x90, 0x51, 0x97, 0x27, 0xa8, 0xbb, 0x3c, 0xe0, 0xfd, 0x9c, 0xc2, 0x73, 0x13, 0x0a, 0x73, + 0xc5, 0xa8, 0xde, 0xe8, 0x92, 0xb2, 0x49, 0x2b, 0xf3, 0xc7, 0x01, 0xf3, 0x28, 0x10, 0x58, 0x16, + 0xc5, 0x33, 0x22, 0x49, 0xdb, 0x1b, 0xc0, 0x7d, 0x3d, 0x18, 0x53, 0x07, 0xa7, 0xe8, 0xf5, 0x5e, + 0x20, 0xa3, 0x21, 0xf7, 0x69, 0xc1, 0x64, 0xb4, 0xe6, 0x81, 0xb7, 0x81, 0x49, 0x5b, 0x25, 0xb3, + 0x5d, 0x2d, 0xc3, 0x10, 0x77, 0x95, 0x1a, 0xae, 0x6d, 0x18, 0x36, 0x5f, 0xf1, 0xa9, 0x93, 0x2c, + 0xd2, 0xc1, 0xdd, 0x4c, 0xc3, 0x79, 0xd8, 0xc4, 0x98, 0x33, 0x81, 0xe2, 0x87, 0x9d, 0xeb, 0x17, + 0xc9, 0xfc, 0x04, 0x8a, 0x03, 0xfe, 0x7b, 0x24, 0x59, 0x48, 0x7f, 0xe8, 0xdc, 0x82, 0x13, 0x7d, + 0x4b, 0xf6, 0x6e, 0xb3, 0xcb, 0x6b, 0xf6, 0x27, 0xed, 0x5a, 0xf2, 0x93, 0x76, 0x6d, 0x17, 0x94, + 0x42, 0x67, 0x84, 0x26, 0xb2, 0xeb, 0x7f, 0x9d, 0x31, 0x7f, 0xaa, 0x1e, 0xba, 0xff, 0xbf, 0xc1, + 0xdc, 0x9f, 0xa7, 0xce, 0x7c, 0x98, 0x5b, 0xed, 0xf7, 0x6e, 0x6f, 0x1c, 0x91, 0x9a, 0x90, 0xc9, + 0xbe, 0x7e, 0x14, 0xba, 0x1b, 0x95, 0xa6, 0xd9, 0x77, 0x80, 0x32, 0x0e, 0x9c, 0x0f, 0x3d, 0xde, + 0x17, 0x7a, 0x30, 0xea, 0xa1, 0xb4, 0x6b, 0x96, 0xed, 0xaa, 0x90, 0xc9, 0x97, 0x51, 0x74, 0xad, + 0x2f, 0xaf, 0xf2, 0x50, 0x5c, 0xb3, 0xfa, 0xc2, 0xde, 0x17, 0x1d, 0xe7, 0x4b, 0x85, 0x5a, 0x7b, + 0x7f, 0x6d, 0xd7, 0x4a, 0xdd, 0x8e, 0x42, 0xb7, 0x37, 0x6d, 0x58, 0x9f, 0xf8, 0x4f, 0x00, 0x00, + 0x00, 0xff, 0xff, 0x64, 0x74, 0xc7, 0xaa, 0x93, 0x16, 0x00, 0x00, } diff --git a/go-api/milvuspb/milvus.pb.go b/go-api/milvuspb/milvus.pb.go index 874b19d..0d25947 100644 --- a/go-api/milvuspb/milvus.pb.go +++ b/go-api/milvuspb/milvus.pb.go @@ -3823,7 +3823,6 @@ func (m *VectorIDs) GetPartitionNames() []string { type VectorsArray struct { // Types that are valid to be assigned to Array: - // // *VectorsArray_IdArray // *VectorsArray_DataArray Array isVectorsArray_Array `protobuf_oneof:"array"` @@ -3970,7 +3969,6 @@ type CalcDistanceResults struct { // num(op_left)*num(op_right) distance values, "HAMMIN" return integer distance // // Types that are valid to be assigned to Array: - // // *CalcDistanceResults_IntDist // *CalcDistanceResults_FloatDist Array isCalcDistanceResults_Array `protobuf_oneof:"array"` diff --git a/go-api/schemapb/schema.pb.go b/go-api/schemapb/schema.pb.go index 7554f09..d5749d6 100644 --- a/go-api/schemapb/schema.pb.go +++ b/go-api/schemapb/schema.pb.go @@ -555,7 +555,6 @@ func (m *StringArray) GetData() []string { type ScalarField struct { // Types that are valid to be assigned to Data: - // // *ScalarField_BoolData // *ScalarField_IntData // *ScalarField_LongData @@ -712,7 +711,6 @@ func (*ScalarField) XXX_OneofWrappers() []interface{} { type VectorField struct { Dim int64 `protobuf:"varint,1,opt,name=dim,proto3" json:"dim,omitempty"` // Types that are valid to be assigned to Data: - // // *VectorField_FloatVector // *VectorField_BinaryVector Data isVectorField_Data `protobuf_oneof:"data"` @@ -802,7 +800,6 @@ type FieldData struct { Type DataType `protobuf:"varint,1,opt,name=type,proto3,enum=milvus.proto.schema.DataType" json:"type,omitempty"` FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"` // Types that are valid to be assigned to Field: - // // *FieldData_Scalars // *FieldData_Vectors Field isFieldData_Field `protobuf_oneof:"field"` @@ -905,7 +902,6 @@ func (*FieldData) XXX_OneofWrappers() []interface{} { type IDs struct { // Types that are valid to be assigned to IdField: - // // *IDs_IntId // *IDs_StrId IdField isIDs_IdField `protobuf_oneof:"id_field"` diff --git a/proto/common.proto b/proto/common.proto index efd043e..6a327a7 100644 --- 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. }