From da490cf44bbc85bda6e75ff4d7dd3d80917d3f72 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Thu, 17 Nov 2022 17:01:23 +0530 Subject: [PATCH] Fix #8658: Redshift Data Type Incorrect (#8808) --- .../src/metadata/ingestion/source/database/redshift.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/database/redshift.py b/ingestion/src/metadata/ingestion/source/database/redshift.py index fdca853bfa4..5658d9ec966 100644 --- a/ingestion/src/metadata/ingestion/source/database/redshift.py +++ b/ingestion/src/metadata/ingestion/source/database/redshift.py @@ -146,12 +146,15 @@ def _get_column_info(self, *args, **kwargs): column_info = super( # pylint: disable=protected-access RedshiftDialectMixin, self )._get_column_info(*args, **kwdrs) - column_info["raw_data_type"] = kwdrs["format_type"] + + # raw_data_type is not included in column_info as + # redhift doesn't suport compex data types directly + # https://docs.aws.amazon.com/redshift/latest/dg/c_Supported_data_types.html if isinstance(column_info["type"], VARCHAR): if column_info["type"].length is None: column_info["type"] = NullType() - if re.match("char", column_info["raw_data_type"]): + if re.match("char", kwdrs["format_type"]): column_info["type"] = CHAR if "info" not in column_info: