From 787de1b41b0b3316c993010dbda98d3ec4c86603 Mon Sep 17 00:00:00 2001 From: jianfengmao Date: Wed, 20 Dec 2023 12:50:10 -0700 Subject: [PATCH] Sync with changes to JPY --- py/server/deephaven/arrow.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/py/server/deephaven/arrow.py b/py/server/deephaven/arrow.py index b61e62debb1..09fb8d73808 100644 --- a/py/server/deephaven/arrow.py +++ b/py/server/deephaven/arrow.py @@ -100,8 +100,7 @@ def to_table(pa_table: pa.Table, cols: List[str] = None) -> Table: dh_schema = pa.schema(dh_fields) try: - pa_buffer = dh_schema.serialize() - j_barrage_table_builder.setSchema(pa_buffer) + j_barrage_table_builder.setSchema(jpy.byte_buffer(dh_schema.serialize())) record_batches = pa_table.to_batches() j_barrage_table_builder.addRecordBatches([jpy.byte_buffer(rb.serialize()) for rb in record_batches])