[
https://issues.apache.org/jira/browse/AMBARI-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nate Cole updated AMBARI-18681:
-------------------------------
Description:
For Host Ordered upgrades, add host information and type to the structured out.
The response should contain:
{noformat}
"Tasks": {
"attempt_cnt": 1,
"cluster_name": "c1",
"command": "EXECUTE",
"command_detail": "All services have been stopped on c6401.ambari.apache.org.
Please prepare the new host and then proceed.",
"custom_command_name":
"org.apache.ambari.server.serveraction.upgrades.ManualStageAction",
"role": "AMBARI_SERVER_ACTION",
...
"status": "HOLDING",
"stderr": "",
"stdout": "",
"structured_out": {
"type": "HOST_PREPARE"
"host": "c6401.ambari.apache.org"
}
}
{noformat}
was:
While doing the POC for Offline Upgrades, the StackVersionListener was trying
to add duplicate records based on version.
{noformat}
Local Exception Stack:
Exception [EclipseLink-4002] (Eclipse Persistence Services -
2.6.2.v20151217-774c696): org.eclipse.persistence.exceptions.DatabaseException
Internal Exception: org.postgresql.util.PSQLException: ERROR: duplicate key
value violates unique constraint "uq_repo_version_stack_id"
Detail: Key (stack_id, version)=(2, 2.5.1.0-30) already exists.
Error Code: 0
Call: UPDATE repo_version SET version = ? WHERE (repo_version_id = ?)
bind => [2 parameters bound]
at
org.eclipse.persistence.exceptions.DatabaseException.sqlException(DatabaseException.java:340)
at
org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor.processExceptionForCommError(DatabaseAccessor.java:1620)
at
org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor.executeDirectNoSelect(DatabaseAccessor.java:900)
at
org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor.executeNoSelect(DatabaseAccessor.java:964)
at
org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor.basicExecuteCall(DatabaseAccessor.java:633)
at
org.eclipse.persistence.internal.databaseaccess.ParameterizedSQLBatchWritingMechanism.executeBatch(ParameterizedSQLBatchWritingMechanism.java:149)
at
org.eclipse.persistence.internal.databaseaccess.ParameterizedSQLBatchWritingMechanism.executeBatchedStatements(ParameterizedSQLBatchWritingMechanism.java:134)
at
org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor.writesCompleted(DatabaseAccessor.java:1845)
at
org.eclipse.persistence.internal.sessions.AbstractSession.writesCompleted(AbstractSession.java:4300)
at
org.eclipse.persistence.internal.sessions.UnitOfWorkImpl.writesCompleted(UnitOfWorkImpl.java:5592)
at
org.eclipse.persistence.internal.sessions.UnitOfWorkImpl.acquireWriteLocks(UnitOfWorkImpl.java:1646)
at
org.eclipse.persistence.internal.sessions.UnitOfWorkImpl.commitTransactionAfterWriteChanges(UnitOfWorkImpl.java:1614)
at
org.eclipse.persistence.internal.sessions.RepeatableWriteUnitOfWork.commitRootUnitOfWork(RepeatableWriteUnitOfWork.java:285)
at
org.eclipse.persistence.internal.sessions.UnitOfWorkImpl.commitAndResume(UnitOfWorkImpl.java:1169)
at
org.eclipse.persistence.internal.jpa.transaction.EntityTransactionImpl.commit(EntityTransactionImpl.java:134)
at
org.apache.ambari.server.orm.AmbariJpaLocalTxnInterceptor.invoke(AmbariJpaLocalTxnInterceptor.java:153)
at
org.apache.ambari.server.events.listeners.upgrade.StackVersionListener.onAmbariEvent(StackVersionListener.java:106)
at sun.reflect.GeneratedMethodAccessor179.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
com.google.common.eventbus.EventSubscriber.handleEvent(EventSubscriber.java:74)
at com.google.common.eventbus.EventBus.dispatch(EventBus.java:322)
at
com.google.common.eventbus.EventBus.dispatchQueuedEvents(EventBus.java:304)
at com.google.common.eventbus.EventBus.post(EventBus.java:275)
at
org.apache.ambari.server.events.publishers.VersionEventPublisher.publish(VersionEventPublisher.java:52)
at
org.apache.ambari.server.agent.HeartbeatProcessor.processCommandReports(HeartbeatProcessor.java:493)
at
org.apache.ambari.server.agent.HeartbeatProcessor.processHeartbeat(HeartbeatProcessor.java:213)
at
org.apache.ambari.server.agent.HeartbeatProcessor$HeartbeatProcessingTask.run(HeartbeatProcessor.java:188)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{noformat}
> StackVersionListener should check for cluster version
> -----------------------------------------------------
>
> Key: AMBARI-18681
> URL: https://issues.apache.org/jira/browse/AMBARI-18681
> Project: Ambari
> Issue Type: Task
> Components: ambari-server
> Reporter: Nate Cole
> Assignee: Nate Cole
> Priority: Critical
> Fix For: 2.5.0
>
>
> For Host Ordered upgrades, add host information and type to the structured
> out. The response should contain:
> {noformat}
> "Tasks": {
> "attempt_cnt": 1,
> "cluster_name": "c1",
> "command": "EXECUTE",
> "command_detail": "All services have been stopped on
> c6401.ambari.apache.org. Please prepare the new host and then proceed.",
> "custom_command_name":
> "org.apache.ambari.server.serveraction.upgrades.ManualStageAction",
> "role": "AMBARI_SERVER_ACTION",
> ...
> "status": "HOLDING",
> "stderr": "",
> "stdout": "",
> "structured_out": {
> "type": "HOST_PREPARE"
> "host": "c6401.ambari.apache.org"
> }
> }
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
