SHDP-388 Fixing problem introduced after package change for JobCreationException in Pig 0.13.0

Thomas Risberg · Thomas Risberg · commit b9186be9a1af · 2014-09-04T12:36:08.000-04:00
diff --git a/spring-hadoop-core/src/main/java/org/springframework/data/hadoop/pig/PigUtils.java b/spring-hadoop-core/src/main/java/org/springframework/data/hadoop/pig/PigUtils.java
@@ -28,7 +28,6 @@
 import org.apache.pig.backend.BackendException;
 import org.apache.pig.backend.executionengine.ExecException;
 import org.apache.pig.backend.executionengine.ExecJob;
-import org.apache.pig.backend.hadoop.executionengine.JobCreationException;
 import org.apache.pig.impl.logicalLayer.FrontendException;
 import org.apache.pig.impl.logicalLayer.schema.SchemaMergeException;
 import org.apache.pig.impl.plan.PlanException;
@@ -74,7 +73,7 @@ static DataAccessException convert(PigException ex) {
 		}
 
 		if (ex instanceof FrontendException) {
-			if (ex instanceof JobCreationException) {
+			if (ex.getClass().getName().contains("JobCreationException")) {
 				return new InvalidDataAccessResourceUsageException("Map Reduce error", ex);
 			}
 

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,6 @@`
`28`	`28`	`import org.apache.pig.backend.BackendException;`
`29`	`29`	`import org.apache.pig.backend.executionengine.ExecException;`
`30`	`30`	`import org.apache.pig.backend.executionengine.ExecJob;`
`31`		`-import org.apache.pig.backend.hadoop.executionengine.JobCreationException;`
`32`	`31`	`import org.apache.pig.impl.logicalLayer.FrontendException;`
`33`	`32`	`import org.apache.pig.impl.logicalLayer.schema.SchemaMergeException;`
`34`	`33`	`import org.apache.pig.impl.plan.PlanException;`
`@@ -74,7 +73,7 @@ static DataAccessException convert(PigException ex) {`
`74`	`73`	`}`
`75`	`74`
`76`	`75`	`if (ex instanceof FrontendException) {`
`77`		`- if (ex instanceof JobCreationException) {`
	`76`	`+ if (ex.getClass().getName().contains("JobCreationException")) {`
`78`	`77`	`return new InvalidDataAccessResourceUsageException("Map Reduce error", ex);`
`79`	`78`	`}`
`80`	`79`