fix: print root cause in error message

confluentinc · Feb 10, 2020 · b24579a · b24579a
1 parent 307c0f4
commit b24579a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ksql-engine/src/main/java/io/confluent/ksql/schema/ksql/inference/DefaultSchemaInjector.java b/ksql-engine/src/main/java/io/confluent/ksql/schema/ksql/inference/DefaultSchemaInjector.java
@@ -31,6 +31,7 @@
 import io.confluent.ksql.schema.ksql.inference.TopicSchemaSupplier.SchemaResult;
 import io.confluent.ksql.statement.ConfiguredStatement;
 import io.confluent.ksql.statement.Injector;
+import io.confluent.ksql.util.ErrorMessageUtil;
 import io.confluent.ksql.util.IdentifierUtil;
 import io.confluent.ksql.util.KsqlException;
 import io.confluent.ksql.util.KsqlStatementException;
@@ -79,7 +80,7 @@ public <T extends Statement> ConfiguredStatement<T> inject(
     } catch (final KsqlStatementException e) {
       throw e;
     } catch (final KsqlException e) {
-      throw new KsqlStatementException(e.getMessage(), statement.getStatementText(), e.getCause());
+      throw new KsqlStatementException(ErrorMessageUtil.buildErrorMessage(e), statement.getStatementText(), e.getCause());
     }
   }