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 index 6a247127a506..a22b9cceb261 100644 --- 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(