You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by mp...@apache.org on 2023/02/16 16:54:13 UTC
[ignite] branch master updated: IGNITE-18825 Fixed OpenCensusSqlNativeTracingTest#testDistributedJoin test. (#10546)
This is an automated email from the ASF dual-hosted git repository.
mpetrov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 4284a50b39a IGNITE-18825 Fixed OpenCensusSqlNativeTracingTest#testDistributedJoin test. (#10546)
4284a50b39a is described below
commit 4284a50b39a950dc334af5aaa7e1da3c48a452bf
Author: Mikhail Petrov <32...@users.noreply.github.com>
AuthorDate: Thu Feb 16 19:54:05 2023 +0300
IGNITE-18825 Fixed OpenCensusSqlNativeTracingTest#testDistributedJoin test. (#10546)
---
.../opencensus/OpenCensusSqlNativeTracingTest.java | 17 ++++++++++-------
1 file changed, 10 insertions(+), 7 deletions(-)
diff --git a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlNativeTracingTest.java b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlNativeTracingTest.java
index 56341665dc8..9122f5dad7e 100644
--- a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlNativeTracingTest.java
+++ b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlNativeTracingTest.java
@@ -334,18 +334,22 @@ public class OpenCensusSqlNativeTracingTest extends AbstractTracingTest {
assertEquals(expParts, parts);
});
- SpanId execSpan = checkChildSpan(SQL_QRY_EXECUTE, execReqSpan);
+ SpanId pagePrepareSpan = checkChildSpan(SQL_PAGE_PREPARE, execReqSpan);
- List<SpanId> distrLookupReqSpans = findChildSpans(SQL_IDX_RANGE_REQ, execSpan);
+ preparedRows += parseInt(getAttribute(pagePrepareSpan, SQL_PAGE_ROWS));
- for (SpanId span : distrLookupReqSpans) {
- idxRangeReqRows += parseInt(getAttribute(span, SQL_IDX_RANGE_ROWS));
+ List<SpanId> distLookupReqSpans = findChildSpans(SQL_IDX_RANGE_REQ, pagePrepareSpan);
+
+ for (SpanId span : distLookupReqSpans) {
+ String rowsAttr = getAttribute(span, SQL_IDX_RANGE_ROWS);
+
+ if (rowsAttr != null)
+ idxRangeReqRows += parseInt(rowsAttr);
checkChildSpan(SQL_IDX_RANGE_RESP, span);
}
- preparedRows += parseInt(getAttribute(checkChildSpan(SQL_PAGE_PREPARE, execReqSpan), SQL_PAGE_ROWS));
-
+ checkChildSpan(SQL_QRY_EXECUTE, execReqSpan);
checkChildSpan(SQL_PAGE_RESP, execReqSpan);
}
@@ -417,7 +421,6 @@ public class OpenCensusSqlNativeTracingTest extends AbstractTracingTest {
* @throws Exception If failed.
*/
@Test
- @SuppressWarnings("Convert2MethodRef")
public void testNextPageRequestFailure() throws Exception {
String prsnTable = createTableAndPopulate(Person.class, PARTITIONED, 1);