You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by hu...@apache.org on 2018/03/16 16:27:22 UTC
incubator-gobblin git commit: [GOBBLIN-428] fix delete spec not
propagating to cluster
Repository: incubator-gobblin
Updated Branches:
refs/heads/master 2e61a10ac -> 7e1d8433a
[GOBBLIN-428] fix delete spec not propagating to cluster
Closes #2305 from arjun4084346/fixDeleteInCluster
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/7e1d8433
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/7e1d8433
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/7e1d8433
Branch: refs/heads/master
Commit: 7e1d8433aee46c2d3f97c068b4348fc051bef654
Parents: 2e61a10
Author: Arjun <ab...@linkedin.com>
Authored: Fri Mar 16 09:27:15 2018 -0700
Committer: Hung Tran <hu...@linkedin.com>
Committed: Fri Mar 16 09:27:15 2018 -0700
----------------------------------------------------------------------
.../gobblin/runtime/job_monitor/KafkaJobMonitor.java | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/7e1d8433/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
index 0bb4f14..6902eae 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
@@ -71,13 +71,9 @@ public abstract class KafkaJobMonitor extends HighLevelConsumer<byte[], byte[]>
super(topic, ConfigUtils.getConfigOrEmpty(config, KAFKA_JOB_MONITOR_PREFIX), 1);
this.jobCatalog = catalog;
try {
- if (config.hasPath(ConfigurationKeys.STATE_STORE_ENABLED) &&
- config.getBoolean(ConfigurationKeys.STATE_STORE_ENABLED) &&
- config.hasPath(ConfigurationKeys.STATE_STORE_ROOT_DIR_KEY)) {
- this.datasetStateStore = DatasetStateStore.buildDatasetStateStore(config);
- }
- } catch (IOException e) {
- log.warn("DatasetStateStore could not be created.");
+ this.datasetStateStore = DatasetStateStore.buildDatasetStateStore(config);
+ } catch (Exception e) {
+ log.warn("DatasetStateStore could not be created.", e);
}
}