Bugfix/encoder row writer (#366)

* fix field not nullable error * fix strList out of bound exception * fix field not nullable error * fix strList out of bound exception Co-authored-by: Anqi <anqi.wang@vesoft.com>
vesoft-inc · Oct 22, 2021 · 2b82dda · 2b82dda
1 parent 597c0ec
commit 2b82dda
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/client/src/main/java/com/vesoft/nebula/encoder/NebulaCodecImpl.java b/client/src/main/java/com/vesoft/nebula/encoder/NebulaCodecImpl.java
@@ -199,7 +199,7 @@ private SchemaProviderImpl genSchemaProvider(long ver, Schema schema) {
         SchemaProviderImpl schemaProvider = new SchemaProviderImpl(ver);
         for (ColumnDef col : schema.getColumns()) {
             ColumnTypeDef type = col.getType();
-            boolean nullable = col.isSetNullable();
+            boolean nullable = col.isSetNullable() && col.isNullable();
             boolean hasDefault = col.isSetDefault_value();
             int len = type.isSetType_length() ? type.getType_length() : 0;
             schemaProvider.addField(new String(col.getName()),

diff --git a/client/src/main/java/com/vesoft/nebula/encoder/RowWriterImpl.java b/client/src/main/java/com/vesoft/nebula/encoder/RowWriterImpl.java
@@ -831,6 +831,7 @@ public ByteBuffer processOutOfSpace() {
                 // Set the new offset and length
                 temp.putInt(offset, 0);
                 temp.putInt(offset + Integer.BYTES, 0);
+                continue;
             } else {
                 // Out of space string
                 if (strNum >= strList.size()) {