Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -334,11 +334,6 @@ public ClientContext(ClientInfo info, AccumuloConfiguration serverConf,
});

zkLockChecker = memoize(() -> {
// make this use its own ZooSession and ZooCache, because this is used by the
// tablet location cache, which is a static singleton reused by multiple clients
// so, it can't rely on being able to continue to use the same client's ZooCache,
// because that client could be closed, and its ZooSession also closed
// this needs to be fixed; TODO https://github.com/apache/accumulo/issues/2301
var zk = info.getZooKeeperSupplier(ZookeeperLockChecker.class.getSimpleName(),
ZooUtil.getRoot(getInstanceID())).get();
return new ZookeeperLockChecker(new ZooCache(zk, Set.of(Constants.ZTSERVERS)));
Comment on lines 336 to 339

@Amemeda Amemeda Aug 25, 2026

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Attaching comment from issue discussing the relevance of this TODO. It looks like it is no longer relevant but could use @ctubbsii opinion.
#2699 (comment)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,6 @@ private ScanServerData binRanges(ClientTabletCache clientTabletCache, List<Range
}

if (retryCountDownTimer.isExpired()) {
// TODO exception used for timeout is inconsistent
throw new TimedOutException(
"Failed to find servers to process scans before timeout was exceeded.");
}
Comment on lines 307 to 310

@Amemeda Amemeda Aug 24, 2026

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Removed this TODO for now. The exception used here seems consistent with what is happening: TimedOutException because the retryCountDownTimer has expired. If anything, the message may not be accurate description of why the timeout happened.

I can add it back if the todo should remain, or if a different exception/message should be used here, I can replace.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import java.util.stream.Collectors;

import org.apache.accumulo.core.data.TabletId;
import org.apache.accumulo.core.dataImpl.KeyExtent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -77,13 +78,12 @@ public void setMigrations(Set<TabletId> migrations) {
@Override
public void report() {
log.warn("Not balancing due to {} outstanding migrations.", migrations.size());
/*
* TODO ACCUMULO-2938 redact key extents in this output to avoid leaking protected
* information.
*/
if (log.isDebugEnabled()) {
// convert each tabletId in migrations to keyExtent for redacting
log.debug("Sample up to 10 outstanding migrations: {}",
migrations.stream().limit(10).map(String::valueOf).collect(Collectors.joining(", ")));
migrations.stream().limit(10)
.map(tabletId -> KeyExtent.fromTabletId(tabletId).obscured())
.collect(Collectors.joining(", ")));
}
// Now that we've reported, clear out the migrations list so we don't hold it in memory.
migrations = Collections.emptySet();
Expand Down