You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by sa...@apache.org on 2017/11/07 19:57:49 UTC
atlas git commit: ATLAS-2240: remove duplicate test
testConcurrentCalls()
Repository: atlas
Updated Branches:
refs/heads/master af51fbcf2 -> 549310e3f
ATLAS-2240: remove duplicate test testConcurrentCalls()
Project: http://git-wip-us.apache.org/repos/asf/atlas/repo
Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/549310e3
Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/549310e3
Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/549310e3
Branch: refs/heads/master
Commit: 549310e3fbb73fdd969fe771821ef857246cc385
Parents: af51fbc
Author: Sarath Subramanian <ss...@hortonworks.com>
Authored: Tue Nov 7 11:57:35 2017 -0800
Committer: Sarath Subramanian <ss...@hortonworks.com>
Committed: Tue Nov 7 11:57:35 2017 -0800
----------------------------------------------------------------------
.../GraphBackedMetadataRepositoryTest.java | 51 --------------------
1 file changed, 51 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/atlas/blob/549310e3/repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java
----------------------------------------------------------------------
diff --git a/repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java b/repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java
index da6fa75..952a644 100755
--- a/repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java
+++ b/repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java
@@ -130,57 +130,6 @@ public class GraphBackedMetadataRepositoryTest {
}
@Test
- //In some cases of parallel APIs, the edge is added, but get edge by label doesn't return the edge. ATLAS-1104
- public void testConcurrentCalls() throws Exception {
- final HierarchicalTypeDefinition<ClassType> refType =
- createClassTypeDef(randomString(), ImmutableSet.<String>of());
- HierarchicalTypeDefinition<ClassType> type =
- createClassTypeDef(randomString(), ImmutableSet.<String>of(),
- new AttributeDefinition("ref", refType.typeName, Multiplicity.OPTIONAL, true, null));
- typeSystem.defineClassType(refType);
- typeSystem.defineClassType(type);
-
- String refId1 = createEntity(new Referenceable(refType.typeName)).get(0);
- String refId2 = createEntity(new Referenceable(refType.typeName)).get(0);
-
- final Referenceable instance1 = new Referenceable(type.typeName);
- instance1.set("ref", new Referenceable(refId1, refType.typeName, null));
-
- final Referenceable instance2 = new Referenceable(type.typeName);
- instance2.set("ref", new Referenceable(refId2, refType.typeName, null));
-
- ExecutorService executor = Executors.newFixedThreadPool(3);
- List<Future<Object>> futures = new ArrayList<>();
- futures.add(executor.submit(new Callable<Object>() {
- @Override
- public Object call() throws Exception {
- return createEntity(instance1).get(0);
- }
- }));
- futures.add(executor.submit(new Callable<Object>() {
- @Override
- public Object call() throws Exception {
- return createEntity(instance2).get(0);
- }
- }));
- futures.add(executor.submit(new Callable<Object>() {
- @Override
- public Object call() throws Exception {
- return discoveryService.searchByDSL(TestUtils.TABLE_TYPE, new QueryParams(10, 0));
- }
- }));
-
- String id1 = (String) futures.get(0).get();
- String id2 = (String) futures.get(1).get();
- futures.get(2).get();
- executor.shutdown();
-
- boolean validated1 = assertEdge(id1, type.typeName);
- boolean validated2 = assertEdge(id2, type.typeName);
- assertTrue(validated1 | validated2);
- }
-
- @Test
public void testSubmitEntity() throws Exception {
ITypedReferenceableInstance hrDept = TestUtils.createDeptEg1(typeSystem);