This is an automated email from the ASF dual-hosted git repository.
vldpyatkov 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 20cbd42fe2e IGNITE-28647 testNextPageRequestFailure and
testDistributedJoin are flaky (#13106)
20cbd42fe2e is described below
commit 20cbd42fe2e198b68632f0992c1d763d2d75a876
Author: Vladislav Pyatkov <[email protected]>
AuthorDate: Wed May 6 20:52:08 2026 +0300
IGNITE-28647 testNextPageRequestFailure and testDistributedJoin are flaky
(#13106)
---
docs/_docs/monitoring-metrics/system-views.adoc | 2 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 2 +-
.../RebalanceAfterResettingLostPartitionTest.java | 2 +-
...ientReconnectAtomicsWithLostPartitionsTest.java | 8 +-
.../monitoring/opencensus/AbstractTracingTest.java | 69 +++++++++---
.../opencensus/OpenCensusSqlJdbcTracingTest.java | 4 +-
.../opencensus/OpenCensusSqlNativeTracingTest.java | 50 +++------
.../opencensus/OpenCensusTxTracingTest.java | 120 +++++++++------------
.../Configuration/DataRegionConfiguration.cs | 2 +-
modules/platforms/dotnet/Apache.Ignite.ndproj | 4 +-
10 files changed, 133 insertions(+), 130 deletions(-)
diff --git a/docs/_docs/monitoring-metrics/system-views.adoc
b/docs/_docs/monitoring-metrics/system-views.adoc
index fca31033d13..b1f5d4d2082 100644
--- a/docs/_docs/monitoring-metrics/system-views.adoc
+++ b/docs/_docs/monitoring-metrics/system-views.adoc
@@ -179,7 +179,7 @@ The CACHE_GROUPS view contains information about the
link:configuring-caches/cac
|CACHE_MODE | VARCHAR | The cache mode.
|DATA_REGION_NAME | VARCHAR | The name of the
link:memory-configuration/data-regions[data region].
|IS_SHARED|BOOLEAN | If this group contains more than one cache.
-|NODE_FILTER | VARCHAR | String representation of the the node filter defined
for the cache group.
+|NODE_FILTER | VARCHAR | String representation of the node filter defined for
the cache group.
|PARTITION_LOSS_POLICY | VARCHAR |
link:configuring-caches/partition-loss-policy[Partition loss policy].
|PARTITIONS_COUNT|INT | The number of partitions.
|REBALANCE_DELAY|LONG | link:data-rebalancing#other-properties[Rebalancing
delay].
diff --git
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 903524c8aa9..9e1b3c60cdc 100644
---
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -604,7 +604,7 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter
implements IgniteDiscovery
* Sets network addresses for the Discovery SPI.
* <p>
* If not provided, the value is resolved from {@link
IgniteConfiguration#getLocalHost()}. If the latter is not set
- * as well, the the node binds to all available IP addresses of an
environment it's running on.
+ * as well, the node binds to all available IP addresses of an environment
it's running on.
* If there is no a non-loopback address, then {@link
InetAddress#getLocalHost()} is used.
* <p>
* <b>NOTE:</b> You should initialize the {@link
IgniteConfiguration#getLocalHost()} or
diff --git
a/modules/core/src/test/java/org/apache/ignite/cache/RebalanceAfterResettingLostPartitionTest.java
b/modules/core/src/test/java/org/apache/ignite/cache/RebalanceAfterResettingLostPartitionTest.java
index e4f223743e6..eea3856d11b 100644
---
a/modules/core/src/test/java/org/apache/ignite/cache/RebalanceAfterResettingLostPartitionTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/cache/RebalanceAfterResettingLostPartitionTest.java
@@ -112,7 +112,7 @@ public class RebalanceAfterResettingLostPartitionTest
extends GridCommonAbstract
String g1Name = grid(1).name();
- // Stopping the the second node.
+ // Stopping the second node.
stopGrid(1);
// Cleaning the persistence for second node.
diff --git
a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAtomicsWithLostPartitionsTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAtomicsWithLostPartitionsTest.java
index 9f67d8403b6..adfb1c9ef25 100644
---
a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAtomicsWithLostPartitionsTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAtomicsWithLostPartitionsTest.java
@@ -267,7 +267,7 @@ public class
IgniteClientReconnectAtomicsWithLostPartitionsTest extends IgniteCl
}
/**
- * Tests atomic long operation provided by the the given {@code clo}.
+ * Tests atomic long operation provided by the given {@code clo}.
*
* @param atomicName Name of atomic long.
* @param op Closure that represents an operation.
@@ -301,7 +301,7 @@ public class
IgniteClientReconnectAtomicsWithLostPartitionsTest extends IgniteCl
}
/**
- * Tests atomic reference operation provided by the the given {@code clo}.
+ * Tests atomic reference operation provided by the given {@code clo}.
*
* @param atomicName Name of atomic.
* @param op Closure that represents an operation.
@@ -335,7 +335,7 @@ public class
IgniteClientReconnectAtomicsWithLostPartitionsTest extends IgniteCl
}
/**
- * Tests atomic stamped operation provided by the the given {@code clo}.
+ * Tests atomic stamped operation provided by the given {@code clo}.
*
* @param atomicName Name of atomic.
* @param op Closure that represents an operation.
@@ -379,7 +379,7 @@ public class
IgniteClientReconnectAtomicsWithLostPartitionsTest extends IgniteCl
}
/**
- * Tests atomic sequence operation provided by the the given {@code clo}.
+ * Tests atomic sequence operation provided by the given {@code clo}.
*
* @param atomicName Name of atomic sequnce.
* @param op Closure that represents an operation.
diff --git
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/AbstractTracingTest.java
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/AbstractTracingTest.java
index dc2830bf266..ba03562dce3 100644
---
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/AbstractTracingTest.java
+++
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/AbstractTracingTest.java
@@ -210,7 +210,7 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
* @param expAttrs Attributes to check.
* @return List of founded span ids.
*/
- java.util.List<SpanId> checkSpan(
+ List<SpanId> checkSpan(
SpanType spanType,
SpanId parentSpanId,
int expSpansCnt,
@@ -228,23 +228,18 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
* @param expAttrs Attributes to check.
* @return List of founded span ids.
*/
- java.util.List<SpanId> checkSpan(
+ List<SpanId> checkSpan(
SpanType spanType,
SpanId parentSpanId,
int expSpansCnt,
/* tagName: tagValue*/ Map<String, String> expAttrs,
CheckAttributes attrCheckType
) {
- java.util.List<SpanData> gotSpans = hnd.allSpans()
- .filter(
- span -> parentSpanId != null ?
- parentSpanId.equals(span.getParentSpanId()) &&
spanType.spanName().equals(span.getName()) :
- spanType.spanName().equals(span.getName()))
- .collect(Collectors.toList());
+ List<SpanData> gotSpans = findChildSpans(spanType, parentSpanId);
assertEquals(expSpansCnt, gotSpans.size());
- java.util.List<SpanId> spanIds = new ArrayList<>();
+ List<SpanId> spanIds = new ArrayList<>();
gotSpans.forEach(spanData -> {
spanIds.add(spanData.getContext().getSpanId());
@@ -255,6 +250,54 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
return spanIds;
}
+ /**
+ * Waits until parent span has expected child spans with specified type.
+ *
+ * @param type Span type.
+ * @param parentSpan Parent span id.
+ * @param expSpansCnt Expected spans count.
+ * @return Ids of the child spans.
+ * @throws IgniteInterruptedCheckedException If interrupted.
+ */
+ List<SpanId> waitForSpan(
+ SpanType type,
+ SpanId parentSpan,
+ int expSpansCnt
+ ) throws IgniteInterruptedCheckedException {
+ assertTrue("Span was not exported [type=" + type + ", parent=" +
parentSpan + ", expCnt=" + expSpansCnt + ']',
+ waitForCondition(() -> findChildSpans(type, parentSpan).size() ==
expSpansCnt, getTestTimeout()));
+
+ return findChildSpanIds(type, parentSpan);
+ }
+
+ /**
+ * Finds child spans with specified type and parent span.
+ *
+ * @param type Span type.
+ * @param parentSpan Parent span id.
+ * @return Ids of the found spans.
+ */
+ List<SpanId> findChildSpanIds(SpanType type, SpanId parentSpan) {
+ return findChildSpans(type, parentSpan).stream()
+ .map(span -> span.getContext().getSpanId())
+ .collect(Collectors.toList());
+ }
+
+ /**
+ * Finds child spans with specified type and parent span.
+ *
+ * @param type Span type.
+ * @param parentSpan Parent span id.
+ * @return List of spans data.
+ */
+ List<SpanData> findChildSpans(SpanType type, SpanId parentSpan) {
+ return hnd.allSpans()
+ .filter(span -> parentSpan != null ?
+ parentSpan.equals(span.getParentSpanId()) &&
type.spanName().equals(span.getName()) :
+ type.spanName().equals(span.getName()))
+ .collect(Collectors.toList());
+ }
+
/**
* Checks that there's at least one span with given spanType and
attributes.
*
@@ -266,7 +309,7 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
SpanType spanType,
/* tagName: tagValue*/ Map<String, String> expAttrs
) {
- java.util.List<SpanData> gotSpans = hnd.allSpans()
+ List<SpanData> gotSpans = hnd.allSpans()
.filter(span ->
spanType.spanName().equals(span.getName())).collect(Collectors.toList());
for (SpanData specificTypeSpans : gotSpans) {
@@ -344,7 +387,7 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
private final Map<SpanId, SpanData> collectedSpans = new
ConcurrentHashMap<>();
/** */
- private final Map<SpanId, java.util.List<SpanData>>
collectedSpansByParents = new ConcurrentHashMap<>();
+ private final Map<SpanId, List<SpanData>> collectedSpansByParents =
new ConcurrentHashMap<>();
/** {@inheritDoc} */
@Override public void export(Collection<SpanData> spanDataList) {
@@ -386,7 +429,7 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
* @param parentId Parent id.
* @return All spans by parent id.
*/
- java.util.List<SpanData> spanByParentId(SpanId parentId) {
+ List<SpanData> spanByParentId(SpanId parentId) {
return collectedSpansByParents.get(parentId);
}
@@ -394,7 +437,7 @@ public abstract class AbstractTracingTest extends
GridCommonAbstractTest {
* @param parentSpan Top span.
* @return All span which are child of parentSpan in any generation.
*/
- java.util.List<SpanData> unrollByParent(SpanData parentSpan) {
+ List<SpanData> unrollByParent(SpanData parentSpan) {
ArrayList<SpanData> spanChain = new ArrayList<>();
LinkedList<SpanData> queue = new LinkedList<>();
diff --git
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlJdbcTracingTest.java
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlJdbcTracingTest.java
index e0fe030218d..4f59bb8ea9f 100644
---
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlJdbcTracingTest.java
+++
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlJdbcTracingTest.java
@@ -90,14 +90,14 @@ public class OpenCensusSqlJdbcTracingTest extends
OpenCensusSqlNativeTracingTest
checkChildSpan(SQL_QRY_EXECUTE, iterSpan);
- int fetchedRows = findChildSpans(SQL_PAGE_FETCH, rootSpan).stream()
+ int fetchedRows = findChildSpanIds(SQL_PAGE_FETCH, rootSpan).stream()
.mapToInt(span -> Integer.parseInt(getAttribute(span,
SQL_PAGE_ROWS)))
.sum();
assertEquals(TEST_TABLE_POPULATION, fetchedRows);
checkChildSpan(SQL_ITER_CLOSE, rootSpan);
- assertFalse(findChildSpans(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
+ assertFalse(findChildSpanIds(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
}
/**
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 9122f5dad7e..03527a6ac7a 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
@@ -174,11 +174,11 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
checkChildSpan(SQL_QRY_EXECUTE, iterSpan);
- fetchedRows += findChildSpans(SQL_PAGE_FETCH, execReqSpan).stream()
+ fetchedRows += findChildSpanIds(SQL_PAGE_FETCH,
execReqSpan).stream()
.mapToInt(span -> parseInt(getAttribute(span, SQL_PAGE_ROWS)))
.sum();
- List<SpanId> cacheUpdateSpans = findChildSpans(SQL_CACHE_UPDATE,
execReqSpan);
+ List<SpanId> cacheUpdateSpans = findChildSpanIds(SQL_CACHE_UPDATE,
execReqSpan);
cacheUpdates += cacheUpdateSpans.stream()
.mapToInt(span -> parseInt(getAttribute(span,
SQL_CACHE_UPDATES)))
@@ -338,7 +338,7 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
preparedRows += parseInt(getAttribute(pagePrepareSpan,
SQL_PAGE_ROWS));
- List<SpanId> distLookupReqSpans =
findChildSpans(SQL_IDX_RANGE_REQ, pagePrepareSpan);
+ List<SpanId> distLookupReqSpans =
findChildSpanIds(SQL_IDX_RANGE_REQ, pagePrepareSpan);
for (SpanId span : distLookupReqSpans) {
String rowsAttr = getAttribute(span, SQL_IDX_RANGE_ROWS);
@@ -365,14 +365,14 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
checkChildSpan(SQL_PAGE_RESP, nexPageSpan);
- List<SpanId> pageFetchSpans = findChildSpans(SQL_PAGE_FETCH, rootSpan);
+ List<SpanId> pageFetchSpans = findChildSpanIds(SQL_PAGE_FETCH,
rootSpan);
for (SpanId span : pageFetchSpans) {
fetchedRows += parseInt(getAttribute(span, SQL_PAGE_ROWS));
checkChildSpan(SQL_PAGE_WAIT, span);
- List<SpanId> nextPageSpans = findChildSpans(SQL_NEXT_PAGE_REQ,
span);
+ List<SpanId> nextPageSpans = findChildSpanIds(SQL_NEXT_PAGE_REQ,
span);
if (!nextPageSpans.isEmpty()) {
assertEquals(1, nextPageSpans.size());
@@ -389,9 +389,9 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
assertEquals(TEST_TABLE_POPULATION, preparedRows);
assertEquals(TEST_TABLE_POPULATION, idxRangeReqRows);
- checkSpan(SQL_QRY_CANCEL_REQ, rootSpan, mapNodesCount(), null);
+ waitForSpan(SQL_QRY_CANCEL_REQ, rootSpan, mapNodesCount());
- assertFalse(findChildSpans(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
+ assertFalse(findChildSpanIds(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
}
/**
@@ -410,7 +410,7 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
SpanId iterOpenSpan = checkChildSpan(SQL_ITER_OPEN, rootSpan);
- List<SpanId> qryExecSpans = findChildSpans(SQL_QRY_EXEC_REQ,
iterOpenSpan);
+ List<SpanId> qryExecSpans = findChildSpanIds(SQL_QRY_EXEC_REQ,
iterOpenSpan);
assertEquals(GRID_CNT * qryParallelism, qryExecSpans.size());
}
@@ -451,17 +451,17 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
SpanId iterCloseSpan = checkChildSpan(SQL_ITER_CLOSE, cursorCloseSpan);
- checkSpan(SQL_QRY_CANCEL_REQ, iterCloseSpan, mapNodesCount(), null);
+ waitForSpan(SQL_QRY_CANCEL_REQ, iterCloseSpan, mapNodesCount());
- List<SpanId> pageFetchSpans = findChildSpans(SQL_PAGE_FETCH, rootSpan);
+ List<SpanId> pageFetchSpans = findChildSpanIds(SQL_PAGE_FETCH,
rootSpan);
for (SpanId pageFetchSpan : pageFetchSpans) {
- List<SpanId> nextPageReqSpans = findChildSpans(SQL_NEXT_PAGE_REQ,
pageFetchSpan);
+ List<SpanId> nextPageReqSpans =
findChildSpanIds(SQL_NEXT_PAGE_REQ, pageFetchSpan);
if (!nextPageReqSpans.isEmpty()) {
assertEquals(1, nextPageReqSpans.size());
- checkChildSpan(SQL_FAIL_RESP, nextPageReqSpans.get(0));
+ waitForSpan(SQL_FAIL_RESP, nextPageReqSpans.get(0), 1);
}
}
}
@@ -564,14 +564,14 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
fetchedRows += parseInt(getAttribute(fetchSpan, SQL_PAGE_ROWS));
- List<SpanId> pageFetchSpans = findChildSpans(SQL_PAGE_FETCH, rootSpan);
+ List<SpanId> pageFetchSpans = findChildSpanIds(SQL_PAGE_FETCH,
rootSpan);
for (SpanId span : pageFetchSpans)
fetchedRows += parseInt(getAttribute(span, SQL_PAGE_ROWS));
assertEquals(expRows, fetchedRows);
- assertFalse(findChildSpans(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
+ assertFalse(findChildSpanIds(SQL_CURSOR_CLOSE, rootSpan).isEmpty());
}
/**
@@ -590,14 +590,14 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
if (fetchRequired) {
checkChildSpan(SQL_ITER_OPEN, dmlExecSpan);
- int fetchedRows = findChildSpans(SQL_PAGE_FETCH, null).stream()
+ int fetchedRows = findChildSpanIds(SQL_PAGE_FETCH, null).stream()
.mapToInt(span -> parseInt(getAttribute(span, SQL_PAGE_ROWS)))
.sum();
assertEquals(expCacheUpdates, fetchedRows);
}
- int cacheUpdates = findChildSpans(SQL_CACHE_UPDATE,
dmlExecSpan).stream()
+ int cacheUpdates = findChildSpanIds(SQL_CACHE_UPDATE,
dmlExecSpan).stream()
.mapToInt(span -> parseInt(getAttribute(span, SQL_CACHE_UPDATES)))
.sum();
@@ -609,28 +609,12 @@ public class OpenCensusSqlNativeTracingTest extends
AbstractTracingTest {
*
* @param type Span type.
* @param parentSpan Parent span id.
- * @return Id of the the child span.
+ * @return Id of the child span.
*/
protected SpanId checkChildSpan(SpanType type, SpanId parentSpan) {
return checkSpan(type, parentSpan, 1, null).get(0);
}
- /**
- * Finds child spans with specified type and parent span.
- *
- * @param type Span type.
- * @param parentSpanId Parent span id.
- * @return Ids of the found spans.
- */
- protected List<SpanId> findChildSpans(SpanType type, SpanId parentSpanId) {
- return handler().allSpans()
- .filter(span -> parentSpanId != null ?
- parentSpanId.equals(span.getParentSpanId()) &&
type.spanName().equals(span.getName()) :
- type.spanName().equals(span.getName()))
- .map(span -> span.getContext().getSpanId())
- .collect(Collectors.toList());
- }
-
/**
* Finds root spans with specified type.
*
diff --git
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingTest.java
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingTest.java
index 7f3ade6c978..891ae13732f 100644
---
a/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingTest.java
+++
b/modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingTest.java
@@ -202,29 +202,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
@@ -349,29 +345,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
@@ -503,29 +495,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
@@ -650,29 +638,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
@@ -804,29 +788,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
@@ -951,29 +931,25 @@ public class OpenCensusTxTracingTest extends
AbstractTracingTest {
1,
null);
- List<SpanId> txNearFinishReqSpanIds = checkSpan(
+ List<SpanId> txNearFinishReqSpanIds = waitForSpan(
TX_NEAR_FINISH_REQ,
txNearFinishSpanIds.get(0),
- 1,
- null);
+ 1);
- List<SpanId> txDhtFinishSpanIds = checkSpan(
+ List<SpanId> txDhtFinishSpanIds = waitForSpan(
TX_DHT_FINISH,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
- checkSpan(
+ waitForSpan(
TX_PROCESS_DHT_FINISH_REQ,
txDhtFinishSpanIds.get(0),
- 2,
- null);
+ 2);
- checkSpan(
+ waitForSpan(
TX_NEAR_FINISH_RESP,
txNearFinishReqSpanIds.get(0),
- 1,
- null);
+ 1);
}
/**
diff --git
a/modules/platforms/dotnet/Apache.Ignite.Core/Configuration/DataRegionConfiguration.cs
b/modules/platforms/dotnet/Apache.Ignite.Core/Configuration/DataRegionConfiguration.cs
index c50e8a113d1..15a027a13f4 100644
---
a/modules/platforms/dotnet/Apache.Ignite.Core/Configuration/DataRegionConfiguration.cs
+++
b/modules/platforms/dotnet/Apache.Ignite.Core/Configuration/DataRegionConfiguration.cs
@@ -163,7 +163,7 @@ namespace Apache.Ignite.Core.Configuration
public long MaxSize { get; set; }
/// <summary>
- /// Gets or sets the the path to the directory for memory-mapped files.
+ /// Gets or sets the path to the directory for memory-mapped files.
/// <para />
/// Null for no swap.
/// </summary>
diff --git a/modules/platforms/dotnet/Apache.Ignite.ndproj
b/modules/platforms/dotnet/Apache.Ignite.ndproj
index f30d8ad9619..2c32783f83e 100644
--- a/modules/platforms/dotnet/Apache.Ignite.ndproj
+++ b/modules/platforms/dotnet/Apache.Ignite.ndproj
@@ -268,7 +268,7 @@ select 100d * debt.ToManDay() / timeToDev.ToManDay()
//
// • the estimated total effort to develop the code base
//
-// • and the the estimated total time to fix all issues (the Debt)
+// • and the estimated total time to fix all issues (the Debt)
//
// Estimated total effort to develop the code base is inferred from
// # lines of code of the code base and from the
@@ -9681,7 +9681,7 @@ select 100d * debt.ToManDay() / timeToDev.ToManDay()
//
// • the estimated total time to develop the code base
//
-// • and the the estimated total time to fix all issues (the Debt).
+// • and the estimated total time to fix all issues (the Debt).
//
// Estimated total time to develop the code base is inferred from
// # lines of code of the code base and from the
