This is an automated email from the ASF dual-hosted git repository.
zstan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 317cbb554a IGNITE-18506 Correct annotation for disabled test
317cbb554a is described below
commit 317cbb554a334f54e90aac6e048422681b8640d6
Author: zstan <[email protected]>
AuthorDate: Fri Mar 10 14:00:08 2023 +0300
IGNITE-18506 Correct annotation for disabled test
---
.../internal/runner/app/ItDataSchemaSyncTest.java | 28 ++++++++++++----------
1 file changed, 15 insertions(+), 13 deletions(-)
diff --git
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
index 7a5c7aebd0..10c2abe728 100644
---
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
+++
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
@@ -191,7 +191,7 @@ public class ItDataSchemaSyncTest extends
IgniteAbstractTest {
* Test correctness of schemes recovery after node restart.
*/
@Test
- @Disabled("Enable when IGNITE-18506 is fixed")
+ @Disabled("Enable when IGNITE-18203 is fixed")
public void checkSchemasCorrectlyRestore() throws Exception {
Ignite ignite1 = clusterNodes.get(1);
@@ -218,25 +218,27 @@ public class ItDataSchemaSyncTest extends
IgniteAbstractTest {
ignite1 = ignite1Fut.get();
- Session ses = ignite1.sql().createSession();
+ try (Session ses = ignite1.sql().createSession()) {
+ ResultSet<SqlRow> res = ses.execute(null, "SELECT valint2 FROM
tbl1");
- ResultSet<SqlRow> res = ses.execute(null, "SELECT valint2 FROM tbl1");
+ for (int i = 0; i < 10; ++i) {
+ assertNotNull(res.next().iterator().next());
+ }
- for (int i = 0; i < 10; ++i) {
- assertNotNull(res.next().iterator().next());
- }
+ for (int i = 10; i < 20; ++i) {
+ sql(ignite1, String.format("INSERT INTO " + TABLE_NAME + "
VALUES(%d, %d, %d, %d)", i, i, i, i));
+ }
- for (int i = 10; i < 20; ++i) {
- sql(ignite1, String.format("INSERT INTO " + TABLE_NAME + "
VALUES(%d, %d, %d, %d)", i, i, i, i));
- }
+ sql(ignite1, "ALTER TABLE " + TABLE_NAME + " DROP COLUMN valint3");
- sql(ignite1, "ALTER TABLE " + TABLE_NAME + " DROP COLUMN valint3");
+ sql(ignite1, "ALTER TABLE " + TABLE_NAME + " ADD COLUMN valint5
INT");
- sql(ignite1, "ALTER TABLE " + TABLE_NAME + " ADD COLUMN valint5 INT");
+ res = ses.execute(null, "SELECT sum(valint4) FROM tbl1");
- res = ses.execute(null, "SELECT sum(valint4) FROM tbl1");
+ assertEquals(10L * (10 + 19) / 2, res.next().iterator().next());
- assertEquals(res.next().iterator().next(), 10L * (10 + 19) / 2);
+ res.close();
+ }
}
/**