fix: Improve pull query error logging (#5477)

confluentinc · May 26, 2020 · f23412e · f23412e
1 parent 20bdb8a
commit f23412e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/PullQueryExecutor.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/PullQueryExecutor.java
@@ -268,8 +268,8 @@ private TableRowsEntity handlePullQuery(
       try {
         return routeQuery(node, statement, executionContext, serviceContext, pullQueryContext);
       } catch (Exception t) {
-        LOG.debug("Error routing query {} to host {} at timestamp {}",
-                 statement.getStatementText(), node, System.currentTimeMillis());
+        LOG.error("Error routing query {} to host {} at timestamp {}",
+            statement.getStatementText(), node, System.currentTimeMillis(), t);
       }
     }
     throw new MaterializationException(String.format(