You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-07-30 19:23:07 +03:00
MCOL-4188 Return true to process the error message from PP in ExeMgr
This commit is contained in:
@ -707,6 +707,14 @@ bool BatchPrimitiveProcessorJL::countThisMsg(messageqcpp::ByteStream& in) const
|
|||||||
|
|
||||||
if (_hasScan && in.length() > offset)
|
if (_hasScan && in.length() > offset)
|
||||||
{
|
{
|
||||||
|
// This is a legitimate error message sent by PrimProc
|
||||||
|
// so we need to return to allow upper layer to throw an error
|
||||||
|
// if needed.
|
||||||
|
if (hdr->Status > 0)
|
||||||
|
{
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
if (data[offset] != 0)
|
if (data[offset] != 0)
|
||||||
offset += (data[offset + CP_FLAG_AND_LBID] * 2) + CP_FLAG_AND_LBID + 1; // skip the CP data with wide min/max values (16/32 bytes each)
|
offset += (data[offset + CP_FLAG_AND_LBID] * 2) + CP_FLAG_AND_LBID + 1; // skip the CP data with wide min/max values (16/32 bytes each)
|
||||||
else
|
else
|
||||||
|
Reference in New Issue
Block a user