File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
ydb/library/yql/dq/actors/compute Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1254,7 +1254,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
12541254 IRandomProvider* randomProvider
12551255 )
12561256 {
1257- auto collectStatsLevel = StatsModeToCollectStatsLevel (RuntimeSettings.StatsMode );
1257+ auto collectStatsLevel = StatsModeToCollectStatsLevel (RuntimeSettings.StatsMode );
12581258 for (auto & [inputIndex, source] : SourcesMap) {
12591259 Y_ABORT_UNLESS (AsyncIoFactory);
12601260 const auto & inputDesc = Task.GetInputs (inputIndex);
@@ -1472,12 +1472,12 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
14721472
14731473private:
14741474 void InitializeTask () {
1475- for (ui32 i = 0 ; i < Task.InputsSize (); ++i) {
1475+ for (ui32 i = 0 ; i < Task.InputsSize (); ++i) {
14761476 const auto & inputDesc = Task.GetInputs (i);
14771477 Y_ABORT_UNLESS (!inputDesc.HasSource () || inputDesc.ChannelsSize () == 0 ); // HasSource => no channels
14781478
14791479 if (inputDesc.HasTransform ()) {
1480- auto result = InputTransformsMap.emplace (
1480+ auto result = InputTransformsMap.emplace (
14811481 i,
14821482 TAsyncInputTransformHelper (LogPrefix, i, NDqProto::WATERMARKS_MODE_DISABLED)
14831483 );
You can’t perform that action at this time.
0 commit comments