diff --git a/butterfree/configs/db/cassandra_config.py b/butterfree/configs/db/cassandra_config.py index 6d7f9a20..919fee8e 100644 --- a/butterfree/configs/db/cassandra_config.py +++ b/butterfree/configs/db/cassandra_config.py @@ -229,6 +229,7 @@ def translate(self, schema: List[Dict[str, Any]]) -> List[Dict[str, Any]]: """ cassandra_mapping = { "timestamptype": "timestamp", + "timestampntztype": "timestamp", "binarytype": "boolean", "booleantype": "boolean", "datetype": "timestamp",