Skip to content

Commit 8663e7c

Browse files
authored
YQ: fix read_actor log message size / to stable (#13958)
1 parent fe0a01d commit 8663e7c

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ class TDqPqRdReadActor : public NActors::TActor<TDqPqRdReadActor>, public NYql::
114114

115115
const ui64 PrintStatePeriodSec = 300;
116116
const ui64 ProcessStatePeriodSec = 1;
117+
const ui64 PrintStateToLogSplitSize = 64000;
117118

118119
struct TReadyBatch {
119120
public:
@@ -869,7 +870,11 @@ void TDqPqRdReadActor::Handle(TEvPrivate::TEvPrintState::TPtr&) {
869870
}
870871

871872
void TDqPqRdReadActor::PrintInternalState() {
872-
SRC_LOG_I(GetInternalState());
873+
auto str = GetInternalState();
874+
auto buf = TStringBuf(str);
875+
for (ui64 offset = 0; offset < buf.size(); offset += PrintStateToLogSplitSize) {
876+
SRC_LOG_I(buf.SubString(offset, PrintStateToLogSplitSize));
877+
}
873878
}
874879

875880
TString TDqPqRdReadActor::GetInternalState() {

0 commit comments

Comments
 (0)