File tree Expand file tree Collapse file tree 2 files changed +1
-3
lines changed Expand file tree Collapse file tree 2 files changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -71,7 +71,6 @@ namespace NKikimr::NEvWrite {
7171 void TShardWriter::Bootstrap () {
7272 SendWriteRequest ();
7373 Become (&TShardWriter::StateMain);
74- Schedule (TDuration::Seconds (10 ), new TEvents::TEvWakeup ());
7574 }
7675
7776 void TShardWriter::Handle (NEvents::TDataEvents::TEvWriteResult::TPtr& ev) {
@@ -139,7 +138,6 @@ namespace NKikimr::NEvWrite {
139138
140139 void TShardWriter::HandleTimeout (const TActorContext& /* ctx*/ ) {
141140 RetryWriteRequest (false );
142- Schedule (TDuration::Seconds (10 ), new TEvents::TEvWakeup ());
143141 }
144142
145143 bool TShardWriter::RetryWriteRequest (const bool delayed) {
Original file line number Diff line number Diff line change @@ -278,7 +278,7 @@ class TUploadRowsBase : public TActorBootstrapped<TUploadRowsBase<DerivedActivit
278278 , Timeout((timeout && timeout <= DEFAULT_TIMEOUT) ? timeout : DEFAULT_TIMEOUT)
279279 , Status(Ydb::StatusIds::SUCCESS)
280280 , UploadCountersGuard(UploadCounters.BuildGuard(TMonotonic::Now()))
281- , ImmediateWrite(AppData(ctx )->FeatureFlags.GetEnableImmediateWritingOnBulkUpsert())
281+ , ImmediateWrite(AppData()->FeatureFlags.GetEnableImmediateWritingOnBulkUpsert())
282282 , DiskQuotaExceeded(diskQuotaExceeded)
283283 , Span(std::move(span))
284284 {}
You can’t perform that action at this time.
0 commit comments