diff --git a/libminifi/include/core/logging/internal/LogCompressorSink.h b/libminifi/include/core/logging/internal/LogCompressorSink.h index d70c0193cb..58868a9573 100644 --- a/libminifi/include/core/logging/internal/LogCompressorSink.h +++ b/libminifi/include/core/logging/internal/LogCompressorSink.h @@ -84,7 +84,7 @@ class LogCompressorSink : public spdlog::sinks::base_sink { return cached_logs_.getMaxSize(); } - size_t getMaxCacheSegmenSize() const { + size_t getMaxCacheSegmentSize() const { return cached_logs_.getMaxItemSize(); } diff --git a/libminifi/src/core/logging/internal/CompressionManager.cpp b/libminifi/src/core/logging/internal/CompressionManager.cpp index fc79b05c92..83da24ee28 100644 --- a/libminifi/src/core/logging/internal/CompressionManager.cpp +++ b/libminifi/src/core/logging/internal/CompressionManager.cpp @@ -52,7 +52,7 @@ std::shared_ptr CompressionManager::initialize( } // do not create new sink if all relevant parameters match if (!sink_ || sink_->getMaxCacheSize() != cached_log_max_size || sink_->getMaxCompressedSize() != compressed_log_max_size || - sink_->getMaxCacheSegmenSize() != cache_segment_size || sink_->getMaxCompressedSegmentSize() != compressed_segment_size) { + sink_->getMaxCacheSegmentSize() != cache_segment_size || sink_->getMaxCompressedSegmentSize() != compressed_segment_size) { sink_ = std::make_shared( LogQueueSize{cached_log_max_size, cache_segment_size}, LogQueueSize{compressed_log_max_size, compressed_segment_size},