Fix get storage connector hudi_engine (#203)

logicalclocks · Dec 22, 2020 · 2448428 · 2448428
1 parent fee3f7d
commit 2448428
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/hsfs/core/hudi_engine.py b/python/hsfs/core/hudi_engine.py
@@ -17,7 +17,7 @@
 
 from datetime import datetime
 
-from hsfs import feature_group_commit, storage_connector, util
+from hsfs import feature_group_commit, util
 from hsfs.core import feature_group_api, storage_connector_api
 
 
@@ -80,7 +80,7 @@ def __init__(
             self._feature_store_id
         )
         self._connstr = self._storage_connector_api.get(
-            self._feature_store_name, storage_connector.StorageConnector.JDBC,
+            self._feature_store_name
         ).connection_string
 
     def save_hudi_fg(self, dataset, save_mode, operation, write_options):