Repository: accumulo Updated Branches: refs/heads/1.7 1f8954fb0 -> 5ef5b8538 refs/heads/master fb349a42d -> f73e79399
ACCUMULO-2240 Format change fix from previous patch Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/5ef5b853 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/5ef5b853 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/5ef5b853 Branch: refs/heads/1.7 Commit: 5ef5b853806a6b610fc537b89fc3be64452d3bc4 Parents: 1f8954f Author: Christopher Tubbs <ctubb...@apache.org> Authored: Tue Jun 16 15:32:05 2015 -0400 Committer: Christopher Tubbs <ctubb...@apache.org> Committed: Tue Jun 16 15:32:05 2015 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/accumulo/tracer/TraceServer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/5ef5b853/server/tracer/src/main/java/org/apache/accumulo/tracer/TraceServer.java ---------------------------------------------------------------------- diff --git a/server/tracer/src/main/java/org/apache/accumulo/tracer/TraceServer.java b/server/tracer/src/main/java/org/apache/accumulo/tracer/TraceServer.java index ee75cda..7511f3c 100644 --- a/server/tracer/src/main/java/org/apache/accumulo/tracer/TraceServer.java +++ b/server/tracer/src/main/java/org/apache/accumulo/tracer/TraceServer.java @@ -236,7 +236,8 @@ public class TraceServer implements Watcher { options.processor(new Processor<Iface>(new Receiver())); server = new TThreadPoolServer(options); registerInZooKeeper(sock.getInetAddress().getHostAddress() + ":" + sock.getLocalPort(), conf.get(Property.TRACE_ZK_PATH)); - writer = new AtomicReference<BatchWriter>(this.connector.createBatchWriter(table, new BatchWriterConfig().setMaxLatency(BATCH_WRITER_MAX_LATENCY, TimeUnit.SECONDS))); + writer = new AtomicReference<BatchWriter>(this.connector.createBatchWriter(table, + new BatchWriterConfig().setMaxLatency(BATCH_WRITER_MAX_LATENCY, TimeUnit.SECONDS))); } public void run() throws Exception {
