From 24484288906c882be79b5ac96ae9349d99e45156 Mon Sep 17 00:00:00 2001 From: Moritz Meister <8422705+moritzmeister@users.noreply.github.com> Date: Tue, 22 Dec 2020 17:41:11 +0100 Subject: [PATCH] Fix get storage connector hudi_engine (#203) --- python/hsfs/core/hudi_engine.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/hsfs/core/hudi_engine.py b/python/hsfs/core/hudi_engine.py index 0b80d8a27c..db47b13382 100644 --- 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):