Skip to content

Commit

Permalink
[Iceberg]Fix flaky caused by rename view test
Browse files Browse the repository at this point in the history
  • Loading branch information
hantangwangd committed Dec 21, 2024
1 parent 737f5e1 commit eae4696
Showing 1 changed file with 12 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -157,16 +157,18 @@ public void testTableValidation()
@Test
public void testRenameView()
{
assertQuerySucceeds("CREATE TABLE iceberg.test_schema.iceberg_test_table (_string VARCHAR, _integer INTEGER)");
assertUpdate("CREATE VIEW iceberg.test_schema.test_view_to_be_renamed AS SELECT * FROM iceberg.test_schema.iceberg_test_table");
assertUpdate("ALTER VIEW IF EXISTS iceberg.test_schema.test_view_to_be_renamed RENAME TO iceberg.test_schema.test_view_renamed");
assertUpdate("CREATE VIEW iceberg.test_schema.test_view2_to_be_renamed AS SELECT * FROM iceberg.test_schema.iceberg_test_table");
assertUpdate("ALTER VIEW iceberg.test_schema.test_view2_to_be_renamed RENAME TO iceberg.test_schema.test_view2_renamed");
assertQuerySucceeds("SELECT * FROM iceberg.test_schema.test_view_renamed");
assertQuerySucceeds("SELECT * FROM iceberg.test_schema.test_view2_renamed");
assertUpdate("DROP VIEW iceberg.test_schema.test_view_renamed");
assertUpdate("DROP VIEW iceberg.test_schema.test_view2_renamed");
assertUpdate("DROP TABLE iceberg.test_schema.iceberg_test_table");
assertQuerySucceeds("CREATE SCHEMA iceberg.test_rename_view_schema");
assertQuerySucceeds("CREATE TABLE iceberg.test_rename_view_schema.iceberg_test_table (_string VARCHAR, _integer INTEGER)");
assertUpdate("CREATE VIEW iceberg.test_rename_view_schema.test_view_to_be_renamed AS SELECT * FROM iceberg.test_rename_view_schema.iceberg_test_table");
assertUpdate("ALTER VIEW IF EXISTS iceberg.test_rename_view_schema.test_view_to_be_renamed RENAME TO iceberg.test_rename_view_schema.test_view_renamed");
assertUpdate("CREATE VIEW iceberg.test_rename_view_schema.test_view2_to_be_renamed AS SELECT * FROM iceberg.test_rename_view_schema.iceberg_test_table");
assertUpdate("ALTER VIEW iceberg.test_rename_view_schema.test_view2_to_be_renamed RENAME TO iceberg.test_rename_view_schema.test_view2_renamed");
assertQuerySucceeds("SELECT * FROM iceberg.test_rename_view_schema.test_view_renamed");
assertQuerySucceeds("SELECT * FROM iceberg.test_rename_view_schema.test_view2_renamed");
assertUpdate("DROP VIEW iceberg.test_rename_view_schema.test_view_renamed");
assertUpdate("DROP VIEW iceberg.test_rename_view_schema.test_view2_renamed");
assertUpdate("DROP TABLE iceberg.test_rename_view_schema.iceberg_test_table");
assertQuerySucceeds("DROP SCHEMA IF EXISTS iceberg.test_rename_view_schema");
}
@Test
public void testRenameViewIfNotExists()
Expand Down

0 comments on commit eae4696

Please sign in to comment.