diff --git a/src/server/pom.xml b/src/server/pom.xml index 820aab518..912187a0d 100644 --- a/src/server/pom.xml +++ b/src/server/pom.xml @@ -31,7 +31,7 @@ 2.1.12 2.35 - 1.2.9 + 1.3.14 3.4.5 1.12.0 0.12.0 @@ -244,7 +244,7 @@ org.apache.commons commons-configuration2 - 2.1 + 2.10.1 io.jsonwebtoken @@ -288,9 +288,9 @@ - junit - junit - 4.13.2 + org.junit.vintage + junit-vintage-engine + 5.9.3 test @@ -662,7 +662,7 @@ org.apache.maven.plugins maven-surefire-plugin - 2.22.2 + 3.2.5 true diff --git a/src/server/src/main/java/io/cassandrareaper/service/RepairRunner.java b/src/server/src/main/java/io/cassandrareaper/service/RepairRunner.java index 0edd17495..34eb67f67 100644 --- a/src/server/src/main/java/io/cassandrareaper/service/RepairRunner.java +++ b/src/server/src/main/java/io/cassandrareaper/service/RepairRunner.java @@ -67,6 +67,7 @@ import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.MoreExecutors; import org.apache.cassandra.repair.RepairParallelism; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.tuple.Pair; @@ -744,7 +745,8 @@ public void onSuccess(Object ignored) { public void onFailure(Throwable throwable) { LOG.error("Executing SegmentRunner failed", throwable); } - }); + }, + MoreExecutors.directExecutor()); } catch (ReaperException ex) { LOG.error("Executing SegmentRunner failed", ex); } diff --git a/src/server/src/main/java/io/cassandrareaper/storage/events/CassandraEventsDao.java b/src/server/src/main/java/io/cassandrareaper/storage/events/CassandraEventsDao.java index 237a5c2e6..48f2b82c3 100644 --- a/src/server/src/main/java/io/cassandrareaper/storage/events/CassandraEventsDao.java +++ b/src/server/src/main/java/io/cassandrareaper/storage/events/CassandraEventsDao.java @@ -56,7 +56,7 @@ static DiagEventSubscription createDiagEventSubscription(Row row) { return new DiagEventSubscription( Optional.of(row.getUUID("id")), row.getString("cluster"), - Optional.of(row.getString("description")), + Optional.ofNullable(row.getString("description")), row.getSet("nodes", String.class), row.getSet("events", String.class), row.getBool("export_sse"), diff --git a/src/server/src/test/java/io/cassandrareaper/acceptance/BasicSteps.java b/src/server/src/test/java/io/cassandrareaper/acceptance/BasicSteps.java index 18f9934cb..cb40d02a5 100644 --- a/src/server/src/test/java/io/cassandrareaper/acceptance/BasicSteps.java +++ b/src/server/src/test/java/io/cassandrareaper/acceptance/BasicSteps.java @@ -2424,7 +2424,7 @@ public void theReturnedListOfSubscriptionsIs(List> subscript new DiagEventSubscription( Optional.empty(), s.getCluster(), - Optional.of(s.getDescription()), + Optional.ofNullable(s.getDescription()), s.getNodes(), s.getEvents(), s.getExportSse(), diff --git a/src/server/src/test/resources/cassandra-reaper-access-control-enabled-at.yaml b/src/server/src/test/resources/cassandra-reaper-access-control-enabled-at.yaml index 52fd00412..3046e3d45 100644 --- a/src/server/src/test/resources/cassandra-reaper-access-control-enabled-at.yaml +++ b/src/server/src/test/resources/cassandra-reaper-access-control-enabled-at.yaml @@ -77,3 +77,5 @@ accessControl: cryptograph: type: symmetric systemPropertySecret: REAPER_ENCRYPTION_KEY + +persistenceStoragePath: /tmp/reaper/storage/ diff --git a/src/server/src/test/resources/cassandra-reaper-at.yaml b/src/server/src/test/resources/cassandra-reaper-at.yaml index fd1de77fa..87efde4b7 100644 --- a/src/server/src/test/resources/cassandra-reaper-at.yaml +++ b/src/server/src/test/resources/cassandra-reaper-at.yaml @@ -76,4 +76,6 @@ metrics: cryptograph: type: symmetric - systemPropertySecret: REAPER_ENCRYPTION_KEY \ No newline at end of file + systemPropertySecret: REAPER_ENCRYPTION_KEY + +persistenceStoragePath: /tmp/reaper/storage/ \ No newline at end of file diff --git a/src/server/src/test/resources/cassandra-reaper-metrics-test.yaml b/src/server/src/test/resources/cassandra-reaper-metrics-test.yaml index ec37225c7..e8ed291f1 100644 --- a/src/server/src/test/resources/cassandra-reaper-metrics-test.yaml +++ b/src/server/src/test/resources/cassandra-reaper-metrics-test.yaml @@ -78,3 +78,5 @@ metrics: cryptograph: type: symmetric systemPropertySecret: REAPER_ENCRYPTION_KEY + +persistenceStoragePath: /tmp/reaper/storage/ \ No newline at end of file diff --git a/src/server/src/test/resources/cassandra-reaper.yaml b/src/server/src/test/resources/cassandra-reaper.yaml index 2c3689a2d..2fab62d98 100644 --- a/src/server/src/test/resources/cassandra-reaper.yaml +++ b/src/server/src/test/resources/cassandra-reaper.yaml @@ -112,4 +112,6 @@ metrics: cryptograph: type: symmetric - systemPropertySecret: REAPER_ENCRYPTION_KEY \ No newline at end of file + systemPropertySecret: REAPER_ENCRYPTION_KEY + +persistenceStoragePath: /tmp/reaper/storage/ \ No newline at end of file