diff options
| author | whcrc <whcrc@ydb.tech> | 2022-09-23 16:30:57 +0300 |
|---|---|---|
| committer | whcrc <whcrc@ydb.tech> | 2022-09-23 16:30:57 +0300 |
| commit | 09ad62c2abdad04688bd86ef6d754ccbe426e608 (patch) | |
| tree | affc066c876dd4ce8d3a3d7111c9a2a457fc5e36 | |
| parent | aa94e3bdb22065ec4106bacdbe1b645481570dea (diff) | |
| download | ydb-09ad62c2abdad04688bd86ef6d754ccbe426e608.tar.gz | |
log dq worker type
| -rw-r--r-- | ydb/library/yql/providers/dq/actors/executer_actor.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/dq/actors/executer_actor.cpp b/ydb/library/yql/providers/dq/actors/executer_actor.cpp index b9f3a15dd0f..8f8aa842f5c 100644 --- a/ydb/library/yql/providers/dq/actors/executer_actor.cpp +++ b/ydb/library/yql/providers/dq/actors/executer_actor.cpp @@ -147,7 +147,8 @@ private: AddChild(CheckPointCoordinatorId); int workerCount = ev->Get()->Record.GetRequest().GetTask().size(); - YQL_CLOG(INFO, ProviderDq) << (TStringBuilder() << "Trying to allocate " << workerCount << " workers"); + const bool enableComputeActor = Settings->EnableComputeActor.Get().GetOrElse(false); + YQL_CLOG(INFO, ProviderDq) << (TStringBuilder() << "Trying to allocate " << workerCount << " workers [EnableComputeActor=" << enableComputeActor << "]"); THashMap<TString, Yql::DqsProto::TFile> files; TVector<NDqProto::TDqTask> tasks; @@ -183,7 +184,6 @@ private: SelfId(), ResultId)); - const bool enableComputeActor = Settings->EnableComputeActor.Get().GetOrElse(false); const TString computeActorType = Settings->ComputeActorType.Get().GetOrElse("sync"); auto resourceAllocator = RegisterChild(CreateResourceAllocator( |