fix benchmark (Azure#30781)

* fix benchmark Co-authored-by: annie-mac <[email protected]>
azure-sdk · Sep 15, 2022 · d5749bf · d5749bf
1 parent 5de376c
commit d5749bf
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 6 deletions.
diff --git a/...smos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/BenchmarkHelper.java b/...smos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/BenchmarkHelper.java
@@ -29,9 +29,6 @@ public static boolean shouldContinue(long startTimeMillis, long iterationCount,
             return iterationCount < maxNumberOfOperations;
         }
 
-        if (startTimeMillis + maxDurationTime.toMillis() > System.currentTimeMillis()) {
-            return false;
-        }
-        return true;
+        return startTimeMillis + maxDurationTime.toMillis() > System.currentTimeMillis();
     }
 }
diff --git a/...re-cosmos/src/main/java/com/azure/cosmos/implementation/caches/AsyncCacheNonBlocking.java b/...re-cosmos/src/main/java/com/azure/cosmos/implementation/caches/AsyncCacheNonBlocking.java
@@ -207,7 +207,7 @@ private Mono<TValue> createBackgroundRefreshTask(Function<TValue, Mono<TValue>>
                         })
                         .doOnError(throwable -> {
                             this.refreshInProgress.set(null);
-                            logger.warn("Background refresh task failed", throwable);
+                            logger.debug("Background refresh task failed", throwable);
                         })
                         .cache();
         }

diff --git a/...src/main/java/com/azure/cosmos/implementation/directconnectivity/GatewayAddressCache.java b/...src/main/java/com/azure/cosmos/implementation/directconnectivity/GatewayAddressCache.java
@@ -276,7 +276,7 @@ public Mono<Utils.ValueHolder<AddressInformation[]>> tryGetAddresses(RxDocumentS
                     if (Arrays
                             .stream(addressesValueHolder.v)
                             .anyMatch(addressInformation -> addressInformation.getPhysicalUri().shouldRefreshHealthStatus())) {
-                        logger.info("refresh cache due to address uri in unhealthy status");
+                        logger.debug("refresh cache due to address uri in unhealthy status for pkRangeId {}", partitionKeyRangeIdentity.getPartitionKeyRangeId());
                         this.serverPartitionAddressCache.refresh(
                                 partitionKeyRangeIdentity,
                                 cachedAddresses -> this.getAddressesForRangeId(request, partitionKeyRangeIdentity, true, cachedAddresses));