diff options
| -rw-r--r-- | ydb/library/yql/tools/dqrun/dqrun.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/tools/dqrun/dqrun.cpp b/ydb/library/yql/tools/dqrun/dqrun.cpp index a547833517c..eaa8666a071 100644 --- a/ydb/library/yql/tools/dqrun/dqrun.cpp +++ b/ydb/library/yql/tools/dqrun/dqrun.cpp @@ -544,6 +544,7 @@ int RunMain(int argc, const char* argv[]) .StoreResult(&runOptions.BindingsFile); opts.AddLongOption("metrics-pusher-config", "Metrics Pusher Config") .StoreResult(&mestricsPusherConfig); + opts.AddLongOption("enable-spilling", "Enable disk spilling").NoArgument(); opts.AddHelpOption('h'); opts.SetFreeArgsNum(0); @@ -796,7 +797,7 @@ int RunMain(int argc, const char* argv[]) size_t requestTimeout = gatewaysConfig.HasHttpGateway() && gatewaysConfig.GetHttpGateway().HasRequestTimeoutSeconds() ? gatewaysConfig.GetHttpGateway().GetRequestTimeoutSeconds() : 100; size_t maxRetries = gatewaysConfig.HasHttpGateway() && gatewaysConfig.GetHttpGateway().HasMaxRetries() ? gatewaysConfig.GetHttpGateway().GetMaxRetries() : 2; - const bool enableSpilling = true; + const bool enableSpilling = res.Has("enable-spilling"); dqGateway = CreateLocalDqGateway(funcRegistry.Get(), dqCompFactory, dqTaskTransformFactory, dqTaskPreprocessorFactories, enableSpilling, CreateAsyncIoFactory(driver, httpGateway, genericClient, requestTimeout, maxRetries), threads, metricsRegistry, |