Skip to content

Commit 536d0ae

Browse files
committed
Fixed typo
1 parent 19b4233 commit 536d0ae

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

ydb/core/fq/libs/row_dispatcher/format_handler/ut/format_handler_ut.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ namespace NFq::NRowDispatcher::NTests {
55

66
namespace {
77

8-
class TFormatHadlerFixture : public TBaseFixture {
8+
class TFormatHandlerFixture : public TBaseFixture {
99
public:
1010
using TBase = TBaseFixture;
1111
using TCallback = std::function<void(TQueue<std::pair<TRope, TVector<ui64>>>&& data)>;
@@ -250,7 +250,7 @@ class TFormatHadlerFixture : public TBaseFixture {
250250

251251

252252
Y_UNIT_TEST_SUITE(TestFormatHandler) {
253-
Y_UNIT_TEST_F(ManyJsonClients, TFormatHadlerFixture) {
253+
Y_UNIT_TEST_F(ManyJsonClients, TFormatHandlerFixture) {
254254
const ui64 firstOffset = 42;
255255
const TSchemaColumn commonColumn = {"com_col", "[DataType; String]"};
256256

@@ -278,7 +278,7 @@ Y_UNIT_TEST_SUITE(TestFormatHandler) {
278278
});
279279
}
280280

281-
Y_UNIT_TEST_F(ManyRawClients, TFormatHadlerFixture) {
281+
Y_UNIT_TEST_F(ManyRawClients, TFormatHandlerFixture) {
282282
CreateFormatHandler(
283283
{.JsonParserConfig = {}, .FiltersConfig = {.CompileServiceId = CompileService}},
284284
{.ParsingFormat = "raw"}
@@ -320,7 +320,7 @@ Y_UNIT_TEST_SUITE(TestFormatHandler) {
320320
});
321321
}
322322

323-
Y_UNIT_TEST_F(ClientValidation, TFormatHadlerFixture) {
323+
Y_UNIT_TEST_F(ClientValidation, TFormatHandlerFixture) {
324324
const TVector<TSchemaColumn> schema = {{"data", "[DataType; String]"}};
325325
const TString filter = "WHERE FALSE";
326326
const auto callback = EmptyCheck();
@@ -345,7 +345,7 @@ Y_UNIT_TEST_SUITE(TestFormatHandler) {
345345
);
346346
}
347347

348-
Y_UNIT_TEST_F(ClientError, TFormatHadlerFixture) {
348+
Y_UNIT_TEST_F(ClientError, TFormatHandlerFixture) {
349349
const ui64 firstOffset = 42;
350350
const TSchemaColumn commonColumn = {"com_col", "[DataType; String]"};
351351

@@ -365,7 +365,7 @@ Y_UNIT_TEST_SUITE(TestFormatHandler) {
365365
);
366366
}
367367

368-
Y_UNIT_TEST_F(ClientErrorWithEmptyFilter, TFormatHadlerFixture) {
368+
Y_UNIT_TEST_F(ClientErrorWithEmptyFilter, TFormatHandlerFixture) {
369369
const ui64 firstOffset = 42;
370370
const TSchemaColumn commonColumn = {"com_col", "[DataType; String]"};
371371

ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
319319
hFunc(NActors::TEvInterconnect::TEvNodeConnected, HandleExecuteBase);
320320
hFunc(IDqComputeActorAsyncInput::TEvNewAsyncInputDataArrived, OnNewAsyncInputDataArrived);
321321
hFunc(IDqComputeActorAsyncInput::TEvAsyncInputError, OnAsyncInputError);
322-
hFunc(TEvPrivate::TEvAsyncOutputError, HadleAsyncOutputError);
322+
hFunc(TEvPrivate::TEvAsyncOutputError, HandleAsyncOutputError);
323323
default: {
324324
CA_LOG_C("TDqComputeActorBase, unexpected event: " << ev->GetTypeRewrite() << " (" << GetEventTypeString(ev) << ")");
325325
InternalError(NYql::NDqProto::StatusIds::INTERNAL_ERROR, TIssuesIds::DEFAULT_ERROR, TStringBuilder() << "Unexpected event: " << ev->GetTypeRewrite() << " (" << GetEventTypeString(ev) << ")");
@@ -1561,7 +1561,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
15611561
this->Send(this->SelfId(), new TEvPrivate::TEvAsyncOutputError(fatalCode, issues));
15621562
}
15631563

1564-
void HadleAsyncOutputError(const TEvPrivate::TEvAsyncOutputError::TPtr& ev) {
1564+
void HandleAsyncOutputError(const TEvPrivate::TEvAsyncOutputError::TPtr& ev) {
15651565
InternalError(ev->Get()->StatusCode, ev->Get()->Issues);
15661566
}
15671567

0 commit comments

Comments
 (0)