Author: xuefu
Date: Tue Jun 16 13:07:56 2015
New Revision: 1685820
URL: http://svn.apache.org/r1685820
Log:
PIG-4605: fix a bug when coping Jar to SparkJob working directory (Xianda via
Xuefu)
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java?rev=1685820&r1=1685819&r2=1685820&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java
Tue Jun 16 13:07:56 2015
@@ -321,6 +321,10 @@ public class SparkLauncher extends Launc
if (isLocal) {
File localFile = new File(currentDirectoryPath + "/"
+ jarName);
+ if (jarFile.getAbsolutePath().equals(localFile.getAbsolutePath())
+ && jarFile.exists()) {
+ return;
+ }
if (localFile.exists()) {
LOG.info(String.format(
"jar file %s exists, ready to delete",
