Merge branch 'release/0.9.128'

CHANGELOG.md

@@ -2,7 +2,23 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.126...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.127...HEAD)
+
+**Fixed bugs:**
+
+- Do not include ztables and zviews into show materialized view and tables command [\#1423](https://github.com/aklivity/zilla/issues/1423)
+- Uploading more than 40k size file into filesystem doesn't get fully uploaded [\#1420](https://github.com/aklivity/zilla/issues/1420)
+
+**Merged pull requests:**
+
+- FLUSH after insert to make SHOW command predictable [\#1427](https://github.com/aklivity/zilla/pull/1427) ([akrambek](https://github.com/akrambek))
+- Fix data fragmentation in http/1.1 and flowcontrol issue in filesystem [\#1426](https://github.com/aklivity/zilla/pull/1426) ([akrambek](https://github.com/akrambek))
+- Ignore ztable and zmaterialized views from relavent non z show commands [\#1424](https://github.com/aklivity/zilla/pull/1424) ([akrambek](https://github.com/akrambek))
+- fix: TLS Client debug logging [\#1422](https://github.com/aklivity/zilla/pull/1422) ([ankitk-me](https://github.com/ankitk-me))
+
+## [0.9.127](https://github.com/aklivity/zilla/tree/0.9.127) (2025-03-04)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.126...0.9.127)
 
 **Fixed bugs:**
 

build/flyweight-maven-plugin/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>build</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

build/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/docker-image/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/helm-chart/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

conf/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-amqp.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-amqp/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql-kafka.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql-kafka/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/PgsqlParser.java

@@ -78,7 +78,7 @@ public PgsqlParser()
         this.createZfunctionListener = new SqlCreateZfunctionListener(tokens);
         this.createMaterializedViewListener = new SqlCreateZviewListener(tokens);
         this.dropListener = new SqlDropListener();
-        this.showListener = new SqlShowListener();
+        this.showListener = new SqlShowListener(tokens);
     }
 
     public String parseCommand(

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlCommandListener.java

@@ -75,7 +75,7 @@ public void enterCreatezviewstmt(
     public void enterShowstmt(
         PostgreSqlParser.ShowstmtContext ctx)
     {
-        String type = ctx.show_object_type_name().getText();
+        String type = tokens.getText(ctx.show_object_type_name());
         command = "SHOW %s".formatted(type.toUpperCase());
     }
 

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlShowListener.java

@@ -14,13 +14,23 @@
  */
 package io.aklivity.zilla.runtime.binding.pgsql.parser.listener;
 
+import org.antlr.v4.runtime.TokenStream;
+
 import io.aklivity.zilla.runtime.binding.pgsql.parser.PostgreSqlParser;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.PostgreSqlParserBaseListener;
 
 public class SqlShowListener extends PostgreSqlParserBaseListener
 {
+    private final TokenStream tokens;
+
     private String type;
 
+    public SqlShowListener(
+        TokenStream tokens)
+    {
+        this.tokens = tokens;
+    }
+
     public String type()
     {
         return type;
@@ -37,6 +47,6 @@ public void enterRoot(
     public void enterShowstmt(
         PostgreSqlParser.ShowstmtContext ctx)
     {
-        this.type = ctx.show_object_type_name().getText();
+        this.type = tokens.getText(ctx.show_object_type_name());
     }
 }

incubator/binding-risingwave.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.127</version>
+    <version>0.9.128</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.zfunction/client.rpt

@@ -178,7 +178,8 @@ write "INSERT INTO zb_catalog.zfunctions (name, sql) VALUES ('send_payment', 'CR
       "$$\n"
       "WITH (\n"
       " EVENTS = ''app_events''\n"
-      ");');"
+      ");'); "
+      "FLUSH;"
       [0x00]
 
 read advised zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.zfunction/server.rpt

@@ -180,7 +180,8 @@ read "INSERT INTO zb_catalog.zfunctions (name, sql) VALUES ('send_payment', 'CRE
      "$$\n"
      "WITH (\n"
      " EVENTS = ''app_events''\n"
-     ");');"
+     ");'); "
+     "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.double.quote.name/client.rpt

@@ -190,7 +190,8 @@ write zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 write "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-     "('cities', 'CREATE ZTABLE IF NOT EXISTS \"cities\" (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+     "('cities', 'CREATE ZTABLE IF NOT EXISTS \"cities\" (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+     "FLUSH;"
       [0x00]
 write flush
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.double.quote.name/server.rpt

@@ -188,7 +188,8 @@ read zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 read "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-     "('cities', 'CREATE ZTABLE IF NOT EXISTS \"cities\" (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+     "('cities', 'CREATE ZTABLE IF NOT EXISTS \"cities\" (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+     "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.generated.as/client.rpt

@@ -202,7 +202,8 @@ write "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
       "(id VARCHAR, name VARCHAR, description VARCHAR, "
       "owner_id VARCHAR GENERATED ALWAYS AS IDENTITY, "
       "created_at TIMESTAMP GENERATED ALWAYS AS NOW, "
-      "PRIMARY KEY (id));');"
+      "PRIMARY KEY (id));'); "
+      "FLUSH;"
       [0x00]
 
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.generated.as/server.rpt

@@ -200,7 +200,8 @@ read "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
      "(id VARCHAR, name VARCHAR, description VARCHAR, "
      "owner_id VARCHAR GENERATED ALWAYS AS IDENTITY, "
      "created_at TIMESTAMP GENERATED ALWAYS AS NOW, "
-     "PRIMARY KEY (id));');"
+     "PRIMARY KEY (id));'); "
+     "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.primary.key/client.rpt

@@ -190,7 +190,8 @@ write zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 write "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-      "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+      "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+      "FLUSH;"
       [0x00]
 write flush
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.ztable.with.primary.key/server.rpt

@@ -188,7 +188,8 @@ read zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 read "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-     "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+     "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+     "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.zview/client.rpt

@@ -204,7 +204,8 @@ write zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 write "INSERT INTO zb_catalog.zviews (name, sql) VALUES "
-      "('distinct_cities', 'CREATE ZVIEW IF NOT EXISTS distinct_cities AS SELECT id, city FROM weather GROUP BY city;');"
+      "('distinct_cities', 'CREATE ZVIEW IF NOT EXISTS distinct_cities AS SELECT id, city FROM weather GROUP BY city;'); "
+      "FLUSH;"
      [0x00]
 write flush
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/create.zview/server.rpt

@@ -208,7 +208,8 @@ read zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 read "INSERT INTO zb_catalog.zviews (name, sql) VALUES "
-      "('distinct_cities', 'CREATE ZVIEW IF NOT EXISTS distinct_cities AS SELECT id, city FROM weather GROUP BY city;');"
+      "('distinct_cities', 'CREATE ZVIEW IF NOT EXISTS distinct_cities AS SELECT id, city FROM weather GROUP BY city;'); "
+      "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.zfunction/client.rpt

@@ -32,7 +32,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DELETE FROM zb_catalog.zfunctions WHERE name = 'send_payment';"
+write "DELETE FROM zb_catalog.zfunctions WHERE name = 'send_payment'; FLUSH;"
       [0x00]
 
 read advised zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.zfunction/server.rpt

@@ -34,7 +34,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DELETE FROM zb_catalog.zfunctions WHERE name = 'send_payment';"
+read "DELETE FROM zb_catalog.zfunctions WHERE name = 'send_payment'; FLUSH;"
       [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.ztable/client.rpt

@@ -101,7 +101,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DELETE FROM zb_catalog.ztables WHERE name = 'weather';"
+write "DELETE FROM zb_catalog.ztables WHERE name = 'weather'; FLUSH;"
       [0x00]
 write flush
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.ztable/server.rpt

@@ -102,7 +102,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DELETE FROM zb_catalog.ztables WHERE name = 'weather';"
+read "DELETE FROM zb_catalog.ztables WHERE name = 'weather'; FLUSH;"
       [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.zview/client.rpt

@@ -55,7 +55,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DELETE FROM zb_catalog.zviews WHERE name = 'weather';"
+write "DELETE FROM zb_catalog.zviews WHERE name = 'weather'; FLUSH;"
       [0x00]
 write flush
 

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.zview/server.rpt

@@ -56,7 +56,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DELETE FROM zb_catalog.zviews WHERE name = 'weather';"
+read "DELETE FROM zb_catalog.zviews WHERE name = 'weather'; FLUSH;"
       [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/query.with.multiple.statements/client.rpt

@@ -190,7 +190,8 @@ write zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 write "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-      "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+      "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+      "FLUSH;"
       [0x00]
 
 read advised zilla:flush ${pgsql:flushEx()

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/query.with.multiple.statements/server.rpt

@@ -188,7 +188,8 @@ read zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 read "INSERT INTO zb_catalog.ztables (name, sql) VALUES "
-     "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));');"
+     "('cities', 'CREATE ZTABLE IF NOT EXISTS cities (id VARCHAR, name VARCHAR, description VARCHAR, PRIMARY KEY (id));'); "
+     "FLUSH;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()