diff --git a/ingestion/src/metadata/ingestion/source/database/hive.py b/ingestion/src/metadata/ingestion/source/database/hive.py index 6f18a0e2319..314f5baf7e0 100644 --- a/ingestion/src/metadata/ingestion/source/database/hive.py +++ b/ingestion/src/metadata/ingestion/source/database/hive.py @@ -183,7 +183,9 @@ class HiveSource(CommonDbSourceService): return cls(config, metadata_config) def _parse_version(self, version: str) -> Tuple: - return tuple(map(int, (version.split(".")))) + if "-" in version: + version = version.replace("-", ".") + return tuple(map(int, (version.split(".")[:3]))) def prepare(self): """