diff --git a/lib/fluent/plugin/in_cloudwatch_logs.rb b/lib/fluent/plugin/in_cloudwatch_logs.rb
index dc1699a..a9b727f 100644
--- a/lib/fluent/plugin/in_cloudwatch_logs.rb
+++ b/lib/fluent/plugin/in_cloudwatch_logs.rb
@@ -1,4 +1,5 @@
 require 'fluent/input'
+require 'fluent/parser'
 
 module Fluent
   require 'fluent/mixin/config_placeholders'
@@ -71,7 +72,7 @@ def shutdown
     private
     def configure_parser(conf)
       if conf['format']
-        @parser = TextParser.new
+        @parser = Fluent::TextParser.new
         @parser.configure(conf)
       end
     end