diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBSstFileWriter.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBSstFileWriter.java index 6ece671af6..4f9149a2ed 100644 --- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBSstFileWriter.java +++ b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBSstFileWriter.java @@ -257,7 +257,7 @@ public Map sync() { + recordNumInLastSSTFile + ", latency(ms): " + LatencyUtils.getElapsedTimeInMs(startMs)); } } - } else { + } else if (!isRMD) { LOGGER.warn( "Sync gets invoked for store: {}, partition id: {}, but the last sst file: {} is empty", storeName, diff --git a/services/venice-controller/src/main/java/com/linkedin/venice/pushmonitor/PushStatusCollector.java b/services/venice-controller/src/main/java/com/linkedin/venice/pushmonitor/PushStatusCollector.java index a2b72a5241..0cf17b0255 100644 --- a/services/venice-controller/src/main/java/com/linkedin/venice/pushmonitor/PushStatusCollector.java +++ b/services/venice-controller/src/main/java/com/linkedin/venice/pushmonitor/PushStatusCollector.java @@ -143,7 +143,7 @@ private void scanDaVinciPushStatus() { try { pushStatus = future.get(); } catch (Exception e) { - LOGGER.error("Caught exception when getting future result of push status.", e); + LOGGER.error("Caught exception when getting future result of push status : " + e.getMessage()); continue; } ExecutionStatusWithDetails daVinciStatus = pushStatus.getDaVinciStatus();