private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException {
      throw new IOException("Raise IOException to cause deserialization failure");
    }
Setup two linear transformation pipelines:
1) input1 --> filter --> sendTo
2) input2 --> map --> sink
samza-core/src/test/java/org/apache/samza/operators/TestOperatorSpecGraph.java