@Test
public void testDataSkewPolicy() throws Exception {

  // this should run without an exception.
  final IRDAG optimizedDAG =
    DataSkewPolicy.BUILDER.build().runCompileTimeOptimization(dagForSkew, DAG.EMPTY_DAG_DIRECTORY);
  assertTrue(optimizedDAG.checkIntegrity().isPassed());
}