Fixed tests

confluentinc · Sep 4, 2020 · fa37637 · fa37637
1 parent 7f632d6
commit fa37637
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateSourceFactory.java b/ksqldb-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateSourceFactory.java
@@ -90,7 +90,7 @@ public CreateStreamCommand createStreamCommand(
     final SourceName sourceName = statement.getName();
     final DataSource dataSource = metaStore.getSource(sourceName);
 
-    if (dataSource != null) {
+    if (dataSource != null && !statement.isOrReplace()) {
       final String sourceType = dataSource.getDataSourceType().getKsqlType();
       if (!statement.isNotExists()) {
         throw new KsqlException(