diff --git a/lib/fluent/plugin/in_sql.rb b/lib/fluent/plugin/in_sql.rb
index babec57..8d5fe33 100644
--- a/lib/fluent/plugin/in_sql.rb
+++ b/lib/fluent/plugin/in_sql.rb
@@ -192,7 +192,9 @@ def start
         socket: @socket,
         schema_search_path: @schema_search_path,
       }
-
+      # This makes the default timezone the local one if it's undefined in the timestamp field itself
+      ActiveRecord::Base.default_timezone = :local
+      
       # creates subclass of ActiveRecord::Base so that it can have different
       # database configuration from ActiveRecord::Base.
       @base_model = Class.new(ActiveRecord::Base) do