This is an automated email from the ASF dual-hosted git repository.

jlli pushed a commit to branch fix-log-error-message
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit fe3cedfdf01d1306a72e0f753afa2f2ee20158f8
Author: Jack Li(Analytics Engineering) <[email protected]>
AuthorDate: Tue Jan 8 10:34:42 2019 -0800

    Fix error messages
---
 .../java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java  | 2 +-
 .../pinot/controller/helix/core/retention/RetentionManager.java         | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
index d8fdbb4..c62d74b 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
@@ -240,7 +240,7 @@ public class SegmentStatusChecker extends 
ControllerPeriodicTask {
             nReplicasIdealMax);
       }
     } catch (Exception e) {
-      LOGGER.warn("Caught exception while updating segment status for table 
{}", e, tableNameWithType);
+      LOGGER.warn("Caught exception while updating segment status for table 
{}", tableNameWithType, e);
 
       // Remove the metric for this table
       resetTableMetrics(tableNameWithType);
diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/retention/RetentionManager.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/retention/RetentionManager.java
index 134c4ee..426ca55 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/retention/RetentionManager.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/retention/RetentionManager.java
@@ -74,7 +74,7 @@ public class RetentionManager extends ControllerPeriodicTask {
       LOGGER.info("Start managing retention for table: {}", tableNameWithType);
       manageRetentionForTable(tableNameWithType);
     } catch (Exception e) {
-      LOGGER.error("Caught exception while managing retention for all tables", 
e);
+      LOGGER.error("Caught exception while managing retention for table: {}", 
tableNameWithType, e);
     }
   }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to