From 6299410d4a8ef4eb3aeddfb9c1d37c62e8055d27 Mon Sep 17 00:00:00 2001 From: Steven Zhang <35498506+stevenpyzhang@users.noreply.github.com> Date: Mon, 10 Feb 2020 18:42:32 -0500 Subject: [PATCH] fix: print root cause in error message (#4505) --- .../ksql/schema/ksql/inference/DefaultSchemaInjector.java | 6 +++++- 1 file changed, 5 insertions(+), 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 index c891702e3ca7..a18d9e573b70 100644 --- 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,10 @@ public ConfiguredStatement 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()); } }