Skip to content

Commit

Permalink
Merge branch 'main' into consumeproperties
Browse files Browse the repository at this point in the history
  • Loading branch information
@nshestakov
nshestakov committed Feb 21, 2024
2 parents 1175a4a + a950903 commit e233f48
Show file tree
Hide file tree
Showing 178 changed files with 4,275 additions and 2,196 deletions.
1 change: 0 additions & 1 deletion ydb/apps/ydb/ut/epilogue.cmake
View file

This file was deleted.

13 changes: 11 additions & 2 deletions ydb/core/blobstorage/pdisk/blobstorage_pdisk_impl.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1518,8 +1518,17 @@ void TPDisk::WhiteboardReport(TWhiteboardReport &whiteboardReport) {
TGuard<TMutex> guard(StateMutex);
const ui64 totalSize = Format.DiskSize;
const ui64 availableSize = (ui64)Format.ChunkSize * Keeper.GetFreeChunkCount();
*Mon.FreeSpaceBytes = availableSize;
*Mon.UsedSpaceBytes = totalSize - *Mon.FreeSpaceBytes;

if (*Mon.PDiskBriefState != TPDiskMon::TPDisk::Error) {
*Mon.FreeSpaceBytes = availableSize;
*Mon.UsedSpaceBytes = totalSize - availableSize;
} else {
// If disk is in Error State, show its total and used space as 32KiB (format size)
*Mon.FreeSpaceBytes = 0;
*Mon.UsedSpaceBytes = 32_KB;
*Mon.TotalSpaceBytes = 32_KB;
}

NKikimrWhiteboard::TPDiskStateInfo& pdiskState = reportResult->PDiskState->Record;
pdiskState.SetPDiskId(PDiskId);
pdiskState.SetPath(Cfg->GetDevicePath());
Expand Down
27 changes: 18 additions & 9 deletions ydb/core/change_exchange/change_sender_common_ops.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,28 +21,37 @@ struct TEvChangeExchangePrivate {

static_assert(EvEnd < EventSpaceEnd(TKikimrEvents::ES_PRIVATE));

template <typename TEv, ui32 TEventType>
struct TEvWithPartitionId: public TEventLocal<TEv, TEventType> {
struct TEvReady: public TEventLocal<TEvReady, EvReady> {
ui64 PartitionId;

explicit TEvWithPartitionId(ui64 partiionId)
explicit TEvReady(ui64 partiionId)
: PartitionId(partiionId)
{
}

TString ToString() const override {
return TStringBuilder() << TEventLocal<TEv, TEventType>::ToStringHeader() << " {"
return TStringBuilder() << ToStringHeader() << " {"
<< " PartitionId: " << PartitionId
<< " }";
}
};

struct TEvReady: public TEvWithPartitionId<TEvReady, EvReady> {
using TEvWithPartitionId::TEvWithPartitionId;
};
struct TEvGone: public TEventLocal<TEvGone, EvGone> {
ui64 PartitionId;
bool HardError;

explicit TEvGone(ui64 partitionId, bool hardError = false)
: PartitionId(partitionId)
, HardError(hardError)
{
}

struct TEvGone: public TEvWithPartitionId<TEvGone, EvGone> {
using TEvWithPartitionId::TEvWithPartitionId;
TString ToString() const override {
return TStringBuilder() << ToStringHeader() << " {"
<< " PartitionId: " << PartitionId
<< " HardError: " << HardError
<< " }";
}
};

}; // TEvChangeExchangePrivate
Expand Down
129 changes: 63 additions & 66 deletions ydb/core/driver_lib/run/auto_config_initializer.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ namespace {
i16 MaxThreadCount;
};

constexpr i16 MaxPreparedCpuCount = 31;
constexpr i16 MaxPreparedCpuCount = 30;
constexpr i16 GRpcWorkerCountInMaxPreparedCpuCase = 4;
constexpr i16 GrpcProxyCountInMaxPreparedCpuCase = 4;
constexpr i16 CpuCountForEachGRpcWorker = MaxPreparedCpuCount / GRpcWorkerCountInMaxPreparedCpuCase;
Expand All @@ -46,32 +46,31 @@ namespace {
{ {1, 2}, {0, 3}, {1, 1}, {0, 0}, {1, 1} }, // 3
{ {1, 2}, {1, 4}, {1, 1}, {0, 0}, {1, 2} }, // 4
{ {1, 3}, {2, 5}, {1, 1}, {0, 0}, {1, 2} }, // 5
{ {1, 3}, {3, 6}, {1, 1}, {0, 0}, {1, 2} }, // 6
{ {1, 3}, {3, 6}, {1, 1}, {0, 0}, {1, 3} }, // 6
{ {2, 4}, {3, 7}, {1, 2}, {0, 0}, {1, 3} }, // 7
{ {2, 4}, {4, 8}, {1, 2}, {0, 0}, {1, 3} }, // 8
{ {2, 5}, {4, 9}, {2, 3}, {0, 0}, {1, 3} }, // 9
{ {2, 5}, {5, 10}, {2, 3}, {0, 0}, {1, 3} }, // 10
{ {2, 6}, {5, 11}, {2, 3}, {0, 0}, {2, 4} }, // 11
{ {2, 6}, {6, 12}, {2, 3}, {0, 0}, {2, 5} }, // 12
{ {3, 7}, {6, 13}, {2, 3}, {0, 0}, {2, 5} }, // 13
{ {3, 7}, {6, 14}, {2, 3}, {0, 0}, {3, 6} }, // 14
{ {3, 8}, {7, 15}, {2, 4}, {0, 0}, {3, 6} }, // 15
{ {3, 8}, {8, 16}, {2, 4}, {0, 0}, {3, 6} }, // 16
{ {3, 9}, {9, 17}, {2, 4}, {0, 0}, {3, 7} }, // 17
{ {3, 9}, {9, 18}, {3, 5}, {0, 0}, {3, 7} }, // 18
{ {3, 10}, {9, 19}, {3, 5}, {0, 0}, {4, 8} }, // 19
{ {4, 10}, {9, 20}, {3, 5}, {0, 0}, {4, 8} }, // 20
{ {4, 11}, {10, 21}, {3, 5}, {0, 0}, {4, 8} }, // 21
{ {4, 11}, {11, 22}, {3, 5}, {0, 0}, {4, 9} }, // 22
{ {4, 12}, {12, 23}, {3, 6}, {0, 0}, {4, 9} }, // 23
{ {4, 12}, {12, 24}, {3, 6}, {0, 0}, {5, 10} }, // 24
{ {5, 13}, {12, 25}, {3, 6}, {0, 0}, {5, 10} }, // 25
{ {5, 13}, {12, 26}, {4, 7}, {0, 0}, {5, 10} }, // 26
{ {5, 14}, {13, 27}, {4, 7}, {0, 0}, {5, 11} }, // 27
{ {5, 14}, {14, 28}, {4, 7}, {0, 0}, {5, 11} }, // 28
{ {5, 15}, {14, 29}, {4, 8}, {0, 0}, {6, 12} }, // 29
{ {5, 15}, {15, 30}, {4, 8}, {0, 0}, {6, 12} }, // 30
{ {6, 18}, {15, 31}, {4, 8}, {0, 0}, {6, 12} }, // 31
{ {2, 4}, {4, 8}, {1, 2}, {0, 0}, {1, 4} }, // 8
{ {2, 5}, {4, 9}, {2, 3}, {0, 0}, {1, 4} }, // 9
{ {2, 5}, {5, 10}, {2, 3}, {0, 0}, {1, 5} }, // 10
{ {2, 6}, {5, 11}, {2, 3}, {0, 0}, {2, 5} }, // 11
{ {2, 6}, {6, 12}, {2, 3}, {0, 0}, {2, 6} }, // 12
{ {3, 7}, {6, 13}, {2, 3}, {0, 0}, {2, 6} }, // 13
{ {3, 7}, {6, 14}, {2, 3}, {0, 0}, {3, 7} }, // 14
{ {3, 8}, {7, 15}, {2, 4}, {0, 0}, {3, 7} }, // 15
{ {3, 8}, {8, 16}, {2, 4}, {0, 0}, {3, 8} }, // 16
{ {3, 9}, {9, 17}, {2, 4}, {0, 0}, {3, 8} }, // 17
{ {3, 9}, {9, 18}, {3, 5}, {0, 0}, {3, 9} }, // 18
{ {3, 10}, {9, 19}, {3, 5}, {0, 0}, {4, 9} }, // 19
{ {4, 10}, {9, 20}, {3, 5}, {0, 0}, {4, 10} }, // 20
{ {4, 11}, {10, 21}, {3, 5}, {0, 0}, {4, 10} }, // 21
{ {4, 11}, {11, 22}, {3, 5}, {0, 0}, {4, 11} }, // 22
{ {4, 12}, {12, 23}, {3, 6}, {0, 0}, {4, 11} }, // 23
{ {4, 12}, {12, 24}, {3, 6}, {0, 0}, {5, 12} }, // 24
{ {5, 13}, {12, 25}, {3, 6}, {0, 0}, {5, 12} }, // 25
{ {5, 13}, {12, 26}, {4, 7}, {0, 0}, {5, 13} }, // 26
{ {5, 14}, {13, 27}, {4, 7}, {0, 0}, {5, 13} }, // 27
{ {5, 14}, {14, 28}, {4, 7}, {0, 0}, {5, 14} }, // 28
{ {5, 15}, {14, 29}, {4, 8}, {0, 0}, {6, 14} }, // 29
{ {5, 15}, {15, 30}, {4, 8}, {0, 0}, {6, 15} }, // 30
};

TShortPoolCfg HybridCpuTable[MaxPreparedCpuCount + 1][5] {
Expand All @@ -81,32 +80,31 @@ namespace {
{ {1, 2}, {0, 3}, {1, 1}, {0, 0}, {1, 1} }, // 3
{ {1, 2}, {1, 4}, {1, 1}, {0, 0}, {1, 2} }, // 4
{ {1, 2}, {2, 5}, {1, 1}, {0, 0}, {1, 2} }, // 5
{ {1, 2}, {2, 6}, {1, 1}, {0, 0}, {2, 2} }, // 6
{ {1, 2}, {2, 6}, {1, 1}, {0, 0}, {2, 3} }, // 6
{ {2, 3}, {2, 7}, {1, 2}, {0, 0}, {2, 3} }, // 7
{ {2, 3}, {3, 8}, {1, 2}, {0, 0}, {2, 3} }, // 8
{ {2, 3}, {3, 8}, {1, 2}, {0, 0}, {2, 4} }, // 8
{ {2, 4}, {3, 9}, {1, 2}, {0, 0}, {3, 4} }, // 9
{ {3, 4}, {3, 10}, {1, 2}, {0, 0}, {3, 4} }, // 10
{ {3, 4}, {3, 10}, {1, 2}, {0, 0}, {3, 5} }, // 10
{ {3, 5}, {4, 11}, {1, 2}, {0, 0}, {3, 5} }, // 11
{ {3, 5}, {4, 12}, {1, 3}, {0, 0}, {4, 5} }, // 12
{ {3, 5}, {4, 12}, {1, 3}, {0, 0}, {4, 6} }, // 12
{ {4, 6}, {4, 13}, {1, 3}, {0, 0}, {4, 6} }, // 13
{ {4, 6}, {5, 14}, {1, 3}, {0, 0}, {4, 6} }, // 14
{ {4, 6}, {5, 14}, {1, 3}, {0, 0}, {4, 7} }, // 14
{ {4, 7}, {5, 15}, {1, 3}, {0, 0}, {5, 7} }, // 15
{ {5, 7}, {5, 16}, {1, 3}, {0, 0}, {5, 7} }, // 16
{ {5, 7}, {5, 16}, {1, 3}, {0, 0}, {5, 8} }, // 16
{ {5, 8}, {6, 17}, {1, 4}, {0, 0}, {5, 8} }, // 17
{ {5, 8}, {6, 18}, {1, 4}, {0, 0}, {6, 8} }, // 18
{ {5, 8}, {6, 18}, {1, 4}, {0, 0}, {6, 9} }, // 18
{ {6, 9}, {6, 19}, {1, 4}, {0, 0}, {6, 9} }, // 19
{ {6, 9}, {7, 20}, {1, 4}, {0, 0}, {6, 9} }, // 20
{ {6, 10}, {7, 21}, {1, 4}, {0, 0}, {7, 10} }, // 21
{ {7, 10}, {7, 22}, {1, 5}, {0, 0}, {7, 10} }, // 22
{ {7, 11}, {8, 23}, {1, 5}, {0, 0}, {7, 11} }, // 23
{ {7, 11}, {8, 24}, {1, 5}, {0, 0}, {8, 11} }, // 24
{ {6, 9}, {7, 20}, {1, 4}, {0, 0}, {6, 10} }, // 20
{ {6, 10}, {7, 21}, {1, 4}, {0, 0}, {7, 10} }, // 21
{ {7, 10}, {7, 22}, {1, 5}, {0, 0}, {7, 11} }, // 22
{ {7, 11}, {8, 23}, {1, 5}, {0, 0}, {7, 11} }, // 23
{ {7, 11}, {8, 24}, {1, 5}, {0, 0}, {8, 12} }, // 24
{ {8, 12}, {8, 25}, {1, 5}, {0, 0}, {8, 12} }, // 25
{ {8, 12}, {9, 26}, {1, 5}, {0, 0}, {8, 12} }, // 26
{ {8, 12}, {9, 26}, {1, 5}, {0, 0}, {8, 13} }, // 26
{ {8, 13}, {9, 27}, {1, 6}, {0, 0}, {9, 13} }, // 27
{ {9, 13}, {9, 28}, {1, 6}, {0, 0}, {9, 13} }, // 28
{ {9, 13}, {9, 28}, {1, 6}, {0, 0}, {9, 14} }, // 28
{ {9, 14}, {10, 29}, {1, 6}, {0, 0}, {9, 14} }, // 29
{ {9, 14}, {10, 30}, {1, 6}, {0, 0}, {10, 14} }, // 30
{ {10, 15}, {10, 31}, {1, 6}, {0, 0}, {10, 15} }, // 31
{ {9, 14}, {10, 30}, {1, 6}, {0, 0}, {10, 15} }, // 30
};

TShortPoolCfg StorageCpuTable[MaxPreparedCpuCount + 1][5] {
Expand All @@ -116,32 +114,31 @@ namespace {
{ {1, 3}, {0, 3}, {1, 1}, {0, 0}, {1, 1} }, // 3
{ {1, 4}, {1, 4}, {1, 1}, {0, 0}, {1, 2} }, // 4
{ {2, 5}, {1, 5}, {1, 1}, {0, 0}, {1, 2} }, // 5
{ {3, 6}, {1, 6}, {1, 1}, {0, 0}, {1, 2} }, // 6
{ {3, 6}, {1, 6}, {1, 1}, {0, 0}, {1, 3} }, // 6
{ {4, 7}, {1, 7}, {1, 2}, {0, 0}, {1, 3} }, // 7
{ {5, 8}, {1, 8}, {1, 2}, {0, 0}, {1, 3} }, // 8
{ {5, 8}, {1, 8}, {1, 2}, {0, 0}, {1, 4} }, // 8
{ {5, 9}, {1, 9}, {1, 2}, {0, 0}, {2, 4} }, // 9
{ {6, 10}, {1, 10}, {1, 2}, {0, 0}, {2, 4} }, // 10
{ {6, 11}, {1, 11}, {2, 3}, {0, 0}, {2, 4} }, // 11
{ {7, 12}, {1, 12}, {2, 3}, {0, 0}, {2, 5} }, // 12
{ {8, 13}, {1, 13}, {2, 3}, {0, 0}, {2, 5} }, // 13
{ {8, 14}, {1, 14}, {2, 3}, {0, 0}, {3, 6} }, // 14
{ {9, 15}, {1, 15}, {2, 4}, {0, 0}, {3, 6} }, // 15
{ {10, 16}, {1, 16}, {2, 4}, {0, 0}, {3, 6} }, // 16
{ {11, 17}, {1, 17}, {2, 4}, {0, 0}, {3, 7} }, // 17
{ {11, 18}, {1, 18}, {3, 5}, {0, 0}, {3, 7} }, // 18
{ {11, 19}, {1, 19}, {3, 5}, {0, 0}, {4, 8} }, // 19
{ {12, 20}, {1, 20}, {3, 5}, {0, 0}, {4, 8} }, // 20
{ {13, 21}, {1, 21}, {3, 5}, {0, 0}, {4, 8} }, // 21
{ {14, 22}, {1, 22}, {3, 6}, {0, 0}, {4, 9} }, // 22
{ {15, 23}, {1, 23}, {3, 6}, {0, 0}, {4, 9} }, // 23
{ {15, 24}, {1, 24}, {3, 6}, {0, 0}, {5, 10} }, // 24
{ {16, 25}, {1, 25}, {3, 6}, {0, 0}, {5, 10} }, // 25
{ {16, 26}, {1, 26}, {4, 7}, {0, 0}, {5, 10} }, // 26
{ {17, 27}, {1, 27}, {4, 7}, {0, 0}, {5, 11} }, // 27
{ {18, 28}, {1, 28}, {4, 7}, {0, 0}, {5, 11} }, // 28
{ {18, 29}, {1, 29}, {4, 7}, {0, 0}, {6, 12} }, // 29
{ {19, 30}, {1, 30}, {4, 8}, {0, 0}, {6, 12} }, // 30
{ {20, 31}, {1, 31}, {4, 8}, {0, 0}, {6, 12} }, // 31
{ {6, 10}, {1, 10}, {1, 2}, {0, 0}, {2, 5} }, // 10
{ {6, 11}, {1, 11}, {2, 3}, {0, 0}, {2, 5} }, // 11
{ {7, 12}, {1, 12}, {2, 3}, {0, 0}, {2, 6} }, // 12
{ {8, 13}, {1, 13}, {2, 3}, {0, 0}, {2, 6} }, // 13
{ {8, 14}, {1, 14}, {2, 3}, {0, 0}, {3, 7} }, // 14
{ {9, 15}, {1, 15}, {2, 4}, {0, 0}, {3, 7} }, // 15
{ {10, 16}, {1, 16}, {2, 4}, {0, 0}, {3, 8} }, // 16
{ {11, 17}, {1, 17}, {2, 4}, {0, 0}, {3, 8} }, // 17
{ {11, 18}, {1, 18}, {3, 5}, {0, 0}, {3, 9} }, // 18
{ {11, 19}, {1, 19}, {3, 5}, {0, 0}, {4, 9} }, // 19
{ {12, 20}, {1, 20}, {3, 5}, {0, 0}, {4, 10} }, // 20
{ {13, 21}, {1, 21}, {3, 5}, {0, 0}, {4, 10} }, // 21
{ {14, 22}, {1, 22}, {3, 6}, {0, 0}, {4, 11} }, // 22
{ {15, 23}, {1, 23}, {3, 6}, {0, 0}, {4, 11} }, // 23
{ {15, 24}, {1, 24}, {3, 6}, {0, 0}, {5, 12} }, // 24
{ {16, 25}, {1, 25}, {3, 6}, {0, 0}, {5, 12} }, // 25
{ {16, 26}, {1, 26}, {4, 7}, {0, 0}, {5, 13} }, // 26
{ {17, 27}, {1, 27}, {4, 7}, {0, 0}, {5, 13} }, // 27
{ {18, 28}, {1, 28}, {4, 7}, {0, 0}, {5, 14} }, // 28
{ {18, 29}, {1, 29}, {4, 7}, {0, 0}, {6, 14} }, // 29
{ {19, 30}, {1, 30}, {4, 8}, {0, 0}, {6, 15} }, // 30
};

i16 GetIOThreadCount(i16 cpuCount) {
Expand Down
1 change: 1 addition & 0 deletions ydb/core/driver_lib/run/kikimr_services_initializers.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -870,6 +870,7 @@ void TBasicServicesInitializer::InitializeServices(NActors::TActorSystemSetup* s
GET_FIELD_FROM_CONFIG(MaxSpansInBatch)
GET_FIELD_FROM_CONFIG(MaxBytesInBatch)
GET_FIELD_FROM_CONFIG(SpanExportTimeoutSeconds)
GET_FIELD_FROM_CONFIG(MaxExportRequestsInflight)

#undef GET_FIELD_FROM_CONFIG

Expand Down
5 changes: 3 additions & 2 deletions ydb/core/fq/libs/compute/ydb/actors_factory.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,9 @@ struct TActorFactory : public IActorFactory {
std::unique_ptr<NActors::IActor> CreateResultWriter(const NActors::TActorId& parent,
const NActors::TActorId& connector,
const NActors::TActorId& pinger,
const NKikimr::NOperationId::TOperationId& operationId) const override {
return CreateResultWriterActor(Params, parent, connector, pinger, operationId, Counters);
const NKikimr::NOperationId::TOperationId& operationId,
bool operationEntryExpected) const override {
return CreateResultWriterActor(Params, parent, connector, pinger, operationId, operationEntryExpected, Counters);
}

std::unique_ptr<NActors::IActor> CreateResourcesCleaner(const NActors::TActorId& parent,
Expand Down
3 changes: 2 additions & 1 deletion ydb/core/fq/libs/compute/ydb/actors_factory.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,8 @@ struct IActorFactory : public TThrRefBase {
virtual std::unique_ptr<NActors::IActor> CreateResultWriter(const NActors::TActorId& parent,
const NActors::TActorId& connector,
const NActors::TActorId& pinger,
const NKikimr::NOperationId::TOperationId& operationId) const = 0;
const NKikimr::NOperationId::TOperationId& operationId,
bool operationEntryExpected) const = 0;
virtual std::unique_ptr<NActors::IActor> CreateResourcesCleaner(const NActors::TActorId& parent,
const NActors::TActorId& connector,
const NYdb::TOperation::TOperationId& operationId) const = 0;
Expand Down
14 changes: 12 additions & 2 deletions ydb/core/fq/libs/compute/ydb/result_writer_actor.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -202,13 +202,14 @@ class TResultWriterActor : public TBaseComputeActor<TResultWriterActor> {
}
};

TResultWriterActor(const TRunActorParams& params, const TActorId& parent, const TActorId& connector, const TActorId& pinger, const NKikimr::NOperationId::TOperationId& operationId, const ::NYql::NCommon::TServiceCounters& queryCounters)
TResultWriterActor(const TRunActorParams& params, const TActorId& parent, const TActorId& connector, const TActorId& pinger, const NKikimr::NOperationId::TOperationId& operationId, bool operationEntryExpected, const ::NYql::NCommon::TServiceCounters& queryCounters)
: TBaseComputeActor(queryCounters, "ResultWriter")
, Params(params)
, Parent(parent)
, Connector(connector)
, Pinger(pinger)
, OperationId(operationId)
, OperationEntryExpected(operationEntryExpected)
, Counters(GetStepCountersSubgroup())
{}

Expand Down Expand Up @@ -246,6 +247,13 @@ class TResultWriterActor : public TBaseComputeActor<TResultWriterActor> {

void Handle(const TEvYdbCompute::TEvGetOperationResponse::TPtr& ev) {
const auto& response = *ev.Get()->Get();
if (!OperationEntryExpected && response.Status == NYdb::EStatus::NOT_FOUND) {
LOG_I("Operation has been already removed");
Send(Parent, new TEvYdbCompute::TEvResultWriterResponse({}, NYdb::EStatus::SUCCESS));
CompleteAndPassAway();
return;
}

if (response.Status != NYdb::EStatus::SUCCESS) {
LOG_E("Can't get operation: " << ev->Get()->Issues.ToOneLineString());
Send(Parent, new TEvYdbCompute::TEvResultWriterResponse(ev->Get()->Issues, ev->Get()->Status));
Expand Down Expand Up @@ -314,6 +322,7 @@ class TResultWriterActor : public TBaseComputeActor<TResultWriterActor> {
TActorId Connector;
TActorId Pinger;
NKikimr::NOperationId::TOperationId OperationId;
const bool OperationEntryExpected;
TCounters Counters;
TInstant StartTime;
TString FetchToken;
Expand All @@ -325,8 +334,9 @@ std::unique_ptr<NActors::IActor> CreateResultWriterActor(const TRunActorParams&
const TActorId& connector,
const TActorId& pinger,
const NKikimr::NOperationId::TOperationId& operationId,
bool operationEntryExpected,
const ::NYql::NCommon::TServiceCounters& queryCounters) {
return std::make_unique<TResultWriterActor>(params, parent, connector, pinger, operationId, queryCounters);
return std::make_unique<TResultWriterActor>(params, parent, connector, pinger, operationId, operationEntryExpected, queryCounters);
}

}
1 change: 1 addition & 0 deletions ydb/core/fq/libs/compute/ydb/result_writer_actor.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ std::unique_ptr<NActors::IActor> CreateResultWriterActor(const TRunActorParams&
const NActors::TActorId& connector,
const NActors::TActorId& pinger,
const NKikimr::NOperationId::TOperationId& operationId,
bool operationEntryExpected,
const ::NYql::NCommon::TServiceCounters& queryCounters);

}
Loading

0 comments on commit e233f48

Please sign in to comment.