lib/embulk/input/elasticsearch/converter.rb in embulk-input-elasticsearch-0.3.5 vs lib/embulk/input/elasticsearch/converter.rb in embulk-input-elasticsearch-0.3.6

@@ -38,10 +38,10 @@
           when "timestamp"
             Time.parse(value)
           when "json"
             value
           else
-            raise "Unsupported type #{field['type']}"
+            raise Elasticsearch::TypecastError.new "Unsupported type #{field['type']}"
           end
         end
       end
     end
   end