File tree Expand file tree Collapse file tree 3 files changed +3
-11
lines changed
topic/topiclistenerinternal Expand file tree Collapse file tree 3 files changed +3
-11
lines changed Original file line number Diff line number Diff line change 11* Massive changed log messages - those have more details now.
2+ * Fixed sometime panic on stats receive in query service
23
34## v3.99.7
45* Fixed not passing request context to topic event logs
Original file line number Diff line number Diff line change @@ -169,7 +169,7 @@ func newResult(
169169
170170 r .lastPart = part
171171
172- if r .statsCallback != nil {
172+ if part . GetExecStats () != nil && r .statsCallback != nil {
173173 r .statsCallback (stats .FromQueryStats (part .GetExecStats ()))
174174 }
175175
Original file line number Diff line number Diff line change @@ -343,16 +343,7 @@ func (l *streamListener) onStopPartitionRequest(
343343 return err
344344 }
345345
346- var handlerCtx context.Context
347- if session == nil {
348- cancelledCtx , cancel := context .WithCancelCause (ctx )
349- cancel (xerrors .WithStackTrace (xerrors .Wrap (errors .New (
350- "ydb: partition on topic listener was force stopped: %w" ,
351- ))))
352- handlerCtx = cancelledCtx
353- } else {
354- handlerCtx = session .Context ()
355- }
346+ handlerCtx := session .Context ()
356347
357348 event := NewPublicStopPartitionSessionEvent (
358349 session .ToPublic (),
You can’t perform that action at this time.
0 commit comments