[CASSANDRA-16814] Fix cassandra to gcs type inconsistency. (#17183)

apache · Jul 23, 2021 · 81bd409 · 81bd409
1 parent 5be1286
commit 81bd409
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/airflow/providers/google/cloud/transfers/cassandra_to_gcs.py b/airflow/providers/google/cloud/transfers/cassandra_to_gcs.py
@@ -136,9 +136,9 @@ def __init__(
 
  # Default Cassandra to BigQuery type mapping
  CQL_TYPE_MAP = {
- 'BytesType': 'BYTES',
+ 'BytesType': 'STRING',
  'DecimalType': 'FLOAT',
- 'UUIDType': 'BYTES',
+ 'UUIDType': 'STRING',
  'BooleanType': 'BOOL',
  'ByteType': 'INTEGER',
  'AsciiType': 'STRING',
@@ -152,7 +152,7 @@ def __init__(
  'DateType': 'TIMESTAMP',
  'SimpleDateType': 'DATE',
  'TimestampType': 'TIMESTAMP',
- 'TimeUUIDType': 'BYTES',
+ 'TimeUUIDType': 'STRING',
  'ShortType': 'INTEGER',
  'TimeType': 'TIME',
  'DurationType': 'INTEGER',