dlmarion commented on a change in pull request #1818:
URL: https://github.com/apache/accumulo/pull/1818#discussion_r555169849
##########
File path:
core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchWriter.java
##########
@@ -198,6 +197,8 @@ public long getTimeOut() {
public TabletServerBatchWriter(ClientContext context, BatchWriterConfig
config) {
this.context = context;
+ this.executor =
ThreadPools.getGeneralScheduledExecutorService(this.context.getConfiguration());
+ this.failedMutations = new FailedMutations();
Review comment:
It's been almost a month since I looked at this. I don't remember the
reason why I moved it and it should work if this line was reverted. I'm not
sure if there is reason to do it one vs the other. I can easily change it back
if necessary.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
