- 15 6月, 2021 40 次提交
-
-
由 neza2017 提交于
* fix msgstream Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * fix asconsumer Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 sunby 提交于
* Remove redundant session startup Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Register datanode after start success Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * fix meta snap shot Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * fix datanode message stream channel Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * Fix bugs when drop empty collection Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Fix bug of getting pchan statistics from task scheduler Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * Fix i/dist/dataservice test code Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * Fix epoch lifetime not applied Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * fix datanode flowgraph dd node Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * Fix handle datanode timetick bug Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Remove repack function of dml stream Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * fix proxynode Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Apply extended seal policy Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * add check for time tick Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * fix check Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Fix the repack function of dml stream Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * Fix the bug when send statistics of pchan Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * Fix the repack function when craete dml stream Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * fix bugs Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * fix describe collection Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Fix bug when send timestamp statistics Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * fix data node Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Add length check before flush request Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * add log for data node Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Fix SaveBinlog bugs Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Add more log in datanode Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * Put SegmentState.Flushing as the last one in enum to fit the client Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Fix params in GetInsertBinlogPaths Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Rename policy Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Remove unused ddl functions and fields Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * Remove pchan when drop collection Signed-off-by: Ndragondriver <jiquan.long@zilliz.com> * Add balanced assignment policy Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * fix master ut Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Add lock in session manager Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * add log for debug Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * Fix some logic bug and typo Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * Fix recover bugs Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Get collection scheme of a specific timestamp Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * Change CheckPoint to SegmentInfo in VchannelInfo Signed-off-by: Nsunby <bingyi.sun@zilliz.com> * Recover Unflushed segment numOfRows Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * Fix dataservice unit tests Signed-off-by: Nsunby <bingyi.sun@zilliz.com> Co-authored-by: Nyefu.chen <yefu.chen@zilliz.com> Co-authored-by: Nyangxuan <xuan.yang@zilliz.com> Co-authored-by: Ndragondriver <jiquan.long@zilliz.com> Co-authored-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 XuanYang-cn 提交于
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 sunby 提交于
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 XuanYang-cn 提交于
* Destroy DataNode when drop collections Signed-off-by: Nyangxuan <xuan.yang@zilliz.com> * golanci-lint Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> Co-authored-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 sunby 提交于
When loading a partition, QueryNode fetches the binlogs need to be loaded and the channels needed to be watched by GetRecoveryInfo Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 godchen 提交于
Signed-off-by: Ngodchen <qingxiang.chen@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 sunby 提交于
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 Cai Yudong 提交于
* send dd msg to dml channel Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com> * add dml_channels.go Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com> * fix race Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com>
-
由 sunby 提交于
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 XuanYang-cn 提交于
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>
-
由 sunby 提交于
Add numRows to segmentStatus and Rename SegmentAllocator to SegmentManager. Remove SegmentAllocStats. Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 godchen 提交于
Signed-off-by: Ngodchen <qingxiang.chen@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 neza2017 提交于
* fix master unitttest Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * tt Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * fix master ut Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 XuanYang-cn 提交于
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>
-
由 XuanYang-cn 提交于
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>
-
由 sunby 提交于
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 neza2017 提交于
Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 dragondriver 提交于
Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
-
由 godchen 提交于
Signed-off-by: Ngodchen <qingxiang.chen@zilliz.com>
-
由 dragondriver 提交于
Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
-
由 congqixia 提交于
* Add dataservice metrics with grpc prometheus middleware Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com> * register server metrics Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 sunby 提交于
Datanode send `SaveBinlogPath` request after every segment flush finish with the binlog paths and dml/ddl position. But the flush of segments is not sorted. So we sort the segments according to segment id and find the largest segment id with not nil dml position which is the position of the msgstream to recover. Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 dragondriver 提交于
Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
-
由 Cai Yudong 提交于
* remove proxy service Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * remove time sync Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * remove proxy service Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * remove proxy service Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * remove proxy service Signed-off-by: Nyefu.chen <yefu.chen@zilliz.com> * remove proxy service from distributed/masterservice Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com> * fix unittest Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com> * fix static-check Signed-off-by: Nyudong.cai <yudong.cai@zilliz.com> Co-authored-by: Nyefu.chen <yefu.chen@zilliz.com>
-
由 congqixia 提交于
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
-
由 dragondriver 提交于
Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
-
由 XuanYang-cn 提交于
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>
-