File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
ydb/library/yql/dq/runtime Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -105,6 +105,9 @@ class TDqOutputChannel : public IDqOutputChannel {
105
105
}
106
106
107
107
if (!MutableSettings.IsLocalChannel && BlockSplitter && BlockSplitter->ShouldSplitItem (values, width)) {
108
+ if (Packer.PackedSizeEstimate ()) {
109
+ TryPack (/* force */ true );
110
+ }
108
111
for (auto && data : BlockSplitter->SplitItem (values, width)) {
109
112
DoPushBlock (std::move (data));
110
113
}
@@ -337,7 +340,7 @@ class TDqOutputChannel : public IDqOutputChannel {
337
340
338
341
TChunkedBuffer FinishPackAndCheckSize () {
339
342
TChunkedBuffer result = Packer.Finish ();
340
- if (result.Size () > ChunkSizeLimit) {
343
+ if (!MutableSettings. IsLocalChannel && result.Size () > ChunkSizeLimit) {
341
344
// TODO: may relax requirement if OOB transport is enabled
342
345
ythrow TDqOutputChannelChunkSizeLimitExceeded () << " Row data size is too big: "
343
346
<< result.Size () << " bytes, exceeds limit of " << ChunkSizeLimit << " bytes" ;
You can’t perform that action at this time.
0 commit comments