-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/57317/#review175872
-----------------------------------------------------------




src/org/apache/pig/backend/hadoop/executionengine/spark/JobGraphBuilder.java
Line 262 (original), 263 (patched)
<https://reviews.apache.org/r/57317/#comment249315>

    Typo. successorPlan



src/org/apache/pig/backend/hadoop/executionengine/spark/JobGraphBuilder.java
Line 265 (original), 266 (patched)
<https://reviews.apache.org/r/57317/#comment249316>

    LOG.error redundant when exception is being thrown



src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java
Lines 166-167 (original), 170 (patched)
<https://reviews.apache.org/r/57317/#comment249317>

    if (LOG.isDebugEnabled())
       LOG.debug(sparkplan);
    
    Can you also print the final spark plan (after optimizations and 
conversions) for the new setting introduced in PIG-5210.



src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
Line 325 (original)
<https://reviews.apache.org/r/57317/#comment249323>

    This seems to be removed by mistake



src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOperator.java
Lines 272 (patched)
<https://reviews.apache.org/r/57317/#comment249325>

    Formatting is off



src/org/apache/pig/backend/hadoop/executionengine/util/SecondaryKeyOptimizerUtil.java
Line 56 (original), 56 (patched)
<https://reviews.apache.org/r/57317/#comment249339>

    Should still be Private



src/org/apache/pig/impl/util/UDFContext.java
Lines 210-212 (patched)
<https://reviews.apache.org/r/57317/#comment249340>

    Remove this and add
    
        /*
         *  Internal pig use 
         */



src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigContext.java
Lines 34 (patched)
<https://reviews.apache.org/r/57317/#comment249319>

    defaultParallelism
    
    Only final constant variables should be in full upper case.



src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigContext.java
Lines 51 (patched)
<https://reviews.apache.org/r/57317/#comment249320>

    Shouldn't default parallelism returned if requested parallelism <= 0 ?



test/e2e/pig/tests/nightly.conf
Lines 2307 (patched)
<https://reviews.apache.org/r/57317/#comment249204>

    Testing distinct + orderby + limit serves the same purpose as orderby + 
limit test. Can you remove orderby from this test? If distinct + limit differs 
everytime even with spark and a different verify_pig_script runs just ignore 
the test for now adding a TODO to test num 4.



test/org/apache/pig/newplan/logical/relational/TestLocationInPhysicalPlan.java
Lines 66 (patched)
<https://reviews.apache.org/r/57317/#comment249202>

    Can you add a TODO to look into the repetition of A[3,4] later?



test/org/apache/pig/test/TestCombiner.java
Lines 122-125 (original), 126-129 (patched)
<https://reviews.apache.org/r/57317/#comment249211>

    Utils.checkQueryOutputsAfterSort(resultIterator, resultTuples);



test/org/apache/pig/test/TestCubeOperator.java
Lines 569 (patched)
<https://reviews.apache.org/r/57317/#comment249212>

    illustrate does not work in spark



test/org/apache/pig/test/TestEmptyInputDir.java
Line 88 (original), 89 (patched)
<https://reviews.apache.org/r/57317/#comment249213>

    assertEmptyOutputFile(); is missing after assumeTrue



test/org/apache/pig/test/TestGrunt.java
Lines 938 (patched)
<https://reviews.apache.org/r/57317/#comment249219>

    Move this to beginning of the test



test/org/apache/pig/test/TestGrunt.java
Line 939 (original)
<https://reviews.apache.org/r/57317/#comment249218>

    assertTrue(caught); is missing



test/org/apache/pig/test/TestPigRunner.java
Lines 216 (patched)
<https://reviews.apache.org/r/57317/#comment249297>

    if (execType.equals("mapreduce")) {
                    assertEquals(2, stats.getNumberJobs());
                    assertEquals(stats.getJobGraph().size(), 2);
                } else {
                    // Tez and Spark
                    assertEquals(1, stats.getNumberJobs());
                    assertEquals(stats.getJobGraph().size(), 1);
                }



test/org/apache/pig/test/TestPigRunner.java
Lines 465 (patched)
<https://reviews.apache.org/r/57317/#comment249299>

    Can you add a TODO here to fix this to work without -no_multiquery?



test/org/apache/pig/test/TestPigRunner.java
Line 508 (original), 548 (patched)
<https://reviews.apache.org/r/57317/#comment249301>

    if(execType.equals("mapreduce") {
    ...
    } else {
    // Tez and spark
    ...
    }



test/org/apache/pig/test/TestPigServer.java
Lines 550-552 (original), 550-553 (patched)
<https://reviews.apache.org/r/57317/#comment249304>

    Assume.assumeTrue("Skip this test for TEZ", 
Util.isMapredExecType(cluster.getExecType()) || 
Util.isSparkExecType(cluster.getExecType()));



test/org/apache/pig/test/TestPigServerLocal.java
Lines 265 (patched)
<https://reviews.apache.org/r/57317/#comment249306>

    _testParseBatchWithScripting is missing



test/org/apache/pig/test/TestSecondarySort.java
Lines 515 (patched)
<https://reviews.apache.org/r/57317/#comment249308>

    Assume.assumeFalse("Skip this test for Spark", 
Util.isSparkExecType(cluster.getExecType()));
    
    Else test will show as Passed instead of Skipped.



test/org/apache/pig/test/YarnMiniCluster.java
Lines 82 (patched)
<https://reviews.apache.org/r/57317/#comment249309>

    Missing changes from PIG-5105.



test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-text.gld
Lines 2 (patched)
<https://reviews.apache.org/r/57317/#comment249310>

    Get rid of whitespace


- Rohini Palaniswamy


On May 18, 2017, 8:06 a.m., kelly zhang wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/57317/
> -----------------------------------------------------------
> 
> (Updated May 18, 2017, 8:06 a.m.)
> 
> 
> Review request for pig, Daniel Dai and Rohini Palaniswamy.
> 
> 
> Bugs: PIG-4059 and PIG-4854;
>     https://issues.apache.org/jira/browse/PIG-4059
>     https://issues.apache.org/jira/browse/PIG-4854;
> 
> 
> Repository: pig-git
> 
> 
> Description
> -------
> 
> Merge all changes from spark branch
> 
> 
> Diffs
> -----
> 
>   bin/pig e1212fa 
>   build.xml a0d2ca8 
>   ivy.xml 42daec9 
>   ivy/libraries.properties 481066e 
>   src/META-INF/services/org.apache.pig.ExecType 5c034c8 
>   src/docs/src/documentation/content/xdocs/start.xml c9a1491 
>   src/org/apache/pig/PigConfiguration.java d25f81a 
>   src/org/apache/pig/PigWarning.java fcda114 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/AccumulatorOptimizer.java
>  ac03d40 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NoopFilterRemover.java
>  4d91556 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NoopFilterRemoverUtil.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java
>  255650e 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
>  6fe8ff3 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigSplit.java
>  e866b28 
>   
> src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SecondaryKeyOptimizerMR.java
>  8170f02 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/PhysicalOperator.java
>  0e35273 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/expressionOperators/POUserFunc.java
>  ecf780c 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/plans/PhyPlanVisitor.java
>  3bad98b 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/plans/PhysicalPlan.java
>  2376d03 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POBroadcastSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POCollectedGroup.java
>  bcbfe2b 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoin.java
>  d80951a 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POForEach.java
>  4dc6d54 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java
>  52cfb73 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeCogroup.java
>  4923d3f 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java
>  13f70c0 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POPoissonSample.java
>  f2830c2 
>   
> src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSort.java
>  c3a82c3 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/JobGraphBuilder.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/JobMetricsListener.java
>  PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/KryoSerializer.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/MapReducePartitionerWrapper.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkEngineConf.java 
> PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/SparkExecType.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkExecutionEngine.java
>  PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLocalExecType.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPOUserFuncVisitor.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigContext.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigRecordReader.java
>  PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigSplit.java 
> PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/SparkUtil.java 
> PRE-CREATION 
>   src/org/apache/pig/backend/hadoop/executionengine/spark/UDFJarsFinder.java 
> PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/BroadcastConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/CollectedGroupConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/CounterConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/IndexedKey.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/IteratorTransform.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/JoinGroupSparkConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LimitConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeCogroupConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/OutputConsumerIterator.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PigSecondaryKeyComparatorSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PoissonSampleConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RDDConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ReduceByConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SparkSampleSortConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/NativeSparkOperator.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POJoinGroupSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POPoissonSampleSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POReduceBySpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POSampleSortSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/AccumulatorOptimizer.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/CombinerOptimizer.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/JoinGroupOptimizerSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/MultiQueryOptimizerSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/NoopFilterRemover.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/ParallelismSetter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/SecondaryKeyOptimizerSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/SparkSecondaryKeyOptimizerUtil.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/DotSparkPrinter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkCompiler.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkCompilerException.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOpPlanVisitor.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOperPlan.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOperator.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkPOPackageAnnotator.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkPrinter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/plan/XMLSparkPrinter.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/running/PigInputFormatSpark.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/spark/streaming/SparkExecutableManager.java
>  PRE-CREATION 
>   
> src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/AccumulatorOptimizer.java
>  eb5b801 
>   
> src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/SecondaryKeyOptimizerTez.java
>  caf1786 
>   
> src/org/apache/pig/backend/hadoop/executionengine/util/AccumulatorOptimizerUtil.java
>  c4b44ad 
>   
> src/org/apache/pig/backend/hadoop/executionengine/util/CombinerOptimizerUtil.java
>  889c01b 
>   
> src/org/apache/pig/backend/hadoop/executionengine/util/SecondaryKeyOptimizerUtil.java
>  0b59c9c 
>   src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java 1826131 
>   src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java 
> 951146f 
>   src/org/apache/pig/data/SelfSpillBag.java d17f0a8 
>   src/org/apache/pig/impl/PigContext.java d43949f 
>   src/org/apache/pig/impl/builtin/StreamingUDF.java de98539 
>   src/org/apache/pig/impl/plan/OperatorPlan.java 8b2e2e7 
>   src/org/apache/pig/impl/util/UDFContext.java 09afc0a 
>   src/org/apache/pig/impl/util/avro/AvroTupleWrapper.java 8adbe84 
>   src/org/apache/pig/scripting/groovy/GroovyEvalFunc.java cff59db 
>   src/org/apache/pig/tools/pigstats/PigStatsUtil.java e97625f 
>   src/org/apache/pig/tools/pigstats/PigStatusReporter.java 5396535 
>   src/org/apache/pig/tools/pigstats/PigWarnCounter.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkCounter.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkCounterGroup.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkCounters.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkJobStats.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkPigStats.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkPigStatusReporter.java 
> PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkScriptState.java PRE-CREATION 
>   src/org/apache/pig/tools/pigstats/spark/SparkStatsUtil.java PRE-CREATION 
>   test/e2e/pig/build.xml 1ec9cf6 
>   test/e2e/pig/conf/spark.conf PRE-CREATION 
>   test/e2e/pig/drivers/TestDriverPig.pm bcec317 
>   test/e2e/pig/tests/bigdata.conf c51ae48 
>   test/e2e/pig/tests/cmdline.conf d72c8c0 
>   test/e2e/pig/tests/grunt.conf 9c794d4 
>   test/e2e/pig/tests/hcat.conf 5910b2b 
>   test/e2e/pig/tests/multiquery.conf 667659a 
>   test/e2e/pig/tests/negative.conf 9a92528 
>   test/e2e/pig/tests/nightly.conf fe5b447 
>   test/e2e/pig/tests/orc.conf 9498d88 
>   test/e2e/pig/tests/streaming.conf 18f2fb2 
>   test/e2e/pig/tests/turing_jython.conf 077231b 
>   test/e2e/pig/tools/test/floatpostprocessor.pl d6631b2 
>   test/excluded-tests-spark PRE-CREATION 
>   
> test/org/apache/pig/newplan/logical/relational/TestLocationInPhysicalPlan.java
>  94b34b3 
>   test/org/apache/pig/pigunit/PigTest.java 0866979 
>   test/org/apache/pig/spark/TestIndexedKey.java PRE-CREATION 
>   test/org/apache/pig/spark/TestSecondarySortSpark.java PRE-CREATION 
>   test/org/apache/pig/spark/TestSparkCompiler.java PRE-CREATION 
>   test/org/apache/pig/test/MiniGenericCluster.java 9347269 
>   test/org/apache/pig/test/SparkMiniCluster.java PRE-CREATION 
>   test/org/apache/pig/test/TestAssert.java 6d4b5c6 
>   test/org/apache/pig/test/TestCase.java c9bb2fa 
>   test/org/apache/pig/test/TestCollectedGroup.java a958d33 
>   test/org/apache/pig/test/TestCombiner.java df44293 
>   test/org/apache/pig/test/TestCubeOperator.java de96e6c 
>   test/org/apache/pig/test/TestEmptyInputDir.java a9a46af 
>   test/org/apache/pig/test/TestEvalPipeline.java 48ece69 
>   test/org/apache/pig/test/TestEvalPipeline2.java c8f51d7 
>   test/org/apache/pig/test/TestEvalPipelineLocal.java c12d595 
>   test/org/apache/pig/test/TestFinish.java f18c103 
>   test/org/apache/pig/test/TestForEachNestedPlanLocal.java 63d8f67 
>   test/org/apache/pig/test/TestGrunt.java f16ff60 
>   test/org/apache/pig/test/TestHBaseStorage.java 864985e 
>   test/org/apache/pig/test/TestLimitVariable.java 53b9dae 
>   test/org/apache/pig/test/TestLineageFindRelVisitor.java e8e6aeb 
>   test/org/apache/pig/test/TestMapSideCogroup.java 2c78b4a 
>   test/org/apache/pig/test/TestMergeJoinOuter.java 81aee55 
>   test/org/apache/pig/test/TestMultiQuery.java c32eab7 
>   test/org/apache/pig/test/TestMultiQueryLocal.java b9ac035 
>   test/org/apache/pig/test/TestNativeMapReduce.java c4f6573 
>   test/org/apache/pig/test/TestNullConstant.java 3ea4509 
>   test/org/apache/pig/test/TestPigRunner.java 25380e4 
>   test/org/apache/pig/test/TestPigServer.java 8e28646 
>   test/org/apache/pig/test/TestPigServerLocal.java fbabd03 
>   test/org/apache/pig/test/TestProjectRange.java 2e3e7b8 
>   test/org/apache/pig/test/TestPruneColumn.java f05e0ec 
>   test/org/apache/pig/test/TestRank1.java 9e4ef62 
>   test/org/apache/pig/test/TestRank2.java fc802a9 
>   test/org/apache/pig/test/TestRank3.java 43af10d 
>   test/org/apache/pig/test/TestSecondarySort.java 8991010 
>   test/org/apache/pig/test/TestStoreBase.java eb3b253 
>   test/org/apache/pig/test/TezMiniCluster.java 0bf7c5a 
>   test/org/apache/pig/test/Util.java 18b241e 
>   test/org/apache/pig/test/YarnMiniCluster.java PRE-CREATION 
>   test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-dot.gld 
> PRE-CREATION 
>   test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-text.gld 
> PRE-CREATION 
>   test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-xml.gld 
> PRE-CREATION 
> 
> 
> Diff: https://reviews.apache.org/r/57317/diff/7/
> 
> 
> Testing
> -------
> 
> all test pass
> 
> 
> Thanks,
> 
> kelly zhang
> 
>

Reply via email to