()
| 633 | } |
| 634 | |
| 635 | @Test |
| 636 | public void testExpressionFail() throws IOException{ |
| 637 | pigServer.registerQuery("A = LOAD 'leftinput' as (a:int);"); |
| 638 | pigServer.registerQuery("B = LOAD 'temp_file*' using " + |
| 639 | DummyIndexableLoader.class.getName() + "() as (a:int);"); |
| 640 | boolean exceptionThrown = false; |
| 641 | try { |
| 642 | pigServer.registerQuery("C = join A by $0 + 10, B by $0 + 10 using 'merge';"); |
| 643 | Iterator<Tuple> iter = pigServer.openIterator("C"); |
| 644 | |
| 645 | }catch (Exception e) { |
| 646 | e.printStackTrace(); |
| 647 | PigException pe = LogUtils.getPigException(e); |
| 648 | Assert.assertEquals(1106, pe.getErrorCode()); |
| 649 | exceptionThrown = true; |
| 650 | } |
| 651 | Assert.assertEquals(true, exceptionThrown); |
| 652 | } |
| 653 | |
| 654 | @Test |
| 655 | public void testMergeJoinSch1() throws IOException{ |
nothing calls this directly
no test coverage detected