Fix Ignite schema change operation tests failure

Author: chenjian2664

plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteConnectorTest.java

@@ -20,6 +20,8 @@
 import io.trino.testing.TestingConnectorBehavior;
 import io.trino.testing.sql.SqlExecutor;
 import io.trino.testing.sql.TestTable;
+import io.trino.testng.services.Flaky;
+import org.intellij.lang.annotations.Language;
 import org.testng.SkipException;
 import org.testng.annotations.Test;
 
@@ -37,6 +39,10 @@
 public class TestIgniteConnectorTest
         extends BaseJdbcConnectorTest
 {
+    private static final String SCHEMA_CHANGE_OPERATION_FAIL_ISSUE = "https://github.com/trinodb/trino/issues/14391";
+    @Language("RegExp")
+    private static final String SCHEMA_CHANGE_OPERATION_FAIL_MATCH = "Schema change operation failed: Thread got interrupted while trying to acquire table lock.";
+
     private TestingIgniteServer igniteServer;
 
     @Override
@@ -317,7 +323,9 @@ protected void verifyConcurrentAddColumnFailurePermissible(Exception e)
         assertThat(e).hasMessage("Schema change operation failed: Thread got interrupted while trying to acquire table lock.");
     }
 
+    @Test
     @Override
+    @Flaky(issue = SCHEMA_CHANGE_OPERATION_FAIL_ISSUE, match = SCHEMA_CHANGE_OPERATION_FAIL_MATCH)
     public void testDropAndAddColumnWithSameName()
     {
         // Override because Ignite can access old data after dropping and adding a column with same name
@@ -330,6 +338,38 @@ public void testDropAndAddColumnWithSameName()
         }
     }
 
+    @Test
+    @Override
+    @Flaky(issue = SCHEMA_CHANGE_OPERATION_FAIL_ISSUE, match = SCHEMA_CHANGE_OPERATION_FAIL_MATCH)
+    public void testAddColumn()
+    {
+        super.testAddColumn();
+    }
+
+    @Test
+    @Override
+    @Flaky(issue = SCHEMA_CHANGE_OPERATION_FAIL_ISSUE, match = SCHEMA_CHANGE_OPERATION_FAIL_MATCH)
+    public void testDropColumn()
+    {
+        super.testDropColumn();
+    }
+
+    @Test
+    @Override
+    @Flaky(issue = SCHEMA_CHANGE_OPERATION_FAIL_ISSUE, match = SCHEMA_CHANGE_OPERATION_FAIL_MATCH)
+    public void testAlterTableAddLongColumnName()
+    {
+        super.testAlterTableAddLongColumnName();
+    }
+
+    @Test(dataProvider = "testColumnNameDataProvider")
+    @Override
+    @Flaky(issue = SCHEMA_CHANGE_OPERATION_FAIL_ISSUE, match = SCHEMA_CHANGE_OPERATION_FAIL_MATCH)
+    public void testAddAndDropColumnName(String columnName)
+    {
+        super.testAddAndDropColumnName(columnName);
+    }
+
     @Override
     protected TestTable simpleTable()
     {