|
@@ -3765,7 +3765,7 @@ public:
|
|
|
translator->translate(aBuilder, fieldCallback, diskRow);
|
|
|
// note the swapped parameters - left and right map to input and raw differently for JOIN vs FETCH
|
|
|
IHThorFetchArg *h = (IHThorFetchArg *) helper;
|
|
|
- return h->transform(rowBuilder, buf.toByteArray(), inputData, rawpos);
|
|
|
+ return h->transform(rowBuilder, aBuilder.getSelf(), inputData, rawpos);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
@@ -4458,7 +4458,7 @@ IMessagePacker *CRoxieKeyedJoinFetchActivity::process()
|
|
|
MemoryBufferBuilder aBuilder(buf, 0);
|
|
|
FetchVirtualFieldCallback fieldCallback(headerPtr->fpos);
|
|
|
translator->translate(aBuilder, fieldCallback, rawRHS);
|
|
|
- rawRHS = (const byte *) buf.toByteArray();
|
|
|
+ rawRHS = aBuilder.getSelf();
|
|
|
}
|
|
|
|
|
|
inputData = &headerPtr->rhsdata[0];
|