add compile opt on windows

f9c49f49 · dengyihao · 8b483965 · f9c49f49
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +1 -1

未找到文件。
--- 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;