@Test
public void testOutofSequenceError() throws Exception
{

  logger.info("Testing Out of Sequence Error");
  LogicalPlan dag = new LogicalPlan();
  String workingDir = new File("target/testOutofSequenceError").getAbsolutePath();
  dag.setAttribute(Context.OperatorContext.STORAGE_AGENT, new AsyncFSStorageAgent(workingDir, null));
  RandomNumberGenerator rng = dag.addOperator("random", new RandomNumberGenerator());
  MyLogger ml = dag.addOperator("logger", new MyLogger());
  dag.addStream("stream", rng.output, ml.input);
  StramLocalCluster lc = new StramLocalCluster(dag);
  lc.run(10000);
}