4 files changed, 10 insertions, 0 deletions
diff --git a/yt/yt/client/api/config.cpp b/yt/yt/client/api/config.cpp
index b67e6ddcccf..885442301c4 100644
--- a/yt/yt/client/api/config.cpp
+++ b/yt/yt/client/api/config.cpp
@@ -100,6 +100,10 @@ void TJournalChunkWriterConfig::Register(TRegistrar registrar)
         .Default(100'000);
     registrar.Parameter("max_flush_data_size", &TThis::MaxFlushDataSize)
         .Default(100_MB);
+    registrar.Parameter("max_in_flight_flush_count", &TThis::MaxInFlightFlushCount)
+        .Default(1)
+        .GreaterThanOrEqual(1)
+        .DontSerializeDefault();
 
     registrar.Parameter("prefer_local_host", &TThis::PreferLocalHost)
         .Default(true);
diff --git a/yt/yt/client/api/config.h b/yt/yt/client/api/config.h
index ef39a4ba3ce..eb16e7cc364 100644
--- a/yt/yt/client/api/config.h
+++ b/yt/yt/client/api/config.h
@@ -172,6 +172,9 @@ struct TJournalChunkWriterConfig
     int MaxFlushRowCount;
     i64 MaxFlushDataSize;
 
+    //! Maximum number of inflight PutBlocks/Flush requests per replica.
+    int MaxInFlightFlushCount;
+
     bool PreferLocalHost;
 
     TDuration NodeRpcTimeout;
diff --git a/yt/yt/client/api/journal_client.cpp b/yt/yt/client/api/journal_client.cpp
index 96854d1174e..cdc985a6b5f 100644
--- a/yt/yt/client/api/journal_client.cpp
+++ b/yt/yt/client/api/journal_client.cpp
@@ -30,6 +30,7 @@ TJournalWriterPerformanceCounters::TJournalWriterPerformanceCounters(const NProf
     MediumWrittenBytes = profiler.Counter("/medium_written_bytes");
     JournalWrittenBytes = profiler.Counter("/journal_written_bytes");
     IORequestCount = profiler.Counter("/io_request_count");
+    PipelinedFlushCount = profiler.Counter("/pipelined_flush_count");
 }
 
 ////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/yt/client/api/journal_client.h b/yt/yt/client/api/journal_client.h
index 51162a9dbd6..c0679a4c1ac 100644
--- a/yt/yt/client/api/journal_client.h
+++ b/yt/yt/client/api/journal_client.h
@@ -54,6 +54,8 @@ struct TJournalWriterPerformanceCounters
     NProfiling::TCounter IORequestCount;
     NProfiling::TCounter JournalWrittenBytes;
 
+    NProfiling::TCounter PipelinedFlushCount;
+
     IJournalWritesObserverPtr JournalWritesObserver;
 };