diff --git a/python/orca/src/bigdl/orca/data/elastic_search.py b/python/orca/src/bigdl/orca/data/elastic_search.py
index <HASH>..<HASH> 100644
--- a/python/orca/src/bigdl/orca/data/elastic_search.py
+++ b/python/orca/src/bigdl/orca/data/elastic_search.py
@@ -43,7 +43,7 @@ class elastic_search:
         sqlContext = SQLContext.getOrCreate(sc)
         spark = sqlContext.sparkSession
 
-        reader = spark.read_df.format("org.elasticsearch.spark.sql")
+        reader = spark.read.format("org.elasticsearch.spark.sql")
 
         for key in esConfig:
             reader.option(key, esConfig[key])
fix es_read typo (#<I>)