Use Fluent::UnrecoverableError instead of RuntimeError

fluent · Mar 31, 2021 · 3f8aefe · 3f8aefe
1 parent 16d2ba1
commit 3f8aefe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/s3_compressor_parquet.rb b/lib/fluent/plugin/s3_compressor_parquet.rb
@@ -57,7 +57,7 @@ def compress(chunk, tmp)
                end
         stdout, stderr, status = columnify(path, tmp.path)
         unless status.success?
-          raise "failed to execute columnify command. stdout=#{stdout} stderr=#{stderr} status=#{status.inspect}"
+          raise Fluent::UnrecoverableError, "failed to execute columnify command. stdout=#{stdout} stderr=#{stderr} status=#{status.inspect}"
         end
       ensure
         unless chunk_is_file