Method returnCodeTest2

test/org/apache/pig/test/TestPigRunner.java:893–921

()

    }

    @Test
    public void returnCodeTest2() throws Exception {
        PrintWriter w = new PrintWriter(new FileWriter(PIG_FILE));
        w.println("A = load 'non-existine.file' as (a0, a1);");
        w.println("B = load 'data' as (b0, b1);");
        w.println("C = join B by b0, A by a0 using 'repl';");
        w.println("store C into '" + OUTPUT_FILE + "';");
        w.close();

        try {
            String[] args = { "-x", execType, PIG_FILE };
            PigStats stats = PigRunner.run(args, null);

            assertTrue(!stats.isSuccessful());
            assertTrue(stats.getReturnCode() != 0);
            //Currently, even if failed, spark engine will add a failed OutputStats,
            // see: SparkPigStats.addFailJobStats()
            if (execType.equals("spark")) {
                assertTrue(stats.getOutputStats().size() == 1);
                assertTrue(stats.getOutputStats().get(0).isSuccessful() == false);
            } else {
                assertTrue(stats.getOutputStats().size() == 0);
            }

        } finally {
            new File(PIG_FILE).delete();
            Util.deleteFile(cluster, OUTPUT_FILE);
        }
    }


    @Test //PIG-1893