Fixing the issue with deletion of temp file along with the dynamic pr…

…efix changes
logstash-plugins · Oct 28, 2015 · b6d430d · b6d430d
1 parent 95bf768
commit b6d430d
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/logstash/outputs/s3.rb b/lib/logstash/outputs/s3.rb
@@ -482,8 +482,13 @@ def reset_page_counter(key)
   private
   def delete_on_bucket(filename)
     bucket = @s3.buckets[@bucket]
+
+    first = Pathname.new @temporary_directory
+    second = Pathname.new filename
 
-    remote_filename = "#{@prefix}#{File.basename(filename)}"
+    remote_filename_path = second.relative_path_from first
+
+    remote_filename = remote_filename_path.to_s
 
     @logger.debug("S3: delete file from bucket", :remote_filename => remote_filename, :bucket => @bucket)