Bill Farner created AURORA-1407:
-----------------------------------
Summary: IllegalArgumentException in end-to-end tests
Key: AURORA-1407
URL: https://issues.apache.org/jira/browse/AURORA-1407
Project: Aurora
Issue Type: Bug
Components: Scheduler, Testing
Reporter: Bill Farner
Priority: Blocker
When running end-to-end tests on {{38c2e76}}, i encountered the following error:
{noformat}
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)
{noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
