org.apache.drill.exec.server

Class TestDrillbitResilience

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.server.TestDrillbitResilience

public class TestDrillbitResilience
extends DrillTest

Test how resilient drillbits are to throwing exceptions during various phases of query execution by injecting exceptions at various points, and to cancellations in various phases.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestDrillbitResilience()

Method Summary

Modifier and Type	Method and Description
void	cancelAfterAllResultsProduced()
void	cancelAfterEverythingIsCompleted()
void	cancelInMiddleOfFetchingResults()
void	cancelWhenQueryIdArrives()
void	checkDrillbits()
void	failsAfterMSorterSetup()
void	failsAfterMSorterSorting()
void	failsDuringExecution()
void	failsWhenParsing()
void	failsWhenSendingFragments()
void	foreman_runTryBeginning()
void	foreman_runTryEnd()
void	interruptingBlockedMergingRecordBatch() Test canceling query interrupts currently blocked FragmentExecutor threads waiting for some event to happen.
void	interruptingBlockedUnorderedReceiverBatch() Test canceling query interrupts currently blocked FragmentExecutor threads waiting for some event to happen.
void	interruptingPartitionerThreadFragment() Tests interrupting the fragment thread that is running PartitionSenderRootExec.
void	interruptingWhileFragmentIsBlockedInAcquiringSendingTicket()
void	memoryLeaksWhenCancelled()
void	memoryLeaksWhenFailed()
void	passThrough()
void	settingNoOpInjectionsAndQuery()
static void	shutdownAllDrillbits()
static void	startSomeDrillbits()
void	successfullyCompletes()

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestDrillbitResilience

public TestDrillbitResilience()

Method Detail

startSomeDrillbits

public static void startSomeDrillbits()
                               throws Exception

Throws:

Exception

shutdownAllDrillbits

public static void shutdownAllDrillbits()

checkDrillbits

public void checkDrillbits()

settingNoOpInjectionsAndQuery

public void settingNoOpInjectionsAndQuery()

foreman_runTryBeginning

public void foreman_runTryBeginning()

foreman_runTryEnd

public void foreman_runTryEnd()

passThrough

public void passThrough()

cancelWhenQueryIdArrives

public void cancelWhenQueryIdArrives()

cancelInMiddleOfFetchingResults

public void cancelInMiddleOfFetchingResults()

cancelAfterAllResultsProduced

public void cancelAfterAllResultsProduced()

cancelAfterEverythingIsCompleted

public void cancelAfterEverythingIsCompleted()

successfullyCompletes

public void successfullyCompletes()

failsWhenParsing

public void failsWhenParsing()

failsWhenSendingFragments

public void failsWhenSendingFragments()

failsDuringExecution

public void failsDuringExecution()

interruptingBlockedMergingRecordBatch

public void interruptingBlockedMergingRecordBatch()

Test canceling query interrupts currently blocked FragmentExecutor threads waiting for some event to happen. Specifically tests canceling fragment which has MergingRecordBatch blocked waiting for data.

interruptingBlockedUnorderedReceiverBatch

public void interruptingBlockedUnorderedReceiverBatch()

Test canceling query interrupts currently blocked FragmentExecutor threads waiting for some event to happen. Specifically tests canceling fragment which has UnorderedReceiverBatch blocked waiting for data.

interruptingPartitionerThreadFragment

public void interruptingPartitionerThreadFragment()

Tests interrupting the fragment thread that is running PartitionSenderRootExec. PartitionSenderRootExec spawns threads for partitioner. Interrupting fragment thread should also interrupt the partitioner threads.

interruptingWhileFragmentIsBlockedInAcquiringSendingTicket

public void interruptingWhileFragmentIsBlockedInAcquiringSendingTicket()

memoryLeaksWhenCancelled

public void memoryLeaksWhenCancelled()

memoryLeaksWhenFailed

public void memoryLeaksWhenFailed()

failsAfterMSorterSorting

public void failsAfterMSorterSorting()

failsAfterMSorterSetup

public void failsAfterMSorterSetup()