diff --git a/java/test1/RedistTest.java b/java/test1/RedistTest.java
index 8d619a6e8..340972171 100644
--- a/java/test1/RedistTest.java
+++ b/java/test1/RedistTest.java
@@ -232,11 +232,11 @@ public static class SpanParser {
 
         SpanParser() {
             if (localTables) {
-                this.api = new DDlogAPI(1, r -> this.onCommit(r));
+                this.api = new DDlogAPI(2, r -> this.onCommit(r));
                 this.spanTableId = this.api.getTableId("Span");
                 System.err.println("Span table id " + this.spanTableId);
             } else {
-                this.api = new DDlogAPI(1, null);
+                this.api = new DDlogAPI(2, null);
             }
             this.command = null;
             this.exitCode = -1;