We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4237da1 commit 3dc04f3Copy full SHA for 3dc04f3
lib/logstash/outputs/s3.rb
@@ -266,6 +266,8 @@ def close
266
267
@logger.debug("Uploading current workspace")
268
269
+ @file_repository.shutdown # stop stale sweeps
270
+
271
# The plugin has stopped receiving new events, but we still have
272
# data on disk, lets make sure it get to S3.
273
# If Logstash get interrupted, the `restore_from_crash` (when set to true) method will pickup
@@ -275,8 +277,6 @@ def close
275
277
upload_file(file)
276
278
end
279
- @file_repository.shutdown
-
280
@uploader.stop # wait until all the current upload are complete
281
@crash_uploader.stop if @restore # we might have still work to do for recovery so wait until we are done
282
0 commit comments