tmp 2

Author: bubriks

Diff for: python/hsfs/engine/spark.py

@@ -195,7 +195,7 @@ def register_external_temporary_table(self, external_fg, alias):
                 external_fg.options,
                 external_fg.get_uri(),
             )
-        elif isinstance(external_fg, fg_mod.SpineGroup):
+        else:
             external_dataset = external_fg.dataframe
         if external_fg.location:
             self._spark_session.sparkContext.textFile(external_fg.location).collect()
@@ -219,9 +219,10 @@ def register_hudi_temporary_table(
             read_options,
         )
 
-        hudi_engine_instance.reconcile_hudi_schema(
-            self.save_empty_dataframe, hudi_fg_alias, read_options
-        )
+        if (hudi_fg_alias._feature_group.storage_connector is None):
+            hudi_engine_instance.reconcile_hudi_schema(
+                self.save_empty_dataframe, hudi_fg_alias, read_options
+            )
 
     def register_delta_temporary_table(
         self, delta_fg_alias, feature_store_id, feature_store_name, read_options