[Transform] Raise loglevel of events related to transform lifecycle f…

…rom DEBUG to INFO (#106602)
elastic · Mar 26, 2024 · 58ed093 · 58ed093
1 parent 1688801
commit 58ed093
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 5 deletions.
diff --git a/docs/changelog/106602.yaml b/docs/changelog/106602.yaml
@@ -0,0 +1,5 @@
+pr: 106602
+summary: Raise loglevel of events related to transform lifecycle from DEBUG to INFO
+area: Transform
+type: enhancement
+issues: []
diff --git a/...rc/main/java/org/elasticsearch/xpack/transform/action/TransportDeleteTransformAction.java b/...rc/main/java/org/elasticsearch/xpack/transform/action/TransportDeleteTransformAction.java
@@ -95,7 +95,7 @@ protected void masterOperation(Task task, Request request, ClusterState state, A
         // <3> Delete transform config
         ActionListener<AcknowledgedResponse> deleteDestIndexListener = ActionListener.wrap(
             unusedAcknowledgedResponse -> transformConfigManager.deleteTransform(request.getId(), ActionListener.wrap(r -> {
-                logger.debug("[{}] deleted transform", request.getId());
+                logger.info("[{}] deleted transform", request.getId());
                 auditor.info(request.getId(), "Deleted transform.");
                 listener.onResponse(AcknowledgedResponse.of(r));
             }, listener::onFailure)),

diff --git a/...m/src/main/java/org/elasticsearch/xpack/transform/action/TransportPutTransformAction.java b/...m/src/main/java/org/elasticsearch/xpack/transform/action/TransportPutTransformAction.java
@@ -168,7 +168,7 @@ private void putTransform(Request request, ActionListener<AcknowledgedResponse>
         var config = request.getConfig();
         transformConfigManager.putTransformConfiguration(config, listener.delegateFailureAndWrap((l, unused) -> {
             var transformId = config.getId();
-            logger.debug("[{}] created transform", transformId);
+            logger.info("[{}] created transform", transformId);
             auditor.info(transformId, "Created transform.");
 
             var validationFunc = FunctionFactory.create(config);

diff --git a/...src/main/java/org/elasticsearch/xpack/transform/action/TransportResetTransformAction.java b/...src/main/java/org/elasticsearch/xpack/transform/action/TransportResetTransformAction.java
@@ -110,7 +110,7 @@ protected void masterOperation(Task task, Request request, ClusterState state, A
         // <4> Reset transform
         ActionListener<TransformUpdater.UpdateResult> updateTransformListener = ActionListener.wrap(
             unusedUpdateResult -> transformConfigManager.resetTransform(request.getId(), ActionListener.wrap(resetResponse -> {
-                logger.debug("[{}] reset transform", request.getId());
+                logger.info("[{}] reset transform", request.getId());
                 auditor.info(request.getId(), "Reset transform.");
                 listener.onResponse(AcknowledgedResponse.of(resetResponse));
             }, listener::onFailure)),

diff --git a/...rc/main/java/org/elasticsearch/xpack/transform/action/TransportUpdateTransformAction.java b/...rc/main/java/org/elasticsearch/xpack/transform/action/TransportUpdateTransformAction.java
@@ -154,7 +154,7 @@ protected void doExecute(Task task, Request request, ActionListener<Response> li
                         TransformConfig updatedConfig = updateResult.getConfig();
                         AuthorizationState authState = updateResult.getAuthState();
                         auditor.info(updatedConfig.getId(), "Updated transform.");
-                        logger.debug("[{}] Updated transform [{}]", updatedConfig.getId(), updateResult.getStatus());
+                        logger.info("[{}] Updated transform [{}]", updatedConfig.getId(), updateResult.getStatus());
 
                         checkTransformConfigAndLogWarnings(updatedConfig);
 

diff --git a/.../main/java/org/elasticsearch/xpack/transform/action/TransportUpgradeTransformsAction.java b/.../main/java/org/elasticsearch/xpack/transform/action/TransportUpgradeTransformsAction.java
@@ -199,7 +199,7 @@ private void recursiveUpdate(
         updateOneTransform(next, dryRun, timeout, ActionListener.wrap(updateResponse -> {
             if (UpdateResult.Status.DELETED.equals(updateResponse.getStatus()) == false) {
                 auditor.info(next, "Updated transform.");
-                logger.debug("[{}] Updated transform [{}]", next, updateResponse.getStatus());
+                logger.info("[{}] Updated transform [{}]", next, updateResponse.getStatus());
                 updatesByStatus.compute(updateResponse.getStatus(), (k, v) -> (v == null) ? 1 : v + 1L);
             }
             if (transformsToUpgrade.isEmpty() == false) {