Skip to content

Commit 50e89f8

Browse files
committed
Merge fallout
1 parent 8c72f27 commit 50e89f8

2 files changed

Lines changed: 1 addition & 3 deletions

File tree

core/src/main/java/io/questdb/client/cutlass/qwp/protocol/QwpTableBuffer.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1132,9 +1132,6 @@ public void addSymbolWithGlobalId(CharSequence value, int globalId) {
11321132
addNull();
11331133
return;
11341134
}
1135-
if (auxBuffer == null) {
1136-
auxBuffer = new OffHeapAppendMemory(64);
1137-
}
11381135
if (!storeGlobalSymbolIdsOnly) {
11391136
if (symbolList != null && symbolList.size() > 0) {
11401137
int localIdx = getOrAddLocalSymbol(value);

core/src/test/java/io/questdb/client/test/cutlass/qwp/client/QwpWebSocketEncoderTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -994,6 +994,7 @@ public void testEncodeWithDeltaDict_readsGlobalIdsFromDataBuffer() throws Except
994994
Assert.assertEquals(SCHEMA_MODE_FULL, cursor.readByte());
995995
Assert.assertEquals("ticker", cursor.readString());
996996
Assert.assertEquals(TYPE_SYMBOL, cursor.readByte());
997+
Assert.assertEquals(0, cursor.readByte()); // no nulls
997998
Assert.assertEquals(5, cursor.readVarint());
998999
Assert.assertEquals(7, cursor.readVarint());
9991000
}

0 commit comments

Comments
 (0)