Skip to content

Commit 9916f3d

Browse files
wip
1 parent ac2d19b commit 9916f3d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,8 @@ public Stream<Object[]> query(@Nonnull final String query,
190190
for (int i = 0; i < fieldVectors.size(); i++) {
191191
var schema = vector.getSchema().getFields().get(i);
192192
var metaType = schema.getMetadata().get("iox::column::type");
193-
String valueType = metaType.split("::")[2];
193+
String valueType = metaType != null ? metaType.split("::")[2] : null;
194+
194195
if ("field".equals(valueType)) {
195196
switch (metaType) {
196197
case "iox::column_type::field::integer":

0 commit comments

Comments
 (0)