diff --git a/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseRowBinaryProcessor.java b/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseRowBinaryProcessor.java index 76befea40..583c475ea 100644 --- a/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseRowBinaryProcessor.java +++ b/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseRowBinaryProcessor.java @@ -374,7 +374,7 @@ private void buildMappingsForDataTypes() { for (int k = 0, len = BinaryStreamUtils.readVarInt(i); k < len; k++) { map.put(deserialize(null, f, keyCol, i).asObject(), deserialize(null, f, valCol, i).asObject()); } - return ClickHouseMapValue.of(map, valCol.getDataType().getObjectClass(), + return ClickHouseMapValue.of(map, keyCol.getDataType().getObjectClass(), valCol.getDataType().getObjectClass()); }, (v, f, c, o) -> { Map map = v.asMap();