|
29 | 29 | import static org.junit.jupiter.api.Assertions.assertTrue; |
30 | 30 |
|
31 | 31 | import java.lang.reflect.Proxy; |
32 | | -import java.util.Arrays; |
33 | 32 | import java.util.concurrent.CompletableFuture; |
34 | 33 | import java.util.concurrent.atomic.AtomicInteger; |
35 | 34 | import java.util.stream.Collectors; |
36 | 35 | import org.apache.ignite.internal.catalog.Catalog; |
37 | 36 | import org.apache.ignite.internal.catalog.CatalogManager; |
38 | 37 | import org.apache.ignite.internal.catalog.CatalogService; |
39 | 38 | import org.apache.ignite.internal.catalog.CatalogValidationException; |
40 | | -import org.apache.ignite.internal.lang.IgniteStringFormatter; |
41 | 39 | import org.apache.ignite.internal.sql.engine.AsyncSqlCursor; |
42 | 40 | import org.apache.ignite.internal.sql.engine.InternalSqlRow; |
43 | 41 | import org.apache.ignite.internal.sql.engine.exec.fsm.QueryInfo; |
@@ -126,8 +124,8 @@ void schemaAndTableCreatedInTheSameBatch() { |
126 | 124 | void fewDdlAreBatched() { |
127 | 125 | AsyncSqlCursor<InternalSqlRow> cursor = gatewayNode.executeQuery( |
128 | 126 | "CREATE TABLE t1 (id INT PRIMARY KEY, val_1 INT, val_2 INT);" |
129 | | - + "CREATE INDEX t1_ind_1 ON t1 (val_1);" |
130 | | - + "CREATE INDEX t1_ind_2 ON t1 (val_2);" |
| 127 | + + "CREATE INDEX t1_ind_1 ON t1 (val_1);" |
| 128 | + + "CREATE INDEX t1_ind_2 ON t1 (val_2);" |
131 | 129 | ); |
132 | 130 |
|
133 | 131 | // CREATE TABLE t1 (id INT PRIMARY KEY, val_1 INT, val_2 INT) |
@@ -490,10 +488,12 @@ void preparationTimeErrorAsFirstItemOfBatch() { |
490 | 488 | } |
491 | 489 |
|
492 | 490 | /** |
493 | | - * This case makes sure that exception thrown is matched the order of execution, and not the order exceptions appear. |
| 491 | + * This case makes sure that exception thrown is matched the order of execution, and not the order |
| 492 | + * exceptions appear. |
494 | 493 | * |
495 | 494 | * <p>To be more specific, first seen exception relates to absent PK definition in 3rd statement, but |
496 | | - * during execution the exception that should be thrown is the one denoting that table with given name already exists (2nd statement). |
| 495 | + * during execution the exception that should be thrown is the one denoting that table with given name |
| 496 | + * already exists (2nd statement). |
497 | 497 | */ |
498 | 498 | @Test |
499 | 499 | void mixedErrorsInBatch() { |
@@ -603,11 +603,10 @@ private void assertIndexNotExists(String name) { |
603 | 603 | private CatalogManager catalogManagerDecorator(CatalogManager original) { |
604 | 604 | return (CatalogManager) Proxy.newProxyInstance( |
605 | 605 | QueryTimeoutTest.class.getClassLoader(), |
606 | | - new Class<?>[]{CatalogManager.class}, |
| 606 | + new Class<?>[] {CatalogManager.class}, |
607 | 607 | (proxy, method, args) -> { |
608 | 608 | if ("execute".equals(method.getName())) { |
609 | | - int i = executeCallCounter.incrementAndGet(); |
610 | | - System.out.println(IgniteStringFormatter.format("CALL: try={}, args={}", i, Arrays.toString(args))); |
| 609 | + executeCallCounter.incrementAndGet(); |
611 | 610 | } |
612 | 611 |
|
613 | 612 | return method.invoke(original, args); |
|
0 commit comments