diff --git a/tap_mysql/discover_utils.py b/tap_mysql/discover_utils.py index 1cdd789..3d24a77 100644 --- a/tap_mysql/discover_utils.py +++ b/tap_mysql/discover_utils.py @@ -271,7 +271,7 @@ def schema_for_column(column): # pylint: disable=too-many-branches result.multipleOf = 10 ** (0 - column.numeric_scale) elif data_type in JSON_TYPES: - result.type = ['null', 'object'] + result.type = ['null', 'string'] elif data_type in STRING_TYPES: result.type = ['null', 'string'] @@ -290,7 +290,7 @@ def schema_for_column(column): # pylint: disable=too-many-branches result.format = 'binary' elif data_type in SPATIAL_TYPES: - result.type = ['null', 'object'] + result.type = ['null', 'string'] result.format = 'spatial' else: