Repository: ambari Updated Branches: refs/heads/branch-1.7.0 1e6167bf5 -> db147072a
AMBARI-7866 - Unable to create new user group after upgrade from 1.6.1 to 1.7.0 Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/db147072 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/db147072 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/db147072 Branch: refs/heads/branch-1.7.0 Commit: db147072aa27746591ca2ee648bde5f0b46778f2 Parents: 1e6167b Author: tbeerbower <[email protected]> Authored: Mon Oct 20 16:06:24 2014 -0400 Committer: tbeerbower <[email protected]> Committed: Mon Oct 20 16:13:13 2014 -0400 ---------------------------------------------------------------------- .../ambari/server/upgrade/UpgradeCatalog170.java | 2 +- .../ambari/server/upgrade/UpgradeCatalog170Test.java | 13 +++++++++++++ 2 files changed, 14 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/db147072/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java b/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java index 34caa48..00b52dc 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/upgrade/UpgradeCatalog170.java @@ -171,7 +171,7 @@ public class UpgradeCatalog170 extends AbstractUpgradeCatalog { columns = new ArrayList<DBColumnInfo>(); columns.add(new DBColumnInfo("group_id", Integer.class, 1, null, false)); columns.add(new DBColumnInfo("principal_id", Integer.class, 1, null, false)); - columns.add(new DBColumnInfo("group_name", String.class, 1, null, false)); + columns.add(new DBColumnInfo("group_name", String.class, 255, null, false)); columns.add(new DBColumnInfo("ldap_group", Integer.class, 1, 0, false)); dbAccessor.createTable("groups", columns, "group_id"); http://git-wip-us.apache.org/repos/asf/ambari/blob/db147072/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java b/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java index a02a962..fbb3eca 100644 --- a/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java +++ b/ambari-server/src/test/java/org/apache/ambari/server/upgrade/UpgradeCatalog170Test.java @@ -303,6 +303,7 @@ public class UpgradeCatalog170Test { Capture<DBAccessor.DBColumnInfo> maskedColumnCapture = new Capture<DBAccessor.DBColumnInfo>(); Capture<DBAccessor.DBColumnInfo> stageCommandParamsColumnCapture = new Capture<DBAccessor.DBColumnInfo>(); Capture<DBAccessor.DBColumnInfo> stageHostParamsColumnCapture = new Capture<DBAccessor.DBColumnInfo>(); + Capture<List<DBAccessor.DBColumnInfo>> groupsCapture = new Capture<List<DBAccessor.DBColumnInfo>>(); Capture<List<DBAccessor.DBColumnInfo>> alertDefinitionColumnCapture = new Capture<List<DBAccessor.DBColumnInfo>>(); Capture<List<DBAccessor.DBColumnInfo>> alertHistoryColumnCapture = new Capture<List<DBAccessor.DBColumnInfo>>(); Capture<List<DBAccessor.DBColumnInfo>> alertCurrentColumnCapture = new Capture<List<DBAccessor.DBColumnInfo>>(); @@ -317,6 +318,9 @@ public class UpgradeCatalog170Test { Capture<DBAccessor.DBColumnInfo> configDataBlueprintConfigurationCapture = new Capture<DBAccessor.DBColumnInfo>(); Capture<DBAccessor.DBColumnInfo> configDataHostGroupConfigurationCapture = new Capture<DBAccessor.DBColumnInfo>(); + dbAccessor.createTable(eq("groups"), + capture(groupsCapture), eq("group_id")); + setViewExpectations(dbAccessor, maskColumnCapture, systemColumnCapture); setViewParameterExpectations(dbAccessor, maskedColumnCapture); setClusterConfigExpectations(dbAccessor, clusterConfigAttributesColumnCapture); @@ -379,6 +383,15 @@ public class UpgradeCatalog170Test { assertViewParameterColumns(maskedColumnCapture); assertStageColumns(stageCommandParamsColumnCapture, stageHostParamsColumnCapture); + assertEquals(4, groupsCapture.getValue().size()); + List<DBAccessor.DBColumnInfo> columnInfoList = groupsCapture.getValue(); + for (DBAccessor.DBColumnInfo info : columnInfoList) { + if (info.getName().equals("group_name")) { + assertEquals(Integer.valueOf(255), info.getLength()); + break; + } + } + assertEquals(12, alertDefinitionColumnCapture.getValue().size()); assertEquals(11, alertHistoryColumnCapture.getValue().size()); assertEquals(7, alertCurrentColumnCapture.getValue().size());
