Author: olga
Date: Fri Sep 26 15:51:51 2008
New Revision: 699526
URL: http://svn.apache.org/viewvc?rev=699526&view=rev
Log:
PIG-736: set name
Modified:
incubator/pig/branches/types/CHANGES.txt
incubator/pig/branches/types/src/org/apache/pig/PigServer.java
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
Modified: incubator/pig/branches/types/CHANGES.txt
URL:
http://svn.apache.org/viewvc/incubator/pig/branches/types/CHANGES.txt?rev=699526&r1=699525&r2=699526&view=diff
==============================================================================
--- incubator/pig/branches/types/CHANGES.txt (original)
+++ incubator/pig/branches/types/CHANGES.txt Fri Sep 26 15:51:51 2008
@@ -255,3 +255,5 @@
olgan)
PIG-443: Illustrate for the Types branch (shubham via olgan)
+
+ PIG-376: set job name (olgan)
Modified: incubator/pig/branches/types/src/org/apache/pig/PigServer.java
URL:
http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/PigServer.java?rev=699526&r1=699525&r2=699526&view=diff
==============================================================================
--- incubator/pig/branches/types/src/org/apache/pig/PigServer.java (original)
+++ incubator/pig/branches/types/src/org/apache/pig/PigServer.java Fri Sep 26
15:51:51 2008
@@ -128,6 +128,9 @@
public PigServer(PigContext context) throws ExecException {
this.pigContext = context;
+ if (this.pigContext.getProperties().getProperty(PigContext.JOB_NAME)
== null) {
+ setJobName("DefaultJobName") ;
+ }
pigContext.connect();
}
Modified:
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
URL:
http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java?rev=699526&r1=699525&r2=699526&view=diff
==============================================================================
---
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
(original)
+++
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
Fri Sep 26 15:51:51 2008
@@ -264,6 +264,7 @@
jobConf.set("pig.inputs", ObjectSerializer.serialize(inp));
jobConf.set("pig.inpTargets",
ObjectSerializer.serialize(inpTargets));
jobConf.set("pig.pigContext",
ObjectSerializer.serialize(pigContext));
+
jobConf.setJobName(pigContext.getProperties().getProperty(PigContext.JOB_NAME));
// Setup the DistributedCache for this job
setupDistributedCache(pigContext, jobConf,
pigContext.getProperties(),
