You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gobblin.apache.org by "Jay Sen (Jira)" <ji...@apache.org> on 2019/11/08 17:28:00 UTC
[jira] [Created] (GOBBLIN-952) PathAlerationListner needs to picks
up only modified job
Jay Sen created GOBBLIN-952:
-------------------------------
Summary: PathAlerationListner needs to picks up only modified job
Key: GOBBLIN-952
URL: https://issues.apache.org/jira/browse/GOBBLIN-952
Project: Apache Gobblin
Issue Type: Bug
Affects Versions: 0.14.0
Reporter: Jay Sen
Fix For: 0.15.0
{{PathAlterationListenerAdaptorForMonitor}} detects any changes to the job config path, which is the required functionality but it also literally tried to schedule or unschedule all the changes.
In case the job runs only once (by config), it will move it to .done file which it then tries to unschedule it.
May be the monitor needs additional logic to ignore some changes like this.
here is the log
{code:java}
22:57:38.803 INFO: [TaskExecutor STOPPING-97] [org.apache.gobblin.runtime.TaskExecutor] TaskExecutor - Successfully shutdown ExecutorService: com.google.common.util.concurrent.MoreExecutors$ScheduledListeningDecorator@6b5a367e
22:57:38.803 INFO: [TaskExecutor STOPPING-97] [org.apache.gobblin.runtime.TaskExecutor] TaskExecutor - Attempting to shutdown ExecutorService: com.google.common.util.concurrent.MoreExecutors$ListeningDecorator@659dd565
22:57:38.803 INFO: [TaskExecutor STOPPING-97] [org.apache.gobblin.runtime.TaskExecutor] TaskExecutor - Successfully shutdown ExecutorService: com.google.common.util.concurrent.MoreExecutors$ListeningDecorator@659dd565
22:57:38.803 INFO: [LocalTaskStateTracker STOPPING-98] [org.apache.gobblin.runtime.local.LocalTaskStateTracker] LocalTaskStateTracker - Stopping the task state tracker
22:57:38.803 INFO: [LocalTaskStateTracker STOPPING-98] [org.apache.gobblin.runtime.local.LocalTaskStateTracker] LocalTaskStateTracker - Attempting to shutdown ExecutorService: com.google.common.util.concurrent.MoreExecutors$ScheduledListeningDecorator@5faf4e52
22:57:38.804 INFO: [LocalTaskStateTracker STOPPING-98] [org.apache.gobblin.runtime.local.LocalTaskStateTracker] LocalTaskStateTracker - Successfully shutdown ExecutorService: com.google.common.util.concurrent.MoreExecutors$ScheduledListeningDecorator@5faf4e52
22:57:38.804 INFO: [JobScheduler-2-70] [org.apache.gobblin.source.extractor.filebased.FileBasedSource] FileBasedSource - Shutting down the FileSystemHelper connection
22:57:56.476 INFO: [newDaemonThreadFactory-26] [org.apache.gobblin.scheduler.PathAlterationListenerAdaptorForMonitor] PathAlterationListenerAdaptorForMonitor - Detected deletion of job configuration file file:/home/jsenjaliya/gobblin-dist/gobblin-jobs/local-aerospike-avro.pull
22:57:56.476 INFO: [newDaemonThreadFactory-26] [org.apache.gobblin.scheduler.PathAlterationListenerAdaptorForMonitor] PathAlterationListenerAdaptorForMonitor - Could not find a scheduled job to unschedule with path /home/jsenjaliya/gobblin-dist/gobblin-jobs/local-aerospike-avro.pull
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)