fix es_read typo (intel-analytics#3186)

yangw1234 · Sep 26, 2021 · c89f7b2 · c89f7b2
1 parent 8a91cc1
commit c89f7b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/orca/src/bigdl/orca/data/elastic_search.py b/python/orca/src/bigdl/orca/data/elastic_search.py
@@ -43,7 +43,7 @@ def read_df(esConfig, esResource, schema=None):
         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])