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

Add debug logging

Browse Source
This commit is contained in:
kssenii 2024-08-05 16:40:54 +02:00
parent ba3099015f
commit e9506202d6
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/Storages/WindowView/StorageWindowView.cpp
View File

@ -1055,6 +1055,8 @@ void StorageWindowView::threadFuncFireProc()
/// TODO: consider using time_t instead (for every timestamp in this class)
UInt32 timestamp_now = now();
LOG_TRACE(log, "Now: {}, next fire signal: {}, max watermark: {}", timestamp_now, next_fire_signal, max_watermark);
while (next_fire_signal <= timestamp_now)
{
try
@ -1072,6 +1074,9 @@ void StorageWindowView::threadFuncFireProc()
if (slide_kind > IntervalKind::Kind::Day)
slide_interval *= 86400;
next_fire_signal += slide_interval;
LOG_TRACE(log, "Now: {}, next fire signal: {}, max watermark: {}, max fired watermark: {}, slide interval: {}",
timestamp_now, next_fire_signal, max_watermark, max_fired_watermark, slide_interval);
}
if (max_watermark >= timestamp_now)
@ -1433,16 +1438,19 @@ void StorageWindowView::writeIntoWindowView(
while (window_view.modifying_query)
std::this_thread::sleep_for(std::chrono::milliseconds(100));
if (!window_view.is_proctime && window_view.max_watermark == 0 && block.rows() > 0)
const size_t block_rows = block.rows();
if (!window_view.is_proctime && window_view.max_watermark == 0 && block_rows > 0)
{
std::lock_guard lock(window_view.fire_signal_mutex);
const auto & window_column = block.getByName(window_view.timestamp_column_name);
const ColumnUInt32::Container & window_end_data = static_cast<const ColumnUInt32 &>(*window_column.column).getData();
UInt32 first_record_timestamp = window_end_data[0];
window_view.max_watermark = window_view.getWindowUpperBound(first_record_timestamp);
LOG_TRACE(window_view.log, "New max watermark: {}", window_view.max_watermark);
}
Pipe pipe(std::make_shared<SourceFromSingleChunk>(block));
Pipe pipe(std::make_shared<SourceFromSingleChunk>(std::move(block)));
UInt32 lateness_bound = 0;
UInt32 t_max_watermark = 0;
@ -1649,6 +1657,8 @@ void StorageWindowView::writeIntoWindowView(
auto executor = builder.execute();
executor->execute(builder.getNumThreads(), local_context->getSettingsRef().use_concurrency_control);
LOG_TRACE(window_view.log, "Wrote {} rows into inner table ({})", block_rows, inner_table->getStorageID().getFullTableName());
}
void StorageWindowView::startup()