Repository: atlas Updated Branches: refs/heads/master d88223bc1 -> b1907a332
ATLAS-2470 - JanusGraph Cassandra. Unit test setup update #2. Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/b1907a33 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/b1907a33 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/b1907a33 Branch: refs/heads/master Commit: b1907a332e3cd0eeab0520e1d93cf8605eae4f8c Parents: d88223b Author: Ashutosh Mestry <[email protected]> Authored: Thu Apr 12 15:39:43 2018 -0700 Committer: Ashutosh Mestry <[email protected]> Committed: Thu Apr 12 15:40:04 2018 -0700 ---------------------------------------------------------------------- .../audit/CassandraAuditRepositoryTest.java | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/b1907a33/repository/src/test/java/org/apache/atlas/repository/audit/CassandraAuditRepositoryTest.java ---------------------------------------------------------------------- diff --git a/repository/src/test/java/org/apache/atlas/repository/audit/CassandraAuditRepositoryTest.java b/repository/src/test/java/org/apache/atlas/repository/audit/CassandraAuditRepositoryTest.java index 4135687..26d3a60 100644 --- a/repository/src/test/java/org/apache/atlas/repository/audit/CassandraAuditRepositoryTest.java +++ b/repository/src/test/java/org/apache/atlas/repository/audit/CassandraAuditRepositoryTest.java @@ -40,15 +40,19 @@ public class CassandraAuditRepositoryTest extends AuditRepositoryTestBase { private final int CLUSTER_PORT = 9042; @BeforeClass - public void setup() throws InterruptedException, TTransportException, ConfigurationException, IOException, - AtlasException { - EmbeddedCassandraServerHelper.startEmbeddedCassandra("cassandra_test.yml"); - eventRepository = new CassandraBasedAuditRepository(); - Configuration atlasConf = new MapConfiguration(getClusterProperties()); - ((CassandraBasedAuditRepository) eventRepository).setApplicationProperties(atlasConf); - ((CassandraBasedAuditRepository) eventRepository).start(); + public void setup() { + try { + EmbeddedCassandraServerHelper.startEmbeddedCassandra("cassandra_test.yml"); + eventRepository = new CassandraBasedAuditRepository(); + Configuration atlasConf = new MapConfiguration(getClusterProperties()); + ((CassandraBasedAuditRepository) eventRepository).setApplicationProperties(atlasConf); + ((CassandraBasedAuditRepository) eventRepository).start(); - ensureClusterCreation(); + ensureClusterCreation(); + } + catch (Exception ex) { + throw new SkipException("setup: failed!", ex); + } } private Map<String, Object> getClusterProperties() {
