Skip to content

Commit 1d00950

Browse files
authored
cherrypick:Bugfix/encoder row writer (#372)
1 parent 0fbc3c6 commit 1d00950

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

client/src/main/java/com/vesoft/nebula/encoder/NebulaCodecImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ private SchemaProviderImpl genSchemaProvider(long ver, Schema schema) {
205205
SchemaProviderImpl schemaProvider = new SchemaProviderImpl(ver);
206206
for (ColumnDef col : schema.getColumns()) {
207207
ColumnTypeDef type = col.getType();
208-
boolean nullable = col.isSetNullable();
208+
boolean nullable = col.isSetNullable() && col.isNullable();
209209
boolean hasDefault = col.isSetDefault_value();
210210
int len = type.isSetType_length() ? type.getType_length() : 0;
211211
schemaProvider.addField(new String(col.getName()),

client/src/main/java/com/vesoft/nebula/encoder/RowWriterImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -831,6 +831,7 @@ public ByteBuffer processOutOfSpace() {
831831
// Set the new offset and length
832832
temp.putInt(offset, 0);
833833
temp.putInt(offset + Integer.BYTES, 0);
834+
continue;
834835
} else {
835836
// Out of space string
836837
if (strNum >= strList.size()) {

0 commit comments

Comments
 (0)