diff --git a/ingestion/examples/airflow/dags/airflow_metadata_to_es.py b/ingestion/examples/airflow/dags/airflow_metadata_to_es.py
index fbbfa9656bd..9fa56c2d7c5 100644
--- a/ingestion/examples/airflow/dags/airflow_metadata_to_es.py
+++ b/ingestion/examples/airflow/dags/airflow_metadata_to_es.py
@@ -49,7 +49,7 @@ config = """
     "sourceConfig":{"config":{}}
   },
   "sink": {
-    "type": "elasticsearch_mapping",
+    "type": "elasticsearch",
     "config": {
       "index_tables": "true",
       "index_topics": "true",
diff --git a/ingestion/src/metadata/ingestion/sink/elasticsearch.py b/ingestion/src/metadata/ingestion/sink/elasticsearch.py
index 860969ae902..380045d8412 100644
--- a/ingestion/src/metadata/ingestion/sink/elasticsearch.py
+++ b/ingestion/src/metadata/ingestion/sink/elasticsearch.py
@@ -35,7 +35,6 @@ from metadata.generated.schema.entity.services.connections.metadata.openMetadata
 from metadata.generated.schema.entity.tags.tagCategory import TagCategory
 from metadata.generated.schema.entity.teams.team import Team
 from metadata.generated.schema.entity.teams.user import User
-from metadata.generated.schema.type import entityReference
 from metadata.generated.schema.type.entityReference import EntityReference
 from metadata.ingestion.api.common import Entity
 from metadata.ingestion.api.sink import Sink, SinkStatus