Schema newSchema = createNewSchema();
hive.alterSchema(hiveDatabase, TOPIC, newSchema);
String[] expectedResult = {"true", "12", "12", "12.2", "12.2", "abc", "12"};
String result = HiveTestUtils.runHive(hiveExec, "SELECT * from " + TOPIC);
String[] rows = result.split("\n");
<BUG>assertEquals(7, rows.length);
</BUG>
for (String row: rows) {
String[] parts = HiveTestUtils.parseOutput(row);
for (int j = 0; j < expectedResult.length; ++j) {

Schema newSchema = createNewSchema();
hive.alterSchema(hiveDatabase, TOPIC, newSchema);
String[] expectedResult = {"true", "12", "12", "12.2", "12.2", "abc", "12"};
String result = HiveTestUtils.runHive(hiveExec, "SELECT * from " + TOPIC);
String[] rows = result.split("\n");
assertEquals(6, rows.length);
for (String row: rows) {
String[] parts = HiveTestUtils.parseOutput(row);
for (int j = 0; j < expectedResult.length; ++j) {
