You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2018/03/21 08:31:01 UTC
[43/50] incubator-gobblin git commit: [GOBBLIN-418] Change Gobblin
Service behavior to not call addSpec for pre-existing specs on FlowCatalog
start up.[]
[GOBBLIN-418] Change Gobblin Service behavior to not call addSpec for pre-existing specs on FlowCatalog start up.[]
Closes #2297 from sv2000/gobblin-418
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/ca5835b1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/ca5835b1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/ca5835b1
Branch: refs/heads/0.12.0
Commit: ca5835b164055815efe5968979b6261c2c9b9fdc
Parents: faa27f4
Author: suvasude <su...@linkedin.biz>
Authored: Fri Mar 2 10:46:02 2018 -0800
Committer: Hung Tran <hu...@linkedin.com>
Committed: Fri Mar 2 10:46:02 2018 -0800
----------------------------------------------------------------------
.../java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/ca5835b1/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
index a91baed..f78be47 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
@@ -121,7 +121,7 @@ public class FlowCatalog extends AbstractIdleService implements SpecCatalog, Mut
@Override
protected void startUp() throws Exception {
- notifyAllListeners();
+ //Do nothing
}
@Override