AMBARI-19381. Heartbeat version transitions must be update Component alongside Cluster (ncole)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/42b8dcf7 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/42b8dcf7 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/42b8dcf7 Branch: refs/heads/trunk Commit: 42b8dcf777ccdd72f84edccd16df78ac526bd218 Parents: 551f17b Author: Nate Cole <nc...@hortonworks.com> Authored: Thu Jan 5 05:01:03 2017 -0500 Committer: Nate Cole <nc...@hortonworks.com> Committed: Wed Jan 25 14:13:25 2017 -0500 ---------------------------------------------------------------------- .../server/orm/dao/ServiceComponentDesiredStateDAO.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/42b8dcf7/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/ServiceComponentDesiredStateDAO.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/ServiceComponentDesiredStateDAO.java b/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/ServiceComponentDesiredStateDAO.java index 11e41b6..92f1d09 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/ServiceComponentDesiredStateDAO.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/ServiceComponentDesiredStateDAO.java @@ -199,6 +199,14 @@ public class ServiceComponentDesiredStateDAO { return daoUtils.selectList(query); } + /** + * Gets a specific version for a component + * @param clusterId the cluster id + * @param serviceName the service name + * @param componentName the component name + * @param version the component version to find + * @return the version entity, or {@code null} if not found + */ @RequiresSession public ServiceComponentVersionEntity findVersion(long clusterId, String serviceName, String componentName, String version) {
