falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shweth...@apache.org
Subject git commit: FALCON-28 unable to submit/delete feed or process which had been attempted submit with wrong cluster - Part 2. Contributed by Shwetha GS
Date Fri, 02 May 2014 11:57:06 GMT
Repository: incubator-falcon
Updated Branches:
  refs/heads/master 40a24c434 -> f25e6c916


FALCON-28 unable to submit/delete feed or process which had been attempted submit with wrong
cluster - Part 2. Contributed by Shwetha GS


Project: http://git-wip-us.apache.org/repos/asf/incubator-falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-falcon/commit/f25e6c91
Tree: http://git-wip-us.apache.org/repos/asf/incubator-falcon/tree/f25e6c91
Diff: http://git-wip-us.apache.org/repos/asf/incubator-falcon/diff/f25e6c91

Branch: refs/heads/master
Commit: f25e6c916d6229f81e454a3ff9417e10a6cb2694
Parents: 40a24c4
Author: Shwetha GS <shwethags@gmail.com>
Authored: Fri May 2 17:26:54 2014 +0530
Committer: Shwetha GS <shwethags@gmail.com>
Committed: Fri May 2 17:26:54 2014 +0530

----------------------------------------------------------------------
 .../falcon/resource/proxy/SchedulableEntityManagerProxy.java   | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/f25e6c91/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java
----------------------------------------------------------------------
diff --git a/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java
b/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java
index 6b07877..a0dbe65 100644
--- a/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java
+++ b/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java
@@ -112,8 +112,14 @@ public class SchedulableEntityManagerProxy extends AbstractSchedulableEntityMana
 
         final String entity = getEntity(bufferedRequest, type).getName();
         Map<String, APIResult> results = new HashMap<String, APIResult>();
+        final Set<String> colos = getApplicableColos(type, getEntity(bufferedRequest,
type));
         results.put(FALCON_TAG, new EntityProxy(type, entity) {
             @Override
+            protected Set<String> getColosToApply() {
+                return colos;
+            }
+
+            @Override
             protected APIResult doExecute(String colo) throws FalconException {
                 return getConfigSyncChannel(colo).invoke("submit", bufferedRequest, type,
colo);
             }


Mime
View raw message