@Test public void testTezParallelismEstimatorHashJoin() throws Exception {
  pc.getProperties().setProperty(PigConfiguration.PIG_NO_SPLIT_COMBINATION,"true");
  String query="a = load '10' using " + ArbitarySplitsLoader.class.getName() + "() as (name:chararray, age:int, gpa:double);"+ "b = load '5' using "+ ArbitarySplitsLoader.class.getName()+ "() as (name:chararray, course:chararray);"+ "c = join a by name, b by name;"+ "store c into 'output';";
  Pair compiledPlan=compile(query);
  TezOperator leafOper=compiledPlan.first.getLeaves().get(0);
  Vertex leafVertex=compiledPlan.second.getVertex(leafOper.getOperatorKey().toString());
  assertEquals(leafVertex.getParallelism(),15);
}