fix: only make shared runtime that its chosen (#8932)

confluentinc · Mar 29, 2022 · eb215c8 · eb215c8
1 parent 61a87ca
commit eb215c8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryRegistryImpl.java b/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryRegistryImpl.java
@@ -282,6 +282,7 @@ public PersistentQueryMetadata createOrReplacePersistentQuery(
       if (sandbox) {
         throwOnNonQueryLevelConfigs(config.getOverrides());
         streams.addAll(sourceStreams.stream()
+            .filter(t -> t.getApplicationId().equals(sharedRuntimeId.get()))
             .map(SandboxedSharedKafkaStreamsRuntimeImpl::new)
             .collect(Collectors.toList()));
       }