thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 09:32:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #8625 from Vxider/fix-liveview-timestamp

Browse Source 
fix liveview timestamp bug
This commit is contained in:
alexey-milovidov 2020-01-13 17:55:10 +03:00 committed by GitHub
commit 166e44922f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/Storages/LiveView/LiveViewBlockInputStream.h
View File

@ -149,7 +149,7 @@ protected:
} }
while (true) while (true)
{ {
UInt64 timestamp_usec = static_cast<UInt64>(timestamp.epochMicroseconds()); UInt64 timestamp_usec = static_cast<UInt64>(Poco::Timestamp().epochMicroseconds());
/// Or spurious wakeup. /// Or spurious wakeup.
bool signaled = std::cv_status::no_timeout == storage->condition.wait_for(lock, bool signaled = std::cv_status::no_timeout == storage->condition.wait_for(lock,
@ -166,7 +166,7 @@ protected:
else else
{ {
// heartbeat // heartbeat
last_event_timestamp_usec = static_cast<UInt64>(timestamp.epochMicroseconds()); last_event_timestamp_usec = static_cast<UInt64>(Poco::Timestamp().epochMicroseconds());
return { getHeader(), true }; return { getHeader(), true };
} }
} }
@ -207,7 +207,6 @@ private:
UInt64 heartbeat_interval_usec; UInt64 heartbeat_interval_usec;
UInt64 temporary_live_view_timeout_sec; UInt64 temporary_live_view_timeout_sec;
UInt64 last_event_timestamp_usec = 0; UInt64 last_event_timestamp_usec = 0;
Poco::Timestamp timestamp;
}; };
} }