-
Notifications
You must be signed in to change notification settings - Fork 610
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
YQL-17542 move sync CA related methods to TDqSyncComputeActorBase #2103
YQL-17542 move sync CA related methods to TDqSyncComputeActorBase #2103
Conversation
⚪
|
⚪
|
⚪
|
⚪
|
CA_LOG_I("task: " << Task.GetId() << ", output channelId: " << channelId << " finished prematurely, " | ||
<< "drop " << dropRows << " rows"); | ||
} | ||
//void TakeInputChannelData(TChannelDataOOB&& channelData, bool ack) is pure and must be overridded in derived class |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't see where we declare TakeInputChannelData
as pure virtual function. Should we do this here?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It's first declared in TDqComputeActorChannels::ICallbacks
Changelog category
Additional information
pr over contrib: https://a.yandex-team.ru/review/5382833/details