diff --git a/lib/fluent/plugin/s3_compressor_parquet.rb b/lib/fluent/plugin/s3_compressor_parquet.rb
index 7d921d0..d96cedd 100644
--- a/lib/fluent/plugin/s3_compressor_parquet.rb
+++ b/lib/fluent/plugin/s3_compressor_parquet.rb
@@ -24,7 +24,7 @@ def configure(conf)
         super
         check_command("columnify", "-h")
 
-        if [:lzo, :brotli, :lz4].include?@compress.parquet_compression_codec
+        if [:lzo, :brotli, :lz4].include?(@compress.parquet_compression_codec)
           raise Fluent::ConfigError, "unsupported compression codec: #{@compress.parquet_compression_codec}"
         end