diff --git a/backends-clickhouse/src/test/resources/text-data/json-settings/data.txt b/backends-clickhouse/src/test/resources/text-data/json-settings/data.txt index 230b46ec3803..0541ce3469a7 100644 --- a/backends-clickhouse/src/test/resources/text-data/json-settings/data.txt +++ b/backends-clickhouse/src/test/resources/text-data/json-settings/data.txt @@ -1,5 +1,4 @@ {"a":1,"b":2,"c":3} -{"a":"a5", "B":"b6", "c":7} {"a":"4"} {"t":{"ta":"cc","tb":100,"tc":1.234}} {"t":{"ta":"cc","tb":100,"td":"ignore"}} diff --git a/cpp-ch/clickhouse.version b/cpp-ch/clickhouse.version index 46b23e5f0e61..cede6e7d0398 100644 --- a/cpp-ch/clickhouse.version +++ b/cpp-ch/clickhouse.version @@ -1,4 +1,4 @@ CH_ORG=Kyligence -CH_BRANCH=rebase_ch/20240806 -CH_COMMIT=c8a7d6e496d +CH_BRANCH=rebase_ch/20240808 +CH_COMMIT=641bd1900cd diff --git a/cpp-ch/local-engine/Common/CHUtil.cpp b/cpp-ch/local-engine/Common/CHUtil.cpp index d32eed92340a..35b4f0c97806 100644 --- a/cpp-ch/local-engine/Common/CHUtil.cpp +++ b/cpp-ch/local-engine/Common/CHUtil.cpp @@ -781,7 +781,6 @@ void BackendInitializerUtil::initSettings(std::map & b settings.set("input_format_parquet_import_nested", true); settings.set("input_format_json_read_numbers_as_strings", true); settings.set("input_format_json_read_bools_as_numbers", false); - settings.set("input_format_json_case_insensitive_column_matching", true); settings.set("input_format_csv_trim_whitespaces", false); settings.set("input_format_csv_allow_cr_end_of_line", true); settings.set("output_format_orc_string_as_string", true); diff --git a/cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.h b/cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.h index a9c796a7556b..b930df0cac95 100644 --- a/cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.h +++ b/cpp-ch/local-engine/Storages/Parquet/VectorizedParquetRecordReader.h @@ -235,7 +235,7 @@ class VectorizedParquetBlockInputFormat final : public DB::IInputFormat ColumnIndexFilterPtr column_index_filter_; protected: - void onCancel() override { is_stopped = 1; } + void onCancel() noexcept override { is_stopped = 1; } public: VectorizedParquetBlockInputFormat(DB::ReadBuffer & in_, const DB::Block & header_, const DB::FormatSettings & format_settings); diff --git a/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp b/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp index d4e9f1eb8d4b..d8f0ee0e3552 100644 --- a/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp +++ b/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.cpp @@ -144,7 +144,7 @@ bool SubstraitFileSource::tryPrepareReader() } -void SubstraitFileSource::onCancel() +void SubstraitFileSource::onCancel() noexcept { if (file_reader) file_reader->cancel(); diff --git a/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h b/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h index 571e4097107a..113538a92922 100644 --- a/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h +++ b/cpp-ch/local-engine/Storages/SubstraitSource/SubstraitFileSource.h @@ -131,7 +131,7 @@ class SubstraitFileSource : public DB::SourceWithKeyCondition private: bool tryPrepareReader(); - void onCancel() override; + void onCancel() noexcept override; DB::ContextPtr context; DB::Block output_header; /// Sample header may contains partitions keys diff --git a/cpp-ch/local-engine/tests/gtest_spark_row.cpp b/cpp-ch/local-engine/tests/gtest_spark_row.cpp index 0350bb16c705..963f7736858f 100644 --- a/cpp-ch/local-engine/tests/gtest_spark_row.cpp +++ b/cpp-ch/local-engine/tests/gtest_spark_row.cpp @@ -136,7 +136,7 @@ TEST(SparkRow, GetArrayElementSize) {std::make_shared(), 4}, {std::make_shared(), 4}, {std::make_shared(), 4}, - {std::make_shared(9, 4), 4}, + {std::make_shared(9, 4), 8}, {std::make_shared(), 8}, {std::make_shared(), 8}, {std::make_shared(), 8}, @@ -152,11 +152,11 @@ TEST(SparkRow, GetArrayElementSize) for (const auto & [type, size] : type_to_size) { - EXPECT_TRUE(BackingDataLengthCalculator::getArrayElementSize(type) == size); + EXPECT_EQ(size, BackingDataLengthCalculator::getArrayElementSize(type)); if (type->canBeInsideNullable()) { const auto type_with_nullable = std::make_shared(type); - EXPECT_TRUE(BackingDataLengthCalculator::getArrayElementSize(type_with_nullable) == size); + EXPECT_EQ(size, BackingDataLengthCalculator::getArrayElementSize(type_with_nullable)); } } }