diff --git a/services/distributeddataservice/service/kvdb/kvdb_general_store.cpp b/services/distributeddataservice/service/kvdb/kvdb_general_store.cpp
index b825f970c85d4e4392cb8a82c523df6d05ec1819..f18d59547fa5cbb3b8d3605abf5c8d9c1dba174c 100644
--- a/services/distributeddataservice/service/kvdb/kvdb_general_store.cpp
+++ b/services/distributeddataservice/service/kvdb/kvdb_general_store.cpp
@@ -443,8 +443,8 @@ std::pair<int32_t, int32_t> KVDBGeneralStore::Sync(const Devices &devices, GenQu
             dbStatus =
                 delegate_->UnSubscribeRemoteQuery(devices, GetDBSyncCompleteCB(std::move(async)), dbQuery, false);
         } else if (syncMode < NEARBY_END) {
-            DeviceSyncOption syncOption = { .devices = devices, .mode = dbMode, .query = dbQuery, .isWait = false,
-                .isRetry = syncParam.isRetry };
+            DeviceSyncOption syncOption = { .devices = devices, .mode = dbMode, .isQuery = !kvQuery->IsEmpty(),
+                .query = dbQuery, .isWait = false, .isRetry = syncParam.isRetry };
             dbStatus = delegate_->Sync(syncOption, GetDBSyncCompleteCB(std::move(async)));
         } else {
             ZLOGE("Err sync mode! sync mode:%{public}d", syncMode);