falcon-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "pavan kumar kolamuri" <pavan.kolam...@gmail.com>
Subject Re: Review Request 41401: Rerun API for Falcon Native Scheduler
Date Thu, 17 Dec 2015 09:00:03 GMT

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

(Updated Dec. 17, 2015, 9 a.m.)


Review request for Falcon.


Changes
-------

Added description to Rerun API as said in comments


Repository: falcon-git


Description
-------

Currently rerun API was not supported in case of Native Scheduler in Falcon. Rerun of instances
should be implemented in FalconWorkflowEngine.


Diffs (updated)
-----

  client/src/main/java/org/apache/falcon/resource/InstancesResult.java e05eeeb 
  scheduler/src/main/java/org/apache/falcon/execution/EntityExecutor.java c9c0f42 
  scheduler/src/main/java/org/apache/falcon/execution/ExecutionInstance.java 3cc8a25 
  scheduler/src/main/java/org/apache/falcon/execution/ProcessExecutionInstance.java f3beabc

  scheduler/src/main/java/org/apache/falcon/execution/ProcessExecutor.java e446069 
  scheduler/src/main/java/org/apache/falcon/notification/service/event/EventType.java 59f5cba

  scheduler/src/main/java/org/apache/falcon/notification/service/event/RerunEvent.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/notification/service/impl/SchedulerService.java
fb11091 
  scheduler/src/main/java/org/apache/falcon/predicate/Predicate.java 164fb0e 
  scheduler/src/main/java/org/apache/falcon/state/InstanceState.java 7f2bda9 
  scheduler/src/main/java/org/apache/falcon/state/InstanceStateChangeHandler.java 1f69fab

  scheduler/src/main/java/org/apache/falcon/state/StateService.java c702cc3 
  scheduler/src/main/java/org/apache/falcon/state/store/InMemoryStateStore.java 2f3aa3a 
  scheduler/src/main/java/org/apache/falcon/state/store/InstanceStateStore.java f1d1931 
  scheduler/src/main/java/org/apache/falcon/state/store/jdbc/BeanMapperUtil.java 4bee269 
  scheduler/src/main/java/org/apache/falcon/state/store/jdbc/InstanceBean.java 0e3dfa9 
  scheduler/src/main/java/org/apache/falcon/state/store/jdbc/JDBCStateStore.java b2f8e80 
  scheduler/src/main/java/org/apache/falcon/workflow/engine/DAGEngine.java e0d2a0e 
  scheduler/src/main/java/org/apache/falcon/workflow/engine/FalconWorkflowEngine.java c19cada

  scheduler/src/main/java/org/apache/falcon/workflow/engine/OozieDAGEngine.java a26eb77 
  scheduler/src/test/java/org/apache/falcon/execution/MockDAGEngine.java d274ad7 
  scheduler/src/test/java/org/apache/falcon/state/service/store/TestJDBCStateStore.java 6d5bd49

  webapp/src/test/java/org/apache/falcon/resource/AbstractSchedulerManagerJerseyIT.java f5bcc54

  webapp/src/test/java/org/apache/falcon/resource/InstanceSchedulerManagerJerseyIT.java 7959b63

  webapp/src/test/resources/local-process-noinputs-template.xml aabdc6a 

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


Testing
-------


Thanks,

pavan kumar kolamuri


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message