I've changed my batch size record reader to be larger. All my test cases still work as I would expect them, except for 1 and I have no idea why? I'v turned on tracing in the hopes of getting a hint. I now see it is in a generated projection class but I'm not sure why.. Can anyone speculate why a change in batch size would make cause such a failure?
I've added my record reader change, test case and error from the trace. Thanks jc public class MsgpackRecordReader extends AbstractRecordReader { private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(MsgpackRecordReader.class); public static final long DEFAULT_ROWS_PER_BATCH = BaseValueVector.INITIAL_VALUE_ALLOCATION * 4; @Test public void testSchemaArrayOfArrayCell() throws Exception { LogFixtureBuilder logBuilder = LogFixture.builder() // Log to the console for debugging convenience .toConsole().logger("org.apache.drill.exec", Level.TRACE); try (LogFixture logs = logBuilder.build()) { learnModel(); String sql = "select root.arrayOfarray[0][0] as w from dfs.data.`secondBatchHasCompleteModel.mp` as root"; rowSetIterator = client.queryBuilder().sql(sql).rowSetIterator(); schemaBuilder.add("w", TypeProtos.MinorType.BIGINT, TypeProtos.DataMode.OPTIONAL); expectedSchema = schemaBuilder.buildSchema(); verifyFirstBatchNull(); rowSetBuilder = newRowSetBuilder(); rowSetBuilder.addRow(1L); verify(rowSetBuilder.build(), nextRowSet()); } } java.lang.AssertionError: null at org.apache.drill.exec.vector.complex.RepeatedListVector$DelegateRepeatedVector$RepeatedListAccessor.get(RepeatedListVector.java:73) ~[vector-1.15.0-SNAPSHOT.jar:1.15.0-SNAPSHOT] at org.apache.drill.exec.vector.complex.impl.RepeatedListReaderImpl.setPosition(RepeatedListReaderImpl.java:95) ~[vector-1.15.0-SNAPSHOT.jar:1.15.0-SNAPSHOT] at org.apache.drill.exec.test.generated.ProjectorGen1.doEval(ProjectorTemplate.java:27) ~[na:na] at org.apache.drill.exec.test.generated.ProjectorGen1.projectRecords(ProjectorTemplate.java:67) ~[na:na] at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.doWork(ProjectRecordBatch.java:232) ~[drill-java-exec-1.15.0-SNAPSHOT.jar:1.15.0-SNAPSHOT] at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:117) ~[drill-java-exec-1.15.0-SNAPSHOT.jar:1.15.0-SNAPSHOT]