diff options
| author | akozhikhov <[email protected]> | 2025-06-16 16:40:08 +0300 |
|---|---|---|
| committer | akozhikhov <[email protected]> | 2025-06-16 16:55:30 +0300 |
| commit | fb7b6617d531abdf5fa04f8d9aa6a89144612b54 (patch) | |
| tree | 82d8c0d24ca6786e4ba5ebd9278e0fa6f14a093b | |
| parent | a986a3fc9a0ae8d7732d0899b06cba0103fe5924 (diff) | |
YT-25264: In case of dictionary compression wait for partition writer to close
commit_hash:ecbfa7e9c32e7facb3056d06948b67a3a69bdf9e
| -rw-r--r-- | yt/yt/client/chunk_client/config.cpp | 4 | ||||
| -rw-r--r-- | yt/yt/client/chunk_client/config.h | 3 |
2 files changed, 7 insertions, 0 deletions
diff --git a/yt/yt/client/chunk_client/config.cpp b/yt/yt/client/chunk_client/config.cpp index 5b493671584..21e049c8f7b 100644 --- a/yt/yt/client/chunk_client/config.cpp +++ b/yt/yt/client/chunk_client/config.cpp @@ -392,6 +392,10 @@ void TMultiChunkWriterConfig::Register(TRegistrar registrar) .GreaterThan(0) .LessThanOrEqual(64_MB) .Default(30_MB); + + registrar.Parameter("tesing_delay_before_chunk_close", &TThis::TestingDelayBeforeChunkClose) + .Default() + .DontSerializeDefault(); } //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/client/chunk_client/config.h b/yt/yt/client/chunk_client/config.h index a9b899118bc..6c673b2789c 100644 --- a/yt/yt/client/chunk_client/config.h +++ b/yt/yt/client/chunk_client/config.h @@ -421,6 +421,9 @@ struct TMultiChunkWriterConfig i64 DesiredChunkWeight; i64 MaxMetaSize; + // For testing purposes only. + std::optional<TDuration> TestingDelayBeforeChunkClose; + REGISTER_YSON_STRUCT(TMultiChunkWriterConfig); static void Register(TRegistrar registrar); |