This is an automated email from the ASF dual-hosted git repository.
sanpwc 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 82c03562f6 IGNITE-14578 Remove obsolete test (#2853)
82c03562f6 is described below
commit 82c03562f6756c1a2ea4d56358988fba40f3649f
Author: Alexander Lapin <[email protected]>
AuthorDate: Thu Nov 23 10:09:03 2023 +0200
IGNITE-14578 Remove obsolete test (#2853)
---
.../internal/runner/app/ItTableCreationTest.java | 289 ---------------------
1 file changed, 289 deletions(-)
diff --git
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItTableCreationTest.java
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItTableCreationTest.java
deleted file mode 100644
index 0f2e007aab..0000000000
---
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItTableCreationTest.java
+++ /dev/null
@@ -1,289 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.runner.app;
-
-import static java.util.stream.Collectors.toList;
-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.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNull;
-
-import java.nio.file.Path;
-import java.util.ArrayList;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.UUID;
-import java.util.concurrent.CompletableFuture;
-import org.apache.ignite.Ignite;
-import org.apache.ignite.IgnitionManager;
-import org.apache.ignite.InitParameters;
-import org.apache.ignite.internal.IgniteIntegrationTest;
-import org.apache.ignite.internal.testframework.TestIgnitionManager;
-import org.apache.ignite.internal.testframework.WorkDirectory;
-import org.apache.ignite.internal.util.IgniteUtils;
-import org.apache.ignite.table.KeyValueView;
-import org.apache.ignite.table.RecordView;
-import org.apache.ignite.table.Table;
-import org.apache.ignite.table.Tuple;
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.TestInfo;
-
-/**
- * Ignition interface tests.
- */
-@Disabled("https://issues.apache.org/jira/browse/IGNITE-14578";)
-class ItTableCreationTest extends IgniteIntegrationTest {
- /** Network ports of the test nodes. */
- private static final int[] PORTS = {3344, 3345, 3346};
-
- /** Nodes bootstrap configuration with preconfigured tables. */
- private final LinkedHashMap<String, String> nodesBootstrapCfg = new
LinkedHashMap<>();
-
- private final List<Ignite> clusterNodes = new ArrayList<>();
-
- @WorkDirectory
- private Path workDir;
-
- /**
- * Before each.
- */
- @BeforeEach
- void setUp(TestInfo testInfo) {
- String node0Name = testNodeName(testInfo, PORTS[0]);
- String node1Name = testNodeName(testInfo, PORTS[1]);
- String node2Name = testNodeName(testInfo, PORTS[2]);
-
- nodesBootstrapCfg.put(
- node0Name,
- "{\n"
- + " network: {\n"
- + " port: " + PORTS[0] + ",\n"
- + " nodeFinder: {\n"
- + " netClusterNodes: [ \"localhost:3344\",
\"localhost:3345\", \"localhost:3346\" ]\n"
- + " }\n"
- + " },\n"
- + " \"table\": {\n"
- + " \"tables\": {\n"
- + " \"tbl1\": {\n"
- + " \"partitions\":10,\n"
- + " \"replicas\":2,\n"
- + " \"columns\": { \n"
- + " \"key\": {\n"
- + " \"type\": {"
- + " \"type\":UUID\n"
- + " },\n"
- + " \"nullable\":false\n"
- + " },\n"
- + " \"affKey\": {\n"
- + " \"type\": {"
- + " \"type\":INT64\n"
- + " },\n"
- + " \"nullable\":false\n"
- + " },\n"
- + " \"valString\": {\n"
- + " \"type\": {"
- + " \"type\":String\n"
- + " },\n"
- + " \"nullable\":false\n"
- + " },\n"
- + " \"valInt\": {\n"
- + " \"type\": {"
- + " \"type\":INT32\n"
- + " },\n"
- + " \"nullable\":false\n"
- + " },\n"
- + " \"valNullable\": {\n"
- + " \"type\": {"
- + " \"type\":String\n"
- + " },\n"
- + " \"nullable\":true\n"
- + " }\n"
- + " },\n"
- + " \"indices\": {\n" /* Columns. */
- + " \"PK\": {\n"
- + " \"type\":PRIMARY,\n"
- + " \"columns\": {\n"
- + " \"key\": {\n"
- + " \"asc\":true\n"
- + " },\n"
- + " \"affKey\": {}\n"
- + " },\n" /* Columns. */
- + " \"affinityColumns\":[
\"affKey\" ]\n"
- + " }\n"
- + " }\n" /* Indices. */
- + " },\n" /* Table. */
- + "\n"
- + " \"tbl2\": {\n" // Table minimal
configuration.
- + " \"columns\": { \n"
- + " \"key\": {\n"
- + " \"type\": {"
- + " \"type\":INT64\n"
- + " },\n"
- + " },\n"
- + " \"val\": {\n"
- + " \"type\": {"
- + " \"type\":INT64\n"
- + " },\n"
- + " }\n"
- + " },\n" /* Columns. */
- + " \"indices\": {\n"
- + " \"PK\": {\n"
- + " \"type\":PRIMARY,\n"
- + " \"columns\": {\n"
- + " \"key\": {}\n"
- + " },\n" /* Columns. */
- + " }\n"
- + " }\n" /* Indices. */
- + " }\n" /* Table. */
- + " }\n" /* Tables. */
- + " }\n" /* Root. */
- + "}"
- );
-
- nodesBootstrapCfg.put(
- node1Name,
- "{\n"
- + " network: {\n"
- + " port: " + PORTS[1] + ",\n"
- + " nodeFinder: {\n"
- + " netClusterNodes: [ \"localhost:3344\",
\"localhost:3345\", \"localhost:3346\" ]\n"
- + " }\n"
- + " }\n"
- + "}"
- );
-
- nodesBootstrapCfg.put(
- node2Name,
- "{\n"
- + " network: {\n"
- + " port: " + PORTS[2] + ",\n"
- + " nodeFinder: {\n"
- + " netClusterNodes: [ \"localhost:3344\",
\"localhost:3345\", \"localhost:3346\" ]\n"
- + " }\n"
- + " }\n"
- + "}"
- );
-
- List<CompletableFuture<Ignite>> futures =
nodesBootstrapCfg.entrySet().stream()
- .map(e -> TestIgnitionManager.start(e.getKey(), e.getValue(),
workDir.resolve(e.getKey())))
- .collect(toList());
-
- String metaStorageNode = nodesBootstrapCfg.keySet().iterator().next();
-
- InitParameters initParameters = InitParameters.builder()
- .destinationNodeName(metaStorageNode)
- .metaStorageNodeNames(List.of(metaStorageNode))
- .clusterName("cluster")
- .build();
- TestIgnitionManager.init(initParameters);
-
- for (CompletableFuture<Ignite> future : futures) {
- assertThat(future, willCompleteSuccessfully());
-
- clusterNodes.add(future.join());
- }
- }
-
- /**
- * After each.
- */
- @AfterEach
- void tearDown() throws Exception {
- List<AutoCloseable> autoCloseables =
nodesBootstrapCfg.keySet().stream()
- .map(name -> (AutoCloseable) () -> IgnitionManager.stop(name))
- .collect(toList());
-
- IgniteUtils.closeAll(autoCloseables);
- }
-
- /**
- * Check table creation via bootstrap configuration with pre-configured
table.
- */
- @Test
- void testInitialSimpleTableConfiguration() {
- assertEquals(3, clusterNodes.size());
-
- clusterNodes.forEach(Assertions::assertNotNull);
-
- /* Table 1. */
-
- Table tbl01 = clusterNodes.get(1).tables().table("tbl1");
- RecordView<Tuple> recView01 = tbl01.recordView();
- KeyValueView<Tuple, Tuple> kvView01 = tbl01.keyValueView();
-
- recView01.insert(null, Tuple.create().set("key", 1L).set("val", 111));
- kvView01.put(null, Tuple.create().set("key", 2L),
Tuple.create().set("val", 222));
-
- Table tbl02 = clusterNodes.get(2).tables().table("tbl1");
- RecordView<Tuple> recView02 = tbl02.recordView();
- KeyValueView<Tuple, Tuple> kvView02 = tbl02.keyValueView();
-
- final Tuple keyTuple01 = Tuple.create().set("key", 1L);
- final Tuple keyTuple02 = Tuple.create().set("key", 2L);
-
- assertEquals(111, (Integer) recView02.get(null,
keyTuple01).value("val"));
- assertEquals(111, (Integer) kvView02.get(null,
keyTuple01).value("val"));
- assertEquals(222, (Integer) recView02.get(null,
keyTuple02).value("val"));
- assertEquals(222, (Integer) kvView02.get(null,
keyTuple02).value("val"));
-
- /* Table 2. */
-
- final UUID uuid = UUID.randomUUID();
- final UUID uuid2 = UUID.randomUUID();
-
- // Put data on node 1.
- Table tbl11 = clusterNodes.get(1).tables().table("tbl1");
- RecordView<Tuple> recView11 = tbl11.recordView();
- KeyValueView<Tuple, Tuple> kvView11 = tbl11.keyValueView();
-
- recView11.insert(null, Tuple.create().set("key", uuid).set("affKey",
42L)
- .set("valStr", "String value").set("valInt",
73).set("valNullable", null));
-
- kvView11.put(
- null,
- Tuple.create().set("key", uuid2).set("affKey", 4242L),
- Tuple.create().set("valStr", "String value 2").set("valInt",
7373).set("valNullable", null)
- );
-
- // Get data on node 2.
- Table tbl12 = clusterNodes.get(2).tables().table("tbl1");
- RecordView<Tuple> recView12 = tbl12.recordView();
- KeyValueView<Tuple, Tuple> kvView12 = tbl12.keyValueView();
-
- final Tuple keyTuple11 = Tuple.create().set("key", uuid).set("affKey",
42L);
- final Tuple keyTuple12 = Tuple.create().set("key",
uuid2).set("affKey", 4242L);
-
- assertEquals("String value", recView12.get(null,
keyTuple11).value("valStr"));
- assertEquals("String value", kvView12.get(null,
keyTuple11).value("valStr"));
- assertEquals("String value 2", recView12.get(null,
keyTuple12).value("valStr"));
- assertEquals("String value 2", kvView12.get(null,
keyTuple12).value("valStr"));
- assertEquals(73, (Integer) recView12.get(null,
keyTuple11).value("valInt"));
- assertEquals(73, (Integer) kvView12.get(null,
keyTuple11).value("valInt"));
- assertEquals(7373, (Integer) recView12.get(null,
keyTuple12).value("valInt"));
- assertEquals(7373, (Integer) kvView12.get(null,
keyTuple12).value("valInt"));
- assertNull(recView12.get(null, keyTuple11).value("valNullable"));
- assertNull(kvView12.get(null, keyTuple11).value("valNullable"));
- assertNull(recView12.get(null, keyTuple12).value("valNullable"));
- assertNull(kvView12.get(null, keyTuple12).value("valNullable"));
- }
-}
