Replace unnecessary shared_ptr.

Remove unused variable.
ydb-platform · Dec 22, 2023 · b8acf67 · b8acf67
1 parent 6579087
commit b8acf67
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/ydb/library/yql/dq/actors/spilling/channel_storage_actor.h b/ydb/library/yql/dq/actors/spilling/channel_storage_actor.h
@@ -3,14 +3,12 @@
 
 #include <ydb/library/actors/core/actor.h>
 
-#include <memory>
-
 namespace NYql::NDq {
 
 class IDqChannelStorageActor
 {
 public:
-    using TPtr = std::shared_ptr<IDqChannelStorageActor>;
+    using TPtr = TIntrusivePtr<IDqChannelStorageActor>;
     using TWakeUpCallback = std::function<void()>;
 
     virtual ~IDqChannelStorageActor() = default;

diff --git a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
@@ -125,7 +125,6 @@ class TOutputChannelReader {
         bool changed = false;
         bool isChanFinished = false;
         i64 remain = ToPopSize;
-        ui32 dataSize = 0;
         bool hasData = true;
         TOutputChannelReadResult result;
 
@@ -146,7 +145,6 @@ class TOutputChannelReader {
             }
 
             hasData = lastPop.GetResult();
-            dataSize = data.Size();
             isChanFinished = !hasData && Channel->IsFinished();
             changed = changed || hasData || (isChanFinished != WasFinished);
             if (hasData) {