public Command create(
      final ConfiguredStatement<? extends Statement> statement,
      final KsqlExecutionContext context) {
    return create(statement, context.getServiceContext(), context);
  }
@Test
  public void shouldRaiseExceptionWhenQueryIsRunningAndProcessingGuranteeIsAttemptedToChange() {
    configuredStatement = configuredStatement("ALTER SYSTEM 'processing.guarantee'='exactly_once';" , alterSystemProperty);
    when(alterSystemProperty.getPropertyName()).thenReturn("processing.guarantee");
    when(alterSystemProperty.getPropertyValue()).thenReturn("exactly_once");
    when(config.getBoolean(KsqlConfig.KSQL_SHARED_RUNTIME_ENABLED)).thenReturn(true);

    final List<PersistentQueryMetadata> persistentList = new ArrayList<>();
    persistentList.add(query1);
    when(executionContext.getPersistentQueries()).thenReturn(persistentList);

    assertThrows(ConfigException.class,
        () -> commandFactory.create(configuredStatement, executionContext));
  }