diff --git a/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/TestSqlServerConnectorTest.java b/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/TestSqlServerConnectorTest.java index 93a16229f5a9..f859fed7a306 100644 --- a/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/TestSqlServerConnectorTest.java +++ b/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/TestSqlServerConnectorTest.java @@ -62,10 +62,8 @@ protected SqlExecutor onRemoteDatabase() return sqlServer::execute; } - @Flaky(issue = "fn_dblog() returns information only about the active portion of the transaction log, therefore it is flaky", match = ".*") @Test public void testCreateTableAsSelectWriteBulkiness() - throws SQLException { testCreateTableAsSelectWriteBulkiness(true, true); testCreateTableAsSelectWriteBulkiness(true, false); @@ -74,7 +72,6 @@ public void testCreateTableAsSelectWriteBulkiness() } private void testCreateTableAsSelectWriteBulkiness(boolean bulkCopyForWrite, boolean bulkCopyLock) - throws SQLException { String table = "bulk_copy_ctas_" + randomNameSuffix(); Session session = Session.builder(getSession()) @@ -86,12 +83,6 @@ private void testCreateTableAsSelectWriteBulkiness(boolean bulkCopyForWrite, boo assertQuerySucceeds(session, format("CREATE TABLE %s as SELECT * FROM tpch.tiny.customer", table)); assertQuery("SELECT * FROM " + table, "SELECT * FROM customer"); - // check whether minimal logging was applied. - // Unlike fully logged operations, which use the transaction log to keep track of every row change, - // minimally logged operations keep track of extent allocations and meta-data changes only. - assertThat(getTableOperationsCount("LOP_INSERT_ROWS", table)) - .isEqualTo(bulkCopyForWrite && bulkCopyLock ? 0 : 1500); - // check that there are no locks remaining on the target table after bulk copy assertQuery("SELECT count(*) FROM " + table, "SELECT count(*) FROM customer"); assertUpdate(format("INSERT INTO %s SELECT * FROM tpch.tiny.customer LIMIT 1", table), 1);