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

(Updated Aug. 5, 2014, 7:49 a.m.)


Review request for oozie.


Changes
-------

ThreadPoolExecutor override beforeExecute() method.
In XLog.log(), prefix computed as thread local log info.

As the comment, ThreadPoolExecutor override beforeExecute() method to reset the 
log info.
The CompositeCallable contains different log info and the syncAction execution 
cause the change of log info. So, the context depends on XCommand(jobId, 
actionId) should be reset. Hence, IMO, this overriding might be duplicated code 
and be removed.


Bugs: OOZIE-1939
    https://issues.apache.org/jira/browse/OOZIE-1939


Repository: oozie-git


Description
-------

Because of ThreadLocal, I added setLogInfo() at XCommand.
If the logInfo in setLogInfo() is enough, It might not need to set logInfo in 
loadState().


Diffs (updated)
-----

  core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java 
94b55cf 
  core/src/main/java/org/apache/oozie/command/XCommand.java 44e1133 
  
core/src/main/java/org/apache/oozie/command/bundle/BundleJobChangeXCommand.java 
41ad8ae 
  
core/src/main/java/org/apache/oozie/command/bundle/BundleJobResumeXCommand.java 
8ccab0e 
  
core/src/main/java/org/apache/oozie/command/bundle/BundleJobSuspendXCommand.java
 65eb272 
  core/src/main/java/org/apache/oozie/command/bundle/BundleKillXCommand.java 
c101f45 
  core/src/main/java/org/apache/oozie/command/bundle/BundlePauseXCommand.java 
0a04a02 
  core/src/main/java/org/apache/oozie/command/bundle/BundleRerunXCommand.java 
f5f4b3f 
  core/src/main/java/org/apache/oozie/command/bundle/BundleStartXCommand.java 
74fbcab 
  core/src/main/java/org/apache/oozie/command/bundle/BundleSubmitXCommand.java 
ffb2d08 
  core/src/main/java/org/apache/oozie/command/bundle/BundleUnpauseXCommand.java 
5d6ef65 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionCheckXCommand.java 
9ac66b2 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionInputCheckXCommand.java
 0a9e4fa 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionNotificationXCommand.java
 562b211 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionReadyXCommand.java 
ffe85f0 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionSkipXCommand.java 
c774f8e 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java 
1ca055d 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionTimeOutXCommand.java
 5a5bf98 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionUpdateXCommand.java
 6e3af70 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionsIgnoreXCommand.java
 ed85a40 
  
core/src/main/java/org/apache/oozie/command/coord/CoordActionsKillXCommand.java 
d2b4659 
  core/src/main/java/org/apache/oozie/command/coord/CoordChangeXCommand.java 
a2748c4 
  core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java 
91e9e09 
  
core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java
 b4b2fef 
  core/src/main/java/org/apache/oozie/command/coord/CoordPauseXCommand.java 
cc2127a 
  
core/src/main/java/org/apache/oozie/command/coord/CoordPushDependencyCheckXCommand.java
 ae71924 
  core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java 
735b295 
  core/src/main/java/org/apache/oozie/command/coord/CoordResumeXCommand.java 
0aae1e6 
  core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java 
02b30ef 
  core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java 
b1b2fcd 
  core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java 
a177101 
  core/src/main/java/org/apache/oozie/command/coord/CoordUpdateXCommand.java 
d6e47da 
  core/src/main/java/org/apache/oozie/command/wf/ActionCheckXCommand.java 
39c522d 
  core/src/main/java/org/apache/oozie/command/wf/ActionEndXCommand.java 42cb290 
  core/src/main/java/org/apache/oozie/command/wf/ActionKillXCommand.java 
863bf7d 
  core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java 
f3a4ba9 
  core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java 0c4c548 
  core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java 
41e6732 
  core/src/main/java/org/apache/oozie/command/wf/DefinitionXCommand.java 
64d4822 
  core/src/main/java/org/apache/oozie/command/wf/KillXCommand.java 37a2f8b 
  core/src/main/java/org/apache/oozie/command/wf/NotificationXCommand.java 
651b5fd 
  core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java 5dd06ca 
  core/src/main/java/org/apache/oozie/command/wf/ResumeXCommand.java 7b8ee3b 
  core/src/main/java/org/apache/oozie/command/wf/SignalXCommand.java 4a7283f 
  core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java 
5e9abcf 
  core/src/main/java/org/apache/oozie/command/wf/SubmitXCommand.java 66baca1 
  core/src/main/java/org/apache/oozie/command/wf/SuspendXCommand.java 635186a 
  core/src/main/java/org/apache/oozie/service/CallableQueueService.java 093eb08 
  core/src/main/java/org/apache/oozie/service/EventHandlerService.java 761537b 
  core/src/main/java/org/apache/oozie/servlet/CallbackServlet.java 541faca 
  core/src/main/java/org/apache/oozie/servlet/JsonRestServlet.java f7458dc 
  core/src/main/java/org/apache/oozie/util/LogUtils.java 814caff 
  core/src/main/java/org/apache/oozie/util/XLog.java 31a5ba0 
  core/src/test/java/org/apache/oozie/util/TestXLog.java 824e5dc 

Diff: https://reviews.apache.org/r/23968/diff/


Testing
-------

Done manual test.


Thanks,

Azrael Park

Reply via email to