This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo-testing.git
The following commit(s) were added to refs/heads/main by this push:
new 293979f changes to support building with java 21 (#305)
293979f is described below
commit 293979f961781070276f8dc5e7d3e853ccc1d04a
Author: Keith Turner <[email protected]>
AuthorDate: Thu Mar 12 15:45:11 2026 -0400
changes to support building with java 21 (#305)
---
.../timely-grafana/Dockerfile | 1 +
.../org/apache/accumulo/testing/continuous/ManySplits.java | 2 +-
.../accumulo/testing/randomwalk/sequential/BatchVerify.java | 2 +-
.../java/org/apache/accumulo/testing/stress/DataWriter.java | 11 -----------
4 files changed, 3 insertions(+), 13 deletions(-)
diff --git a/contrib/terraform-testing-infrastructure/timely-grafana/Dockerfile
b/contrib/terraform-testing-infrastructure/timely-grafana/Dockerfile
index bcc6759..b5386ac 100644
--- a/contrib/terraform-testing-infrastructure/timely-grafana/Dockerfile
+++ b/contrib/terraform-testing-infrastructure/timely-grafana/Dockerfile
@@ -16,6 +16,7 @@
# specific language governing permissions and limitations
# under the License.
#
+
FROM redhat/ubi8 as builder
COPY build_output/maven /opt/apache-maven
COPY build_output/repo /opt/apache-maven
diff --git
a/src/main/java/org/apache/accumulo/testing/continuous/ManySplits.java
b/src/main/java/org/apache/accumulo/testing/continuous/ManySplits.java
index d28f557..920c990 100644
--- a/src/main/java/org/apache/accumulo/testing/continuous/ManySplits.java
+++ b/src/main/java/org/apache/accumulo/testing/continuous/ManySplits.java
@@ -168,7 +168,7 @@ public class ManySplits {
// wait for all tablets to reach the expected sum file size
tableNames.stream().parallel().forEach(tableName -> {
- int elapsedMillis = 0;
+ long elapsedMillis = 0;
long sleepMillis = SECONDS.toMillis(1);
try {
// wait for each tablet to reach the expected sum file size
diff --git
a/src/main/java/org/apache/accumulo/testing/randomwalk/sequential/BatchVerify.java
b/src/main/java/org/apache/accumulo/testing/randomwalk/sequential/BatchVerify.java
index 594c4ab..e13f21a 100644
---
a/src/main/java/org/apache/accumulo/testing/randomwalk/sequential/BatchVerify.java
+++
b/src/main/java/org/apache/accumulo/testing/randomwalk/sequential/BatchVerify.java
@@ -53,7 +53,7 @@ public class BatchVerify extends Test {
try (BatchScanner scanner =
client.createBatchScanner(state.getString("seqTableName"), new
Authorizations(), 2)) {
- int count = 0;
+ long count = 0;
List<Range> ranges = new ArrayList<>();
while (count < numVerify) {
long rangeStart = env.getRandom().nextInt((int) numWrites);
diff --git a/src/main/java/org/apache/accumulo/testing/stress/DataWriter.java
b/src/main/java/org/apache/accumulo/testing/stress/DataWriter.java
index 5cc4c90..49c538f 100644
--- a/src/main/java/org/apache/accumulo/testing/stress/DataWriter.java
+++ b/src/main/java/org/apache/accumulo/testing/stress/DataWriter.java
@@ -18,27 +18,19 @@
*/
package org.apache.accumulo.testing.stress;
-import java.lang.ref.Cleaner.Cleanable;
import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.MutationsRejectedException;
-import org.apache.accumulo.core.util.cleaner.CleanerUtil;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class DataWriter extends Stream<Void> implements AutoCloseable {
private final BatchWriter writer;
private final RandomMutations mutations;
- private final Cleanable cleanable;
private final AtomicBoolean closed = new AtomicBoolean(false);
- private static final Logger log = LoggerFactory.getLogger(DataWriter.class);
-
public DataWriter(BatchWriter writer, RandomMutations mutations) {
this.writer = writer;
this.mutations = mutations;
- this.cleanable = CleanerUtil.unclosed(this, DataWriter.class, closed, log,
writer);
}
@Override
@@ -54,9 +46,6 @@ public class DataWriter extends Stream<Void> implements
AutoCloseable {
@Override
public void close() {
if (closed.compareAndSet(false, true)) {
- // deregister cleanable, but it won't run because it checks
- // the value of closed first, which is now true
- cleanable.clean();
try {
writer.close();
} catch (MutationsRejectedException e) {
