Skip to content

Commit

Permalink
Fix and enable kudu update test
Browse files Browse the repository at this point in the history
  • Loading branch information
chenjian2664 authored and ebyhr committed Dec 16, 2024
1 parent edc72f2 commit 16fe873
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -927,19 +927,19 @@ public void testRowLevelDelete()
}

/**
* This test fails intermittently because Kudu doesn't have strong enough
* semantics to support writing from multiple threads.
* createTableForWrites will create the table using the first column as the primary key.
* Attempting to update the primary key (`nationkey` in this case) caused a failure due to duplicate values.
* This override modifies the test to focus on updating the `regionkey` instead.
*/
@Test
@Disabled
@Override
public void testUpdate()
{
withTableName("test_update", tableName -> {
createTableForWrites("CREATE TABLE %s " + NATION_COLUMNS, tableName, Optional.empty());
assertUpdate("INSERT INTO " + tableName + " SELECT * FROM nation", 25);
assertUpdate("UPDATE " + tableName + " SET nationkey = 100 WHERE regionkey = 2", 5);
assertQuery("SELECT count(*) FROM " + tableName + " WHERE nationkey = 100", "VALUES 5");
assertUpdate("UPDATE " + tableName + " SET regionkey = 100 WHERE regionkey = 2", 5);
assertQuery("SELECT count(*) FROM " + tableName + " WHERE regionkey = 100", "VALUES 5");
});
}

Expand Down

0 comments on commit 16fe873

Please sign in to comment.