diff --git a/eventdata/parameter_sources/elasticlogs_bulk_source.py b/eventdata/parameter_sources/elasticlogs_bulk_source.py
index d9f328c2554de..3ce60dbe8917b 100755
--- a/eventdata/parameter_sources/elasticlogs_bulk_source.py
+++ b/eventdata/parameter_sources/elasticlogs_bulk_source.py
@@ -68,7 +68,8 @@ def __init__(self, track, params, **kwargs):
             logger.debug("[bulk] Index pattern specified in parameters ({}) will be used".format(params['index']))
 
         if 'type' not in params.keys():
-            self._params['type'] = self._indices[0].types[0].name
+            t = self._indices[0].types[0]
+            self._params['type'] = t if isinstance(t, str) else t.name
 
     def partition(self, partition_index, total_partitions):
         return self
diff --git a/eventdata/parameter_sources/sample_based_bulk_source.py b/eventdata/parameter_sources/sample_based_bulk_source.py
index 5cea6a75571b8..7da3fc6a42315 100755
--- a/eventdata/parameter_sources/sample_based_bulk_source.py
+++ b/eventdata/parameter_sources/sample_based_bulk_source.py
@@ -100,7 +100,8 @@ def __init__(self, track, params, **kwargs):
             logger.debug("[bulk] Index pattern specified in parameters ({}) will be used".format(params['index']))
 
         if 'type' not in params.keys():
-            self._params['type'] = self._indices[0].types[0].name
+            t = self._indices[0].types[0]
+            self._params['type'] = t if isinstance(t, str) else t.name
 
         if 'timestamp_field' not in params.keys():
             self._params['timestamp_field'] = []