-
Notifications
You must be signed in to change notification settings - Fork 646
Add pragma to grace join runtime node with spilling #6253
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add pragma to grace join runtime node with spilling #6253
Conversation
This comment was marked as resolved.
This comment was marked as resolved.
This comment was marked as resolved.
This comment was marked as resolved.
This comment was marked as outdated.
This comment was marked as outdated.
This comment was marked as outdated.
This comment was marked as outdated.
⚪
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
⚪
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
⚪
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
Outdated
Show resolved
Hide resolved
⚪
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
⚪
🟡
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
NDq::TSpillingSettings spillingSettings{State->Settings->GetEnabledSpillingNodes()}; | ||
*lambda = NDq::BuildProgram( | ||
programLambda, *paramsType, compiler, typeEnv, *State->FunctionRegistry, | ||
ctx, fakeReads); | ||
ctx, fakeReads, spillingSettings); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Этот код зовется из HandleResult, который в том числе может исполнять лямбду локально. Тут нужно либо отключать сплиинг для локального исполнения, либо убедиться, что все отработает номрально без spilling service под ногами
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Спиллинг не должен включаться без spilling service под ногами. Нужно добавить проверку в TSpillingTransformProvider, чтобы спиллинг ноды не включались, если спиллинга нет.
Предлагаю это сделать в PR по добавлению прагмы в widecombine, чтобы не ждать 3 часа тестов
Changelog entry
Added pragma that enables spilling in grace join.
...
Changelog category
Additional information
...