Permalink
Browse files

Adding CachingFlow

  • Loading branch information...
rbpark committed Mar 21, 2012
1 parent fc455fa commit 4849960c7af36c417370e3e39699a945b47b0462
Showing with 2 additions and 1 deletion.
  1. +2 −1 azkaban/src/java/azkaban/flow/CachingFlowManager.java
@@ -64,7 +64,7 @@ public CachingFlowManager(FlowManager baseManager, final int cacheSize, final lo
cache = new Cache(config);
manager.addCache(cache);
- cleanInterval = timeToIdle * 1000;
+ cleanInterval = timeToIdle * 1000l;
}
private void cleanCache() {
@@ -146,6 +146,7 @@ public long getCurrMaxId()
public FlowExecutionHolder saveExecutableFlow(FlowExecutionHolder holder)
{
+ cleanCache();
return baseManager.saveExecutableFlow(holder);
}

0 comments on commit 4849960

Please sign in to comment.