@@ -162,7 +162,7 @@ class LogStash::Outputs::S3 < LogStash::Outputs::Base
162
162
# The default strategy is to check for both size and time, the first one to match will rotate the file.
163
163
config :rotation_strategy , :validate => [ "size_and_time" , "size" , "time" ] , :default => "size_and_time"
164
164
165
- # The common use case is to define permission on the root bucket and give Logstash full access to write his logs.
165
+ # The common use case is to define permission on the root bucket and give Logstash full access to write its logs.
166
166
# In some circonstances you need finer grained permission on subfolder, this allow you to disable the check at startup.
167
167
config :validate_credentials_on_root_bucket , :validate => :boolean , :default => true
168
168
@@ -185,7 +185,7 @@ def register
185
185
end
186
186
187
187
if @time_file . nil? && @size_file . nil? || @size_file == 0 && @time_file == 0
188
- raise LogStash ::ConfigurationError , "Logstash need at ` time_file` or ` size_file` greather than 0"
188
+ raise LogStash ::ConfigurationError , "The S3 plugin must have at least one of time_file or size_file set to a value greater than 0"
189
189
end
190
190
191
191
@file_repository = FileRepository . new ( @tags , @encoding , @temporary_directory )
@@ -216,7 +216,7 @@ def multi_receive_encoded(events_and_encoded)
216
216
217
217
begin
218
218
@file_repository . get_file ( prefix_key ) { |file | file . write ( encoded ) }
219
- # The output should stop accepting new events coming in, since he cannot do anything with them anymore.
219
+ # The output should stop accepting new events coming in, since it cannot do anything with them anymore.
220
220
# Log the error and rethrow it.
221
221
rescue Errno ::ENOSPC => e
222
222
@logger . error ( "S3: No space left in temporary directory" , :temporary_directory => @temporary_directory )
@@ -351,7 +351,7 @@ def restore_from_crash
351
351
key_parts = Pathname . new ( file ) . relative_path_from ( temp_folder_path ) . to_s . split ( ::File ::SEPARATOR )
352
352
temp_file = TemporaryFile . new ( key_parts . slice ( 1 , key_parts . size ) . join ( "/" ) , ::File . open ( file , "r" ) )
353
353
354
- @logger . debug ( "Recover from crash and uploading" , :file => temp_file . path )
354
+ @logger . debug ( "Recovering from crash and uploading" , :file => temp_file . path )
355
355
@crash_uploader . upload_async ( temp_file , :on_complete => method ( :clean_temporary_file ) )
356
356
end
357
357
end
0 commit comments