Details
Blocker Description
When running end-to-end tests on 38c2e76, i encountered the following error:
E0723 00:20:18.231 THREAD137 org.apache.aurora.scheduler.updater.JobUpdateEventSubscriber.taskChangedState: Failed to handle state change: com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalArgumentException: Multiple entries wit
h same key: TaskConfig(job:JobKey(role:vagrant, environment:test, name:http_example_docker), owner:Identity(role:vagrant, user:vagrant), environment:test, jobName:http_example_docker, isService:true, numCpus:0.5, ramMb:34, diskMb:64, priority:0, maxTaskFailu
res:1, production:false, constraints:[Constraint(name:host, constraint:<TaskConstraint limit:LimitConstraint(limit:4)>)], requestedPorts:[http], taskLinks:{http=http://%host%:%port:http%}, contactEmail:vagrant@localhost, executorConfig:ExecutorConfig(name:Au
roraExecutor, data:{"environment": "test", "health_check_config": {"initial_interval_secs": 5.0, "endpoint": "/health", "expected_response_code": 0, "expected_response": "ok", "max_consecutive_failures": 0, "timeout_secs": 1.0, "interval_secs": 1.0}, "contai
ner": {"docker": {"image": "http_example", "parameters": []}}, "name": "http_example_docker", "service": true, "max_task_failures": 1, "cron_collision_policy": "KILL_EXISTING", "enable_hooks": false, "cluster": "devcluster", "task": {"processes": [{"daemon":
false, "name": "stage_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "cp /tmp/http_example.py .", "final": false}, {"daemon": false, "name": "run_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "p
ython http_example.py {{thermos.ports[http]}}", "final": false}], "name": "http_example", "finalization_wait": 30, "max_failures": 1, "max_concurrency": 0, "resources": {"disk": 67108864, "ram": 35651584, "cpu": 0.5}, "constraints": [{"order": ["stage_server
", "run_server"]}]}, "role": "vagrant", "contact": "vagrant@localhost", "announce": {"primary_port": "http", "portmap": {"aurora": "http"}}, "priority": 0, "lifecycle": {"http": {"graceful_shutdown_endpoint": "/quitquitquit", "port": "health", "shutdown_endp
oint": "/abortabortabort"}}, "production": false, "constraints": {"host": "limit:4"}}), metadata:[], container:<Container docker:DockerContainer(image:http_example)>)=org.apache.aurora.scheduler.storage.db.views.DbTaskConfig@12f27c5c and TaskConfig(job:JobKe
y(role:vagrant, environment:test, name:http_example_docker), owner:Identity(role:vagrant, user:vagrant), environment:test, jobName:http_example_docker, isService:true, numCpus:0.5, ramMb:34, diskMb:64, priority:0, maxTaskFailures:1, production:false, constra
ints:[Constraint(name:host, constraint:<TaskConstraint limit:LimitConstraint(limit:4)>)], requestedPorts:[http], taskLinks:{http=http://%host%:%port:http%}, contactEmail:vagrant@localhost, executorConfig:ExecutorConfig(name:AuroraExecutor, data:{"environment": "test", "health_check_config": {"initial_interval_secs": 5.0, "endpoint": "/health", "expected_response_code": 0, "expected_response": "ok", "max_consecutive_failures": 0, "timeout_secs": 1.0, "interval_secs": 1.0}, "container": {"docker": {"image": "http_example", "parameters": []}}, "name": "http_example_docker", "service": true, "max_task_failures": 1, "cron_collision_policy": "KILL_EXISTING", "enable_hooks": false, "cluster": "devcluster", "task": {"processes": [{"daemon": false, "name": "stage_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "cp /tmp/http_example.py .", "final": false}, {"daemon": false, "name": "run_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "python http_example.py {{thermos.ports[http]}}", "final": false}], "name": "http_example", "finalization_wait": 30, "max_failures": 1, "max_concurrency": 0, "resources": {"disk": 67108864, "ram": 35651584, "cpu": 0.5}, "constraints": [{"order": ["stage_server", "run_server"]}]}, "role": "vagrant", "contact": "vagrant@localhost", "announce": {"primary_port": "http", "portmap": {"aurora": "http"}}, "priority": 0, "lifecycle": {"http": {"graceful_shutdown_endpoint": "/quitquitquit", "port": "health", "shutdown_endpoint": "/abortabortabort"}}, "production": false, "constraints": {"host": "limit:4"}}), metadata:[], container:<Container docker:DockerContainer(image:http_example)>)=org.apache.aurora.scheduler.storage.db.views.DbTaskConfig@75f259b
com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalArgumentException: Multiple entries with same key: TaskConfig(job:JobKey(role:vagrant, environment:test, name:http_example_docker), owner:Identity(role:vagrant, user:vagrant), environment:test, jobName:http_example_docker, isService:true, numCpus:0.5, ramMb:34, diskMb:64, priority:0, maxTaskFailures:1, production:false, constraints:[Constraint(name:host, constraint:<TaskConstraint limit:LimitConstraint(limit:4)>)], requestedPorts:[http], taskLinks:{http=http://%host%:%port:http%}, contactEmail:vagrant@localhost, executorConfig:ExecutorConfig(name:AuroraExecutor, data:{"environment": "test", "health_check_config": {"initial_interval_secs": 5.0, "endpoint": "/health", "expected_response_code": 0, "expected_response": "ok", "max_consecutive_failures": 0, "timeout_secs": 1.0, "interval_secs": 1.0}, "container": {"docker": {"image": "http_example", "parameters": []}}, "name": "http_example_docker", "service": true, "max_task_failures": 1, "cron_collision_policy": "KILL_EXISTING", "enable_hooks": false, "cluster": "devcluster", "task": {"processes": [{"daemon": false, "name": "stage_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "cp /tmp/http_example.py .", "final": false}, {"daemon": false, "name": "run_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "python http_example.py {{thermos.ports[http]}}", "final": false}], "name": "http_example", "finalization_wait": 30, "max_failures": 1, "max_concurrency": 0, "resources": {"disk": 67108864, "ram": 35651584, "cpu": 0.5}, "constraints": [{"order": ["stage_server", "run_server"]}]}, "role": "vagrant", "contact": "vagrant@localhost", "announce": {"primary_port": "http", "portmap": {"aurora": "http"}}, "priority": 0, "lifecycle": {"http": {"graceful_shutdown_endpoint": "/quitquitquit", "port": "health", "shutdown_endpoint": "/abortabortabort"}}, "production": false, "constraints": {"host": "limit:4"}}), metadata:[], container:<Container docker:DockerContainer(image:http_example)>)=org.apache.aurora.scheduler.storage.db.views.DbTaskConfig@12f27c5c and TaskConfig(job:JobKey(role:vagrant, environment:test, name:http_example_docker), owner:Identity(role:vagrant, user:vagrant), environment:test, jobName:http_example_docker, isService:true, numCpus:0.5, ramMb:34, diskMb:64, priority:0, maxTaskFailures:1, production:false, constraints:[Constraint(name:host, constraint:<TaskConstraint limit:LimitConstraint(limit:4)>)], requestedPorts:[http], taskLinks:{http=http://%host%:%port:http%}, contactEmail:vagrant@localhost, executorConfig:ExecutorConfig(name:AuroraExecutor, data:{"environment": "test", "health_check_config": {"initial_interval_secs": 5.0, "endpoint": "/health", "expected_response_code": 0, "expected_response": "ok", "max_consecutive_failures": 0, "timeout_secs": 1.0, "interval_secs": 1.0}, "container": {"docker": {"image": "http_example", "parameters": []}}, "name": "http_example_docker", "service": true, "max_task_failures": 1, "cron_collision_policy": "KILL_EXISTING", "enable_hooks": false, "cluster": "devcluster", "task": {"processes": [{"daemon": false, "name": "stage_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "cp /tmp/http_example.py .", "final": false}, {"daemon": false, "name": "run_server", "ephemeral": false, "max_failures": 1, "min_duration": 5, "cmdline": "python http_example.py {{thermos.ports[http]}}", "final": false}], "name": "http_example", "finalization_wait": 30, "max_failures": 1, "max_concurrency": 0, "resources": {"disk": 67108864, "ram": 35651584, "cpu": 0.5}, "constraints": [{"order": ["stage_server", "run_server"]}]}, "role": "vagrant", "contact": "vagrant@localhost", "announce": {"primary_port": "http", "portmap": {"aurora": "http"}}, "priority": 0, "lifecycle": {"http": {"graceful_shutdown_endpoint": "/quitquitquit", "port": "health", "shutdown_endpoint": "/abortabortabort"}}, "production": false, "constraints": {"host": "limit:4"}}), metadata:[], container:<Container docker:DockerContainer(image:http_example)>)=org.apache.aurora.scheduler.storage.db.views.DbTaskConfig@75f259b
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2201)
at com.google.common.cache.LocalCache.get(LocalCache.java:3934)
at com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3938)
at com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4821)
at com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4827)
at org.apache.aurora.scheduler.storage.db.DbTaskStore.saveTasks(DbTaskStore.java:132)
at com.twitter.common.inject.TimedInterceptor.invoke(TimedInterceptor.java:87)
at org.apache.aurora.scheduler.storage.db.DbTaskStore.mutateTasks(DbTaskStore.java:176)
at com.twitter.common.inject.TimedInterceptor.invoke(TimedInterceptor.java:87)
at org.apache.aurora.scheduler.storage.log.WriteAheadStorage.mutateTasks(WriteAheadStorage.java:195)
at org.apache.aurora.scheduler.state.StateManagerImpl.updateTaskAndExternalState(StateManagerImpl.java:326)
at org.apache.aurora.scheduler.state.StateManagerImpl.insertPendingTasks(StateManagerImpl.java:144)
at org.apache.aurora.scheduler.updater.InstanceActionHandler$AddTask.getReevaluationDelay(InstanceActionHandler.java:85)
at org.apache.aurora.scheduler.updater.JobUpdateControllerImpl.evaluateUpdater(JobUpdateControllerImpl.java:668)
at org.apache.aurora.scheduler.updater.JobUpdateControllerImpl.access$1400(JobUpdateControllerImpl.java:108)
at org.apache.aurora.scheduler.updater.JobUpdateControllerImpl$6.execute(JobUpdateControllerImpl.java:356)
at org.apache.aurora.scheduler.storage.Storage$MutateWork$NoResult.apply(Storage.java:131)
at org.apache.aurora.scheduler.storage.Storage$MutateWork$NoResult$Quiet.apply(Storage.java:148)
at org.apache.aurora.scheduler.storage.log.LogStorage$24.apply(LogStorage.java:605)
at org.apache.aurora.scheduler.storage.log.LogStorage$24.apply(LogStorage.java:602)
at org.apache.aurora.scheduler.storage.db.DbStorage.write(DbStorage.java:143)
at org.mybatis.guice.transactional.TransactionalMethodInterceptor.invoke(TransactionalMethodInterceptor.java:101)
at com.twitter.common.inject.TimedInterceptor.invoke(TimedInterceptor.java:87)
at org.apache.aurora.scheduler.storage.log.LogStorage.doInTransaction(LogStorage.java:602)
at org.apache.aurora.scheduler.storage.log.LogStorage.write(LogStorage.java:635)
at org.apache.aurora.scheduler.storage.CallOrderEnforcingStorage.write(CallOrderEnforcingStorage.java:130)
at org.apache.aurora.scheduler.updater.JobUpdateControllerImpl.instanceChanged(JobUpdateControllerImpl.java:347)
at org.apache.aurora.scheduler.updater.JobUpdateControllerImpl.instanceChangedState(JobUpdateControllerImpl.java:332)
at org.apache.aurora.scheduler.updater.JobUpdateEventSubscriber.taskChangedState(JobUpdateEventSubscriber.java:56)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at com.google.common.eventbus.EventSubscriber.handleEvent(EventSubscriber.java:74)
at com.google.common.eventbus.SynchronizedEventSubscriber.handleEvent(SynchronizedEventSubscriber.java:47)
at com.google.common.eventbus.EventBus.dispatch(EventBus.java:322)
at com.google.common.eventbus.AsyncEventBus.access$001(AsyncEventBus.java:34)
at com.google.common.eventbus.AsyncEventBus$1.run(AsyncEventBus.java:117)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)