From 124c8662e89965e5d087ccbaf299e6c82345be95 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Wed, 11 Jan 2023 08:37:39 +0800 Subject: [PATCH] [Bug](schema scanner) Fix wrong type in schema scanner (#15768) --- .../schema_scanner/schema_columns_scanner.cpp | 20 ++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) diff --git a/be/src/exec/schema_scanner/schema_columns_scanner.cpp b/be/src/exec/schema_scanner/schema_columns_scanner.cpp index 3ccdfc42ab..fcf78542bf 100644 --- a/be/src/exec/schema_scanner/schema_columns_scanner.cpp +++ b/be/src/exec/schema_scanner/schema_columns_scanner.cpp @@ -149,7 +149,7 @@ std::string SchemaColumnsScanner::type_to_string(TColumnDesc& desc) { case TPrimitiveType::BIGINT: return "bigint(20)"; case TPrimitiveType::LARGEINT: - return "bigint(20) unsigned"; + return "largeint"; case TPrimitiveType::FLOAT: return "float"; case TPrimitiveType::DOUBLE: @@ -189,6 +189,24 @@ std::string SchemaColumnsScanner::type_to_string(TColumnDesc& desc) { stream << ")"; return stream.str(); } + case TPrimitiveType::DECIMAL32: + case TPrimitiveType::DECIMAL64: + case TPrimitiveType::DECIMAL128I: { + fmt::memory_buffer debug_string_buffer; + fmt::format_to( + debug_string_buffer, "decimalv3({}, {})", + desc.__isset.columnPrecision ? std::to_string(desc.columnPrecision) : "UNKNOWN", + desc.__isset.columnScale ? std::to_string(desc.columnScale) : "UNKNOWN"); + return fmt::to_string(debug_string_buffer); + } + case TPrimitiveType::DATEV2: + return "datev2"; + case TPrimitiveType::DATETIMEV2: { + fmt::memory_buffer debug_string_buffer; + fmt::format_to(debug_string_buffer, "datetimev2({})", + desc.__isset.columnScale ? std::to_string(desc.columnScale) : "UNKNOWN"); + return fmt::to_string(debug_string_buffer); + } case TPrimitiveType::HLL: { return "hll"; }