diff --git a/ingestion/src/metadata/ingestion/source/sql_source.py b/ingestion/src/metadata/ingestion/source/sql_source.py index ec91c26c40e..2bee39d206f 100644 --- a/ingestion/src/metadata/ingestion/source/sql_source.py +++ b/ingestion/src/metadata/ingestion/source/sql_source.py @@ -394,6 +394,7 @@ class SQLSource(Source[OMetaDatabaseAndTable]): manifest_columns = mnode.get("columns", {}) for key in ccolumns: ccolumn = ccolumns[key] + col_name = ccolumn["name"].lower().replace(".", "_DOT_") try: ctype = ccolumn["type"] col_type = ColumnTypeParser.get_column_type(ctype) @@ -403,7 +404,7 @@ class SQLSource(Source[OMetaDatabaseAndTable]): if description is None: description = ccolumn.get("comment", None) col = Column( - name=ccolumn["name"].lower(), + name=col_name, description=description, dataType=col_type, dataLength=1, @@ -411,7 +412,7 @@ class SQLSource(Source[OMetaDatabaseAndTable]): ) columns.append(col) except Exception as err: # pylint: disable=broad-except - logger.error(f"Failed to parse column type due to {err}") + logger.error(f"Failed to parse column {col_name} due to {err}") return columns