WIP

aklivity · Dec 16, 2024 · 57fb1d5 · 57fb1d5
1 parent c4ad8f5
commit 57fb1d5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...aklivity/zilla/runtime/binding/risingwave/internal/macro/RisingwaveCreateZtableMacro.java b/...aklivity/zilla/runtime/binding/risingwave/internal/macro/RisingwaveCreateZtableMacro.java
@@ -511,11 +511,10 @@ private void doExecute(
                 long authorization)
             {
                 String name = command.name();
-                String schema = command.schema();
 
                 String newSql = sql.replace(ZTABLE_NAME, TABLE_NAME)
                     .replace("\u0000", "");
-                String sqlQuery = String.format(sqlFormat, systemSchema, schema, name, newSql);
+                String sqlQuery = String.format(sqlFormat, systemSchema, ZTABLE_NAME, name, newSql);
 
                 handler.doExecute(traceId, authorization, sqlQuery);
             }