diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutor.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutor.java index 23001145eb07..96e8f8a7cf33 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutor.java +++ b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutor.java @@ -307,7 +307,7 @@ private void terminateQuery(final PreparedStatement<TerminateQuery> terminateQue private static void throwUnsupportedStatementError() { throw new KsqlException("This version of ksqlDB does not support executing " - + "statements submitted prior to ksqlDB 0.8.0 or Confluent Platform ksqlDB 5.0. " + + "statements submitted prior to ksqlDB 0.8.0 or Confluent Platform ksqlDB 5.5. " + "Please see the upgrading guide to upgrade."); } diff --git a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutorTest.java b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutorTest.java index 1f65285d7afd..d2f93650aa7f 100644 --- a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutorTest.java +++ b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/server/computation/InteractiveStatementExecutorTest.java @@ -491,7 +491,7 @@ public void shouldThrowOnCreateSourceWithoutPlan() { // Then assertThat(e.getMessage(), containsString( "This version of ksqlDB does not support executing statements submitted prior to ksqlDB " - + "0.8.0 or Confluent Platform ksqlDB 5.0. Please see the upgrading guide to upgrade.")); + + "0.8.0 or Confluent Platform ksqlDB 5.5. Please see the upgrading guide to upgrade.")); } @Test @@ -515,7 +515,7 @@ public void shouldThrowOnCreateAsSelectWithoutPlan() { // Then assertThat(e.getMessage(), containsString( "This version of ksqlDB does not support executing statements submitted prior to ksqlDB " - + "0.8.0 or Confluent Platform ksqlDB 5.0. Please see the upgrading guide to upgrade.")); + + "0.8.0 or Confluent Platform ksqlDB 5.5. Please see the upgrading guide to upgrade.")); } @Test @@ -539,7 +539,7 @@ public void shouldThrowOnDropSourceWithoutPlan() { // Then assertThat(e.getMessage(), containsString( "This version of ksqlDB does not support executing statements submitted prior to ksqlDB " - + "0.8.0 or Confluent Platform ksqlDB 5.0. Please see the upgrading guide to upgrade.")); + + "0.8.0 or Confluent Platform ksqlDB 5.5. Please see the upgrading guide to upgrade.")); } @Test