dlmarion commented on code in PR #2620:
URL: https://github.com/apache/accumulo/pull/2620#discussion_r852949706
##########
server/tserver/src/main/java/org/apache/accumulo/tserver/ThriftClientHandler.java:
##########
@@ -162,17 +164,22 @@
import io.opentelemetry.api.trace.Span;
import io.opentelemetry.context.Scope;
-public class ThriftClientHandler extends ClientServiceHandler implements
TabletClientService.Iface {
+public class ThriftClientHandler implements TabletClientService.Iface {
private static final Logger log =
LoggerFactory.getLogger(ThriftClientHandler.class);
private final long MAX_TIME_TO_WAIT_FOR_SCAN_RESULT_MILLIS;
private static final long RECENTLY_SPLIT_MILLIES = MINUTES.toMillis(1);
private final TabletServer server;
+ protected final TransactionWatcher transactionWatcher;
+ protected final ServerContext context;
+ protected final SecurityOperation security;
private final WriteTracker writeTracker = new WriteTracker();
private final RowLocks rowLocks = new RowLocks();
public ThriftClientHandler(TabletServer server) {
- super(server.getContext(), new TransactionWatcher(server.getContext()));
+ this.context = server.getContext();
+ this.transactionWatcher = new TransactionWatcher(server.getContext());
Review Comment:
Modified to create a TransactionWatcher in TabletServer and pass the
instance to the ClientHandler and the TabletClientHandler in
d582824abc7df65759f6ebe2dc3d55e0ec554daa
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
