[ https://issues-test.apache.org/jira/browse/PIG-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941280#comment-15941280 ]
liyunzhang_intel commented on PIG-5176: --------------------------------------- [~nkollar]: based on 213c1bc, using following command without your patch: ant -Dharness.cluster.conf=$HADOOP_CONF_DIR -Dharness.cluster.bin=$HADOOP_BIN -Dharness.hadoop.home=$HADOOP_HOME -Dtests.to.run="-t ComputeSpec" test-e2e-spark all tests pass, can you verify again? if there is some wrong , please tell me. > Several ComputeSpec test cases fail > ----------------------------------- > > Key: PIG-5176 > URL: https://issues-test.apache.org/jira/browse/PIG-5176 > Project: Pig > Issue Type: Sub-task > Components: spark > Reporter: Nandor Kollar > Assignee: Nandor Kollar > Fix For: spark-branch > > Attachments: PIG-5176.patch > > > Several ComputeSpec test cases failed on my cluster: > ComputeSpec_5 - ComputeSpec_13 > These scripts have a ship() part in the define, where the ship includes the > script file too, so we add the same file to spark context twice. This is not > a problem with Hadoop, but looks like Spark doesn't like adding the same > filename twice: > {code} > Caused by: java.lang.IllegalArgumentException: requirement failed: File > PigStreamingDepend.pl already registered. > at scala.Predef$.require(Predef.scala:233) > at > org.apache.spark.rpc.netty.NettyStreamManager.addFile(NettyStreamManager.scala:69) > at org.apache.spark.SparkContext.addFile(SparkContext.scala:1386) > at org.apache.spark.SparkContext.addFile(SparkContext.scala:1348) > at > org.apache.spark.api.java.JavaSparkContext.addFile(JavaSparkContext.scala:662) > at > org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.addResourceToSparkJobWorkingDirectory(SparkLauncher.java:462) > at > org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.shipFiles(SparkLauncher.java:371) > at > org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.addFilesToSparkJob(SparkLauncher.java:357) > at > org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.uploadResources(SparkLauncher.java:235) > at > org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.launchPig(SparkLauncher.java:222) > at > org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.launchPig(HExecutionEngine.java:290) > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)