From 6fc4a510348f38564cea74d7185266817bb89356 Mon Sep 17 00:00:00 2001 From: bubriks Date: Wed, 23 Oct 2024 14:04:47 +0300 Subject: [PATCH] init --- python/hsfs/engine/spark.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/hsfs/engine/spark.py b/python/hsfs/engine/spark.py index 4fd42a648d..2a4446c7f7 100644 --- a/python/hsfs/engine/spark.py +++ b/python/hsfs/engine/spark.py @@ -183,7 +183,7 @@ def register_external_temporary_table(self, external_fg, alias): external_fg.query, external_fg.data_format, external_fg.options, - external_fg.prepare_spark_location(), + external_fg.storage_connector._get_path(external_fg.path), # cant rely on location since this method can be used before FG is saved ) else: external_dataset = external_fg.dataframe