[DRILL-299] OutgoingRecordBatch trying to get RecordCount on incoming batch with outcome NOT_YET

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Assignee: Ben Becker
• Reporter: Steven Phillips
• Created: 15/Nov/13 20:24
• Updated: 31/Jul/14 06:32
• Resolved: 18/Nov/13 22:57

Description

I think this slipped in because TestHashToRandomExchange is currently ignored. This must have accidently been checked in as part of some other jira.

Removing the @Ignore, and running the test, gives this exception:

java.lang.IllegalStateException: You tried to do a batch data read operation when you were in a state of NOT_YET. You can only do this type of operation when you are in a state of OK or OK_NEW_SCHEMA.
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.validateReadState(IteratorValidatorBatchIterator.java:48) ~[classes/:na]
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.getRecordCount(IteratorValidatorBatchIterator.java:71) ~[classes/:na]
org.apache.drill.exec.physical.impl.partitionsender.OutgoingRecordBatch.initializeBatch(OutgoingRecordBatch.java:153) ~[classes/:na]
org.apache.drill.exec.physical.impl.partitionsender.OutgoingRecordBatch.<init>(OutgoingRecordBatch.java:74) ~[classes/:na]
org.apache.drill.exec.physical.impl.partitionsender.PartitionSenderRootExec.<init>(PartitionSenderRootExec.java:68) ~[classes/:na]
org.apache.drill.exec.physical.impl.partitionsender.PartitionSenderCreator.getRoot(PartitionSenderCreator.java:36) ~[classes/:na]
org.apache.drill.exec.physical.impl.ImplCreator.visitHashPartitionSender(ImplCreator.java:146) ~[classes/:na]
org.apache.drill.exec.physical.impl.ImplCreator.visitHashPartitionSender(ImplCreator.java:57) ~[classes/:na]
org.apache.drill.exec.physical.config.HashPartitionSender.accept(HashPartitionSender.java:65) ~[classes/:na]
org.apache.drill.exec.physical.impl.ImplCreator.getExec(ImplCreator.java:207) ~[classes/:na]
org.apache.drill.exec.work.batch.BitComHandlerImpl.startNewRemoteFragment(BitComHandlerImpl.java:119) [classes/:na]
org.apache.drill.exec.work.batch.BitComHandlerImpl.handle(BitComHandlerImpl.java:88) [classes/:na]
org.apache.drill.exec.rpc.bit.BitServer.handle(BitServer.java:59) [classes/:na]
org.apache.drill.exec.rpc.bit.BitServer.handle(BitServer.java:37) [classes/:na]
org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:142) [classes/:na]
org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:127) [classes/:na]
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) [netty-codec-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) [netty-codec-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173) [netty-codec-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465) [netty-transport-4.0.7.Final.jar:na]
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359) [netty-transport-4.0.7.Final.jar:na]
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty-common-4.0.7.Final.jar:na]
java.lang.Thread.run(Thread.java:722) [na:1.7.0_21]