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 <hut...@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); } }
