diff --git a/apps/common/plugins/es.py b/apps/common/plugins/es.py
index 27b97b3de..8438c43cc 100644
--- a/apps/common/plugins/es.py
+++ b/apps/common/plugins/es.py
@@ -131,7 +131,10 @@ class ES(object):
                 }
 
             try:
-                self.es.indices.create(self.index, body=mappings)
+                if version == '6':
+                    self.es.indices.create(self.index, body=mappings)
+                else:
+                    self.es.indices.create(index=self.index, body=mappings)
             except RequestError as e:
                 if e.error == 'resource_already_exists_exception':
                     logger.warning(e)