()
| 514 | } |
| 515 | |
| 516 | @Test |
| 517 | public void testMergeJoinFailure2() throws IOException{ |
| 518 | pigServer.registerQuery("A = LOAD '" + INPUT_FILE + "' as (id, name, n);"); |
| 519 | pigServer.registerQuery("B = LOAD '" + INPUT_FILE + "' as (id, name);"); |
| 520 | pigServer.registerQuery("C = GROUP B by id;"); |
| 521 | pigServer.registerQuery("D = join A by id, C by $0 using 'merge';"); |
| 522 | try { |
| 523 | pigServer.openIterator("D"); |
| 524 | }catch(Exception e) { |
| 525 | PigException pe = LogUtils.getPigException(e); |
| 526 | Assert.assertEquals(1103,pe.getErrorCode()); |
| 527 | return; |
| 528 | } |
| 529 | Assert.fail("Should fail to compile"); |
| 530 | } |
| 531 | |
| 532 | @Test |
| 533 | public void testEmptyRightFile() throws IOException{ |
nothing calls this directly
no test coverage detected