Log existing datastream for update and delete call (#948)

Co-authored-by: Vaibhav Maheshwari <vmaheshw@vmaheshw-mn2.linkedin.biz>
linkedin · Jul 10, 2023 · 9f3c26a · 9f3c26a
1 parent c317f12
commit 9f3c26a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...m-server-restli/src/main/java/com/linkedin/datastream/server/dms/DatastreamResources.java b/...m-server-restli/src/main/java/com/linkedin/datastream/server/dms/DatastreamResources.java
@@ -245,6 +245,8 @@ private void doUpdateDatastreams(Map<String, Datastream> datastreamMap) {
           throw new DatastreamValidationException(String.format("Failed to update %s. Can't update numTasks."
               + " old: %s new: %s", key, oldDatastream, datastream));
         }
+
+        LOG.info("[UPDATE] old datastream = {}, new datastream = {}", oldDatastream, datastream);
       } catch (DatastreamValidationException e) {
         _dynamicMetricsManager.createOrUpdateMeter(CLASS_NAME, CALL_ERROR, 1);
         _errorLogger.logAndThrowRestLiServiceException(HttpStatus.S_400_BAD_REQUEST, e.getMessage());
@@ -766,7 +768,7 @@ public UpdateResponse delete(String datastreamName) {
     }
 
     try {
-      LOG.info("Delete datastream called for datastream " + datastreamName);
+      LOG.info("[DELETE] operation called for datastream {} = {}", datastreamName, datastream);
 
       _dynamicMetricsManager.createOrUpdateMeter(CLASS_NAME, DELETE_CALL, 1);
       Instant startTime = Instant.now();