From 5485a4e4417d73ac67a0985083c6e162920f6e86 Mon Sep 17 00:00:00 2001 From: Kanthi Subramanian Date: Sun, 31 Jul 2022 10:05:23 -0400 Subject: [PATCH] Map INT32 Kafka connect to INT256 CH type --- .../sink/connector/converters/ClickHouseDataTypeMapper.java | 3 ++- .../connector/converters/ClickHouseDataTypeMapperTest.java | 3 +++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java b/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java index 4e484f5c5..9181248bb 100644 --- a/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java +++ b/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java @@ -25,7 +25,8 @@ public class ClickHouseDataTypeMapper { dataTypesMap.put(new MutablePair(Schema.INT16_SCHEMA.type(), null), ClickHouseDataType.Int16); dataTypesMap.put(new MutablePair(Schema.INT8_SCHEMA.type(), null), ClickHouseDataType.Int8); dataTypesMap.put(new MutablePair(Schema.INT32_SCHEMA.type(), null), ClickHouseDataType.Int32); - dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int64); + + dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int256); // Float dataTypesMap.put(new MutablePair(Schema.FLOAT32_SCHEMA.type(), null), ClickHouseDataType.Float32); diff --git a/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java b/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java index 464b58cd7..69d9298fa 100644 --- a/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java +++ b/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java @@ -26,6 +26,9 @@ public void getClickHouseDataType() { chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT32_SCHEMA.type(), Date.SCHEMA_NAME); Assert.assertTrue(chDataType.name().equalsIgnoreCase("Date32")); + chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT64_SCHEMA.type(), null); + Assert.assertTrue(chDataType.name().equalsIgnoreCase("INT256")); + } }