thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-30 03:22:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Miscellaneous

Browse Source
This commit is contained in:
Alexey Milovidov 2024-02-19 03:19:21 +01:00
parent 6fd563df52
commit fa1ca348a4
7 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Core/MySQL/PacketEndpoint.cpp
View File

@ -40,7 +40,7 @@ bool PacketEndpoint::tryReceivePacket(IMySQLReadPacket & packet, UInt64 millisec
ReadBufferFromPocoSocket * socket_in = typeid_cast<ReadBufferFromPocoSocket *>(in); ReadBufferFromPocoSocket * socket_in = typeid_cast<ReadBufferFromPocoSocket *>(in);
if (!socket_in) if (!socket_in)
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: Attempt to pull the duration in a non socket stream"); throw Exception(ErrorCodes::LOGICAL_ERROR, "Attempt to pull the duration in a non socket stream");
if (!socket_in->poll(millisecond * 1000)) if (!socket_in->poll(millisecond * 1000))
return false; return false;

4
src/Databases/MySQL/MaterializedMySQLSyncThread.cpp
View File

@ -779,7 +779,7 @@ static void writeFieldsToColumn(
casted_int32_column->insertValue(num & 0x800000 ? num | 0xFF000000 : num); casted_int32_column->insertValue(num & 0x800000 ? num | 0xFF000000 : num);
} }
else else
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: it is a bug."); throw Exception(ErrorCodes::LOGICAL_ERROR, "MaterializedMySQL is a bug.");
} }
} }
} }
@ -844,7 +844,7 @@ static inline bool differenceSortingKeys(const Tuple & row_old_data, const Tuple
static inline size_t onUpdateData(const Row & rows_data, Block & buffer, size_t version, const std::vector<size_t> & sorting_columns_index) static inline size_t onUpdateData(const Row & rows_data, Block & buffer, size_t version, const std::vector<size_t> & sorting_columns_index)
{ {
if (rows_data.size() % 2 != 0) if (rows_data.size() % 2 != 0)
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: It is a bug."); throw Exception(ErrorCodes::LOGICAL_ERROR, "MaterializedMySQL is a bug.");
size_t prev_bytes = buffer.bytes(); size_t prev_bytes = buffer.bytes();
std::vector<bool> writeable_rows_mask(rows_data.size()); std::vector<bool> writeable_rows_mask(rows_data.size());

2
src/Functions/FunctionsConversion.h
View File

@ -2560,7 +2560,7 @@ public:
if constexpr (std::is_same_v<ToDataType, DataTypeDateTime>) if constexpr (std::is_same_v<ToDataType, DataTypeDateTime>)
res = std::make_shared<DataTypeDateTime>(extractTimeZoneNameFromFunctionArguments(arguments, 1, 0, false)); res = std::make_shared<DataTypeDateTime>(extractTimeZoneNameFromFunctionArguments(arguments, 1, 0, false));
else if constexpr (std::is_same_v<ToDataType, DataTypeDateTime64>) else if constexpr (std::is_same_v<ToDataType, DataTypeDateTime64>)
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: It is a bug."); throw Exception(ErrorCodes::LOGICAL_ERROR, "MaterializedMySQL is a bug.");
else if constexpr (to_decimal) else if constexpr (to_decimal)
{ {
UInt64 scale = extractToDecimalScale(arguments[1]); UInt64 scale = extractToDecimalScale(arguments[1]);

2
src/Interpreters/MySQL/InterpretersMySQLDDLQuery.cpp
View File

@ -337,7 +337,7 @@ static ASTPtr getPartitionPolicy(const NamesAndTypesList & primary_keys)
WhichDataType which(type); WhichDataType which(type);
if (which.isNullable()) if (which.isNullable())
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: MySQL primary key must be not null, it is a bug."); throw Exception(ErrorCodes::LOGICAL_ERROR, "MySQL's primary key must be not null, it is a bug.");
if (which.isDate() || which.isDate32() || which.isDateTime() || which.isDateTime64()) if (which.isDate() || which.isDate32() || which.isDateTime() || which.isDateTime64())
{ {

2
src/Server/HTTPHandlerFactory.cpp
View File

@ -120,7 +120,7 @@ HTTPRequestHandlerFactoryPtr createHandlerFactory(IServer & server, const Poco::
return createPrometheusMainHandlerFactory(server, config, metrics_writer, name); return createPrometheusMainHandlerFactory(server, config, metrics_writer, name);
} }
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: Unknown HTTP handler factory name."); throw Exception(ErrorCodes::LOGICAL_ERROR, "Unknown HTTP handler factory name.");
} }

2
src/Storages/MergeTree/MergeTreeIndexConditionBloomFilter.cpp
View File

@ -59,7 +59,7 @@ bool maybeTrueOnBloomFilter(const IColumn * hash_column, const BloomFilterPtr &
const auto * non_const_column = typeid_cast<const ColumnUInt64 *>(hash_column); const auto * non_const_column = typeid_cast<const ColumnUInt64 *>(hash_column);
if (!const_column && !non_const_column) if (!const_column && !non_const_column)
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: hash column must be Const Column or UInt64 Column."); throw Exception(ErrorCodes::LOGICAL_ERROR, "Hash column must be Const or UInt64.");
if (const_column) if (const_column)
{ {

2
src/Storages/MergeTree/MergeTreeIndexConditionBloomFilter.h
View File

@ -53,7 +53,7 @@ public:
if (const auto & bf_granule = typeid_cast<const MergeTreeIndexGranuleBloomFilter *>(granule.get())) if (const auto & bf_granule = typeid_cast<const MergeTreeIndexGranuleBloomFilter *>(granule.get()))
return mayBeTrueOnGranule(bf_granule); return mayBeTrueOnGranule(bf_granule);
throw Exception(ErrorCodes::LOGICAL_ERROR, "LOGICAL ERROR: require bloom filter index granule."); throw Exception(ErrorCodes::LOGICAL_ERROR, "Requires bloom filter index granule.");
} }
private: private: