From f9c49f493887347d954f78f0b013b5dcf10200e3 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 4 May 2023 10:22:13 +0000 Subject: [PATCH] add compile opt on windows --- source/libs/stream/src/streamBackendRocksdb.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 2fb60a9ec7..8339d10579 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -168,7 +168,7 @@ int defaultKeyComp(void* state, const char* aBuf, size_t aLen, const char* bBuf, int streamStateValueIsStale(char* vv) { int64_t ts = 0; taosDecodeFixedI64(vv, &ts); - return ts < taosGetTimestampSec() ? 1 : 0; + return (ts != 0 && ts < taosGetTimestampSec()) ? 1 : 0; } int iterValueIsStale(rocksdb_iterator_t* iter) { size_t len;