This is an automated email from the ASF dual-hosted git repository.
ibessonov 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 ff7909ec78 IGNITE-18376 Use aimem in ItIgniteInMemoryNodeRestartTest
(#1437)
ff7909ec78 is described below
commit ff7909ec78d7e2b3e84a1cc7cf3a60545e2b9d72
Author: Alexander Polovtcev <[email protected]>
AuthorDate: Tue Dec 13 10:30:18 2022 +0300
IGNITE-18376 Use aimem in ItIgniteInMemoryNodeRestartTest (#1437)
---
.../internal/runner/app/ItIgniteInMemoryNodeRestartTest.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteInMemoryNodeRestartTest.java
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteInMemoryNodeRestartTest.java
index 8d5fb1f433..fb32865c60 100644
---
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteInMemoryNodeRestartTest.java
+++
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteInMemoryNodeRestartTest.java
@@ -20,6 +20,7 @@ package org.apache.ignite.internal.runner.app;
import static
org.apache.ignite.internal.testframework.IgniteTestUtils.testNodeName;
import static
org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.willCompleteSuccessfully;
import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.is;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -332,13 +333,19 @@ public class ItIgniteInMemoryNodeRestartTest extends
IgniteAbstractTest {
private static void createTableWithData(Ignite ignite, String name, int
replicas, int partitions) {
try (Session session = ignite.sql().createSession()) {
session.execute(null, "CREATE TABLE " + name
- + "(id INT PRIMARY KEY, name VARCHAR) WITH replicas=" +
replicas + ", partitions=" + partitions);
+ + " (id INT PRIMARY KEY, name VARCHAR)"
+ + " ENGINE aimem"
+ + " WITH replicas=" + replicas + ", partitions=" +
partitions);
for (int i = 0; i < 100; i++) {
session.execute(null, "INSERT INTO " + name + "(id, name)
VALUES (?, ?)",
i, VALUE_PRODUCER.apply(i));
}
}
+
+ var table = (TableImpl) ignite.tables().table(name);
+
+ assertThat(table.internalTable().storage().isVolatile(), is(true));
}
private static IgniteImpl ignite(int idx) {