Moved commit "ydb_topic writer: remove obsolete fields" from ydb repo

Author: qyryq

src/client/topic/impl/write_session_impl.cpp

@@ -417,10 +417,6 @@ void TWriteSessionImpl::InitWriter() { // No Lock, very initial start - no race
             ThrowFatalError("ProducerId != MessageGroupId scenario is currently not supported");
     }
     CompressionExecutor = Settings.CompressionExecutor_;
-    IExecutor::TPtr executor;
-    executor = CreateSyncExecutor();
-    executor->Start();
-    Executor = std::move(executor);
 
     Settings.CompressionExecutor_->Start();
     Settings.EventHandlers_.HandlersExecutor_->Start();
@@ -1225,7 +1221,6 @@ void TWriteSessionImpl::ResetForRetryImpl() {
     }
     if (!OriginalMessagesToSend.empty() && OriginalMessagesToSend.front().Id < minId)
         minId = OriginalMessagesToSend.front().Id;
-    MinUnsentId = minId;
     Y_ABORT_UNLESS(PackedMessagesToSend.size() == totalPackedMessages);
     Y_ABORT_UNLESS(OriginalMessagesToSend.size() == totalOriginalMessages);
 }

src/client/topic/impl/write_session_impl.h

@@ -415,10 +415,7 @@ class TWriteSessionImpl : public TContinuationTokenIssuer,
     TWriteSessionSettings Settings;
     std::shared_ptr<TTopicClient::TImpl> Client;
     std::shared_ptr<TGRpcConnectionsImpl> Connections;
-    std::string TargetCluster;
-    std::string InitialCluster;
-    std::string CurrentCluster;
-    std::string PreferredClusterByCDS;
+
     std::shared_ptr<IWriteSessionConnectionProcessorFactory> ConnectionFactory;
     TDbDriverStatePtr DbDriverState;
     std::string PrevToken;
@@ -438,7 +435,6 @@ class TWriteSessionImpl : public TContinuationTokenIssuer,
     std::shared_ptr<TServerMessage> ServerMessage; // Server message to write server response to.
 
     std::string SessionId;
-    IExecutor::TPtr Executor;
     IExecutor::TPtr CompressionExecutor;
     size_t MemoryUsage = 0; //!< Estimated amount of memory used
     bool FirstTokenSent = false;
@@ -461,10 +457,8 @@ class TWriteSessionImpl : public TContinuationTokenIssuer,
     ui32 PartitionId = 0;
     TPartitionLocation PreferredPartitionLocation = {};
     uint64_t NextId = 0;
-    uint64_t MinUnsentId = 1;
     std::optional<uint64_t> InitSeqNo;
     std::optional<bool> AutoSeqNoMode;
-    bool ValidateSeqNoMode = false;
 
     NThreading::TPromise<uint64_t> InitSeqNoPromise;
     bool InitSeqNoSetDone = false;