mirror of https://gitee.com/bigwinds/arangodb
Merge branch 'devel' of https://github.com/arangodb/arangodb into devel
This commit is contained in:
commit
e37ac1c4f8
|
@ -312,7 +312,7 @@ int SortedCollectBlock::getOrSkipSome(size_t atLeast, size_t atMost,
|
||||||
// we already had a group, check if the group has changed
|
// we already had a group, check if the group has changed
|
||||||
size_t i = 0;
|
size_t i = 0;
|
||||||
|
|
||||||
if (_pos > 0) {
|
if (_pos > 0 && !skipping) {
|
||||||
// re-use already copied AQLValues
|
// re-use already copied AQLValues
|
||||||
for (auto& it : _groupRegisters) {
|
for (auto& it : _groupRegisters) {
|
||||||
res->copyColValuesFromFirstRow(_pos, it.second);
|
res->copyColValuesFromFirstRow(_pos, it.second);
|
||||||
|
@ -345,7 +345,7 @@ int SortedCollectBlock::getOrSkipSome(size_t atLeast, size_t atMost,
|
||||||
// increase output row count
|
// increase output row count
|
||||||
++skipped;
|
++skipped;
|
||||||
|
|
||||||
if (skipped == atMost) {
|
if (skipped == atMost && !skipping) {
|
||||||
// output is full
|
// output is full
|
||||||
// do NOT advance input pointer
|
// do NOT advance input pointer
|
||||||
result = res.release();
|
result = res.release();
|
||||||
|
|
|
@ -50,7 +50,7 @@
|
||||||
using namespace arangodb::basics;
|
using namespace arangodb::basics;
|
||||||
using namespace arangodb::rest;
|
using namespace arangodb::rest;
|
||||||
|
|
||||||
static double const CL_DEFAULT_TIMEOUT = 90.0;
|
static double const CL_DEFAULT_TIMEOUT = 120.0;
|
||||||
|
|
||||||
namespace {
|
namespace {
|
||||||
template<typename T>
|
template<typename T>
|
||||||
|
|
Loading…
Reference in New Issue