Fix minor things

This commit is contained in:
divanik 2024-07-19 13:30:46 +00:00
parent 45e0f0350e
commit 07d03c0c67
4 changed files with 5 additions and 15 deletions

View File

@ -80,7 +80,6 @@ UUID parseUUID(std::span<const UInt8> src)
return uuid;
}
void NO_INLINE throwAtAssertionFailed(const char * s, ReadBuffer & buf)
{
WriteBufferFromOwnString out;
@ -89,15 +88,12 @@ void NO_INLINE throwAtAssertionFailed(const char * s, ReadBuffer & buf)
if (buf.eof())
out << " at end of stream.";
else
out << " before: " << quote << String(buf.position(), std::min(static_cast<ptrdiff_t>(1000), buf.buffer().end() - buf.position()));
out << " before: " << quote << String(buf.position(), std::min(SHOW_CHARS_ON_SYNTAX_ERROR, buf.buffer().end() - buf.position()));
throw Exception(
ErrorCodes::CANNOT_PARSE_INPUT_ASSERTION_FAILED,
"Cannot parse input: expected {} {}",
out.str(),
buf.buffer().end() - buf.position());
throw Exception(ErrorCodes::CANNOT_PARSE_INPUT_ASSERTION_FAILED, "Cannot parse input: expected {}", out.str());
}
bool checkString(const char * s, ReadBuffer & buf)
{
for (; *s; ++s)

View File

@ -125,12 +125,6 @@ public:
, num_streams(num_streams_)
, distributed_processing(distributed_processing_)
{
LOG_DEBUG(&Poco::Logger::get("Read step created"), "Read step created");
LOG_DEBUG(&Poco::Logger::get("Conf"), "Keys size: {}", configuration->getPaths().size());
for (auto && key : configuration->getPaths())
{
LOG_DEBUG(&Poco::Logger::get("Conf"), "Current key: {}", key);
}
}
std::string getName() const override { return name; }

View File

@ -1,3 +1,3 @@
<clickhouse>
<path>/var/lib/clickhouse/</path>
</clickhouse>
</clickhouse>

View File

@ -1,3 +1,3 @@
id,data
1,Str1
2,Str2
2,Str2

1 id data
2 1 Str1
3 2 Str2