diff --git a/lib/fluent/plugin/s3_compressor_parquet.rb b/lib/fluent/plugin/s3_compressor_parquet.rb
index 15bf4b1e..7d921d02 100644
--- 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