[CH-197] Fix bug when c2r with const columns (#198)

* close #197 * fix gtest build error
Kyligence · Nov 18, 2022 · 0fc2fae · 0fc2fae
1 parent 4fda39e
commit 0fc2fae
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/utils/local-engine/Common/Logger.h b/utils/local-engine/Common/Logger.h
@@ -8,7 +8,7 @@ namespace local_engine
 class Logger
 {
 public:
-    static void initConsoleLogger(const std::string & level);
+    static void initConsoleLogger(const std::string & level = "error");
     static void initFileLogger(Poco::Util::AbstractConfiguration & config, const std::string & cmd_name);
 };
 }

diff --git a/utils/local-engine/Parser/CHColumnToSparkRow.cpp b/utils/local-engine/Parser/CHColumnToSparkRow.cpp
@@ -352,10 +352,12 @@ std::unique_ptr<SparkRowInfo> CHColumnToSparkRow::convertCHColumnToSparkRow(cons
     {
         const auto & col = block.getByPosition(col_idx);
         int64_t field_offset = spark_row_info->getFieldOffset(col_idx);
+
+        ColumnWithTypeAndName col_not_const{col.column->convertToFullColumnIfConst(), col.type, col.name};
         writeValue(
             spark_row_info->getBufferAddress(),
             field_offset,
-            col,
+            col_not_const,
             col_idx,
             spark_row_info->getNumRows(),
             spark_row_info->getOffsets(),