diff --git a/ksqldb-cli/src/main/java/io/confluent/ksql/cli/console/Console.java b/ksqldb-cli/src/main/java/io/confluent/ksql/cli/console/Console.java index aaaf0a458731..763a7099dc66 100644 --- a/ksqldb-cli/src/main/java/io/confluent/ksql/cli/console/Console.java +++ b/ksqldb-cli/src/main/java/io/confluent/ksql/cli/console/Console.java @@ -558,7 +558,7 @@ private void printOverriddenProperties(final QueryDescription queryDescription) final List> rows = overriddenProperties.entrySet().stream() .sorted(Entry.comparingByKey()) - .map(prop -> Arrays.asList(prop.getKey(), "", Objects.toString(prop.getValue()))) + .map(prop -> Arrays.asList(prop.getKey(), Objects.toString(prop.getValue()))) .collect(Collectors.toList()); new Builder() diff --git a/ksqldb-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java b/ksqldb-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java index 8f32d21149fd..0f47223fbbb6 100644 --- a/ksqldb-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java +++ b/ksqldb-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java @@ -373,7 +373,7 @@ public void shouldPrintExplainQueryWithError() { ImmutableSet.of("sink"), "topology", "executionPlan", - ImmutableMap.of(), + ImmutableMap.of("overridden.prop", 42), ImmutableMap.of(new KsqlHostInfoEntity("foo", 123), KsqlQueryStatus.ERROR), KsqlQueryType.PERSISTENT, ImmutableList.of(new QueryError("error", Type.SYSTEM)) @@ -407,7 +407,9 @@ public void shouldPrintExplainQueryWithError() { " \"sinks\" : [ \"sink\" ],\n" + " \"topology\" : \"topology\",\n" + " \"executionPlan\" : \"executionPlan\",\n" + - " \"overriddenProperties\" : { },\n" + + " \"overriddenProperties\" : {\n" + + " \"overridden.prop\" : 42\n" + + " },\n" + " \"ksqlHostQueryStatus\" : {\n" + " \"foo:123\" : \"ERROR\"\n" + " },\n" + @@ -452,8 +454,16 @@ public void shouldPrintExplainQueryWithError() { "------------------- \n" + "topology\n" + "\n" + + "Overridden Properties\n" + + "---------------------\n" + + " Property | Value \n" + + "-------------------------\n" + + " overridden.prop | 42 \n" + + "-------------------------\n" + + "\n" + "Error Details : error\n" + - "Error Type : SYSTEM\n")); + "Error Type : SYSTEM\n" + )); } }