diff --git a/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/TestKuduConnectorTest.java b/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/TestKuduConnectorTest.java index be6690f7542b..e1c7579e9c01 100644 --- a/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/TestKuduConnectorTest.java +++ b/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/TestKuduConnectorTest.java @@ -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"); }); }