throws Exception
{
ExecutorService executor = Executors.newCachedThreadPool(Threads.daemonThreadsNamed("test"));
SqlStageExecution stageExecution = null;
try {
MetadataManager metadata = new MetadataManager(new FeaturesConfig());
metadata.addInternalSchemaMetadata(MetadataManager.INTERNAL_CONNECTOR_ID, new DualMetadata());
StageExecutionPlan joinPlan = createJoinPlan("A", metadata);
InMemoryNodeManager nodeManager = new InMemoryNodeManager();