yukun
eb818d05ab
Remove vector fields from output fields ( #6112 )
...
* Remove vector fields from output fields
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
* Add empty_collection error_code
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-06-25 16:52:11 +08:00
yukun
282d2624e0
Not remove rocksdb folder when close and init ( #5974 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-06-22 16:20:10 +08:00
neza2017
71ed21f9bf
Pass smoke test ( #5797 )
...
* pass smoke test
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
2021-06-16 16:59:50 +08:00
Cai Yudong
0f4bd50ce3
Support ETCD endpoints array ( #5755 )
2021-06-15 16:36:36 +08:00
sunby
189ac881f3
Fix bugs ( #5676 )
...
* Remove redundant session startup
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Register datanode after start success
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* fix meta snap shot
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* fix datanode message stream channel
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
* Fix bugs when drop empty collection
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Fix bug of getting pchan statistics from task scheduler
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* Fix i/dist/dataservice test code
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* Fix epoch lifetime not applied
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* fix datanode flowgraph dd node
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
* Fix handle datanode timetick bug
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Remove repack function of dml stream
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* fix proxynode
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Apply extended seal policy
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* add check for time tick
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* fix check
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Fix the repack function of dml stream
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* Fix the bug when send statistics of pchan
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* Fix the repack function when craete dml stream
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* fix bugs
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* fix describe collection
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Fix bug when send timestamp statistics
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* fix data node
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Add length check before flush request
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* add log for data node
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Fix SaveBinlog bugs
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Add more log in datanode
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
* Put SegmentState.Flushing as the last one in enum to fit the client
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Fix params in GetInsertBinlogPaths
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Rename policy
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Remove unused ddl functions and fields
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* Remove pchan when drop collection
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
* Add balanced assignment policy
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* fix master ut
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Add lock in session manager
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* add log for debug
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* Fix some logic bug and typo
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
* Fix recover bugs
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Get collection scheme of a specific timestamp
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
* Change CheckPoint to SegmentInfo in VchannelInfo
Signed-off-by: sunby <bingyi.sun@zilliz.com>
* Recover Unflushed segment numOfRows
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
* Fix dataservice unit tests
Signed-off-by: sunby <bingyi.sun@zilliz.com>
Co-authored-by: yefu.chen <yefu.chen@zilliz.com>
Co-authored-by: yangxuan <xuan.yang@zilliz.com>
Co-authored-by: dragondriver <jiquan.long@zilliz.com>
Co-authored-by: Congqi Xia <congqi.xia@zilliz.com>
2021-06-15 16:06:11 +08:00
godchen
91ef35bad4
Change receive msg logic ( #5605 )
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-06-15 16:04:48 +08:00
yukun
a3fb1356de
Fix rocksmq seek error ( #5432 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
In milvus-standalone, when seek is called, rocksmq won't put a
mutex in MsgMutex channel, which cause that the consume
process hang. So the seek function in rocksmq needs to
notify the consumer to consume.
2021-05-26 09:31:09 +00:00
Xiangyu Wang
82ccd4cec0
Rename module ( #4988 )
...
* Rename module
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-04-22 14:45:57 +08:00
Xiangyu Wang
c731e2df78
Add license header in util
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-04-19 13:42:47 +08:00
godchen
deba964590
Change name of kvBase
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-04-12 18:09:28 +08:00
yukun
964e7e0a28
Add unittest for mqclient
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-04-08 20:05:33 +08:00
yukun
18e0581d5c
Destroy readOptions after use
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-31 14:10:07 +08:00
yukun
604f96ed2b
Replace consumers map by sync.map
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-31 10:05:24 +08:00
sunby
f8e879b423
Fix high cpu usage in singlenode
...
Signed-off-by: sunby <bingyi.sun@zilliz.com>
2021-03-29 17:48:15 +08:00
yukun
c4f9a6f22b
Fix get position wrong
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-27 17:39:12 +08:00
yukun
432b53149b
Refactor msgstream
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-26 20:10:11 +08:00
yukun
85bc2a54f0
Fix load twice hang bug
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-25 18:49:41 +08:00
Xiangyu Wang
9ba9bf5e8a
Release memory after rocksdb.write()
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-03-19 20:20:32 +08:00
yukun
0823382876
Refactor rmq_msgstream
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-19 19:33:21 +08:00
yukun
207f6ae773
Fix rocksmq CreateConsumerGroup
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-16 21:37:25 +08:00
Xiangyu Wang
fc6472eb08
Implement RocksMQ client
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-03-13 11:46:50 +08:00
Xiangyu Wang
c875fdf913
Add logs in rocksmq
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-03-10 10:02:55 +08:00
yukun
0d499a9f99
Fix search waiting for seconds in singlenode
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-03-09 17:42:13 +08:00
sunby
ddddd65d10
Delete internal/errors package
...
Signed-off-by: sunby <bingyi.sun@zilliz.com>
2021-03-05 10:15:27 +08:00
BossZou
7893ebdb40
Fix test insert case
...
Signed-off-by: BossZou <yinghao.zou@zilliz.com>
2021-02-26 17:59:13 +08:00
Xiangyu Wang
38266b8569
Lock channel at produce and consume
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-02-25 17:44:29 +08:00
zhenshan.cao
0679954922
Refactor tso and global id allocator
...
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
2021-02-24 17:12:06 +08:00
yukun
e786ad6aa8
Fix inconsistency of produce msg and consume msg with rmq
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-02-22 16:34:15 +08:00
BossZou
7ac1821cf1
Add RocksMQ throughout test
...
Signed-off-by: BossZou <yinghao.zou@zilliz.com>
2021-02-20 18:30:37 +08:00
yukun
346b0a9549
Add unittest for RmqTtMsgStream
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-02-20 15:58:19 +08:00
groot
af3736aff6
Fix rocksmq bug
...
Signed-off-by: groot <yihua.mo@zilliz.com>
2021-02-18 14:13:55 +08:00
groot
833f1d49ab
Let singlenode use rocksmq
...
Signed-off-by: groot <yihua.mo@zilliz.com>
2021-02-09 15:57:10 +08:00
yukun
563a8d66ae
Add RmqTtMsgStream
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-02-07 15:10:13 +08:00
yukun
099220394e
Add rmq_msgstream unittest and fix bugs
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-02-06 11:39:12 +08:00
Xiangyu Wang
fd9e42d3ed
Update msgstream/unmarshal interface
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-02-03 17:30:10 +08:00
bigsheeper
abffdbff62
Remove partition tag
...
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2021-02-03 16:44:38 +08:00
yukun
35f6f4b7c2
Add consume in rmq_msgstream
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-02-03 15:18:54 +08:00
cai.zhang
f940cc455a
Add dockerfile for index
...
Signed-off-by: cai.zhang <cai.zhang@zilliz.com>
2021-01-26 09:38:40 +08:00
FluorineDog
a8fd6e7686
Enable drop index/field_data and extract info visitor
...
Signed-off-by: FluorineDog <guilin.gou@zilliz.com>
2021-01-25 18:59:44 +08:00
yukun
5600d06583
Add global_rmq
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-01-25 18:53:08 +08:00
BossZou
01267776d2
Fix rocksmq consume invalid currendID
...
Signed-off-by: BossZou <yinghao.zou@zilliz.com>
2021-01-23 10:15:57 +08:00
yukun
527c0c49df
Add rocksmq unittest with goroutines
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-01-20 16:46:58 +08:00
BossZou
4588342fa1
Add IdAlocator service
...
Signed-off-by: BossZou <yinghao.zou@zilliz.com>
2021-01-20 15:02:23 +08:00
XuanYang-cn
6a13386393
Add DataNode package
...
Signed-off-by: XuanYang-cn <xuan.yang@zilliz.com>
2021-01-19 11:37:16 +08:00
neza2017
1ce32d8775
Add master service
...
Signed-off-by: neza2017 <yefu.chen@zilliz.com>
2021-01-19 09:45:42 +08:00
yukun
b874a55c35
Add complex unittest for rocksmq
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-01-19 10:22:27 +08:00
yukun
3aca35b10c
Add rocksmq unittest
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-01-18 15:05:49 +08:00
yukun
44c75bdd2a
Add consume function in rocksmq
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-01-15 20:12:26 +08:00
BossZou
31178d6a5c
Add procude logic of RocksMQ
...
Signed-off-by: BossZou <yinghao.zou@zilliz.com>
2021-01-15 16:06:35 +08:00
Xiangyu Wang
52bd6abdf8
Change RocksMQ interface
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-01-13 17:26:57 +08:00