zstan commented on a change in pull request #8709:
URL: https://github.com/apache/ignite/pull/8709#discussion_r565940634
##########
File path:
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java
##########
@@ -1046,6 +1047,36 @@ else if (o2 != null)
}
}
+ /**
+ * Test verifies that an AssertionError thrown from an execution node
+ * proprely handled by a task executor.
+ */
+ @Test
+ @SuppressWarnings("ThrowableNotThrown")
+ public void assertionHandlingTest() {
+ ExecutionContext<Object[]> ctx = executionContext(F.first(nodes()),
UUID.randomUUID(), 0);
+ IgniteTypeFactory tf = ctx.getTypeFactory();
+ RelDataType rowType = TypeUtils.createRowType(tf, int.class,
String.class);
+
+ CorruptedNode<Object[]> node = new CorruptedNode<>();
+
+ RootNode<Object[]> root = new RootNode<>(ctx, rowType);
+ root.register(node);
+
+ new Thread(() -> {
Review comment:
don`t understand the purpose of this nonjoining thread. If u want to
close the node - close it in finally
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
