You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2015/06/16 22:14:21 UTC
[2/4] accumulo git commit: ACCUMULO-2240 Format change fix from
previous patch
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/master
Commit: 5ef5b853806a6b610fc537b89fc3be64452d3bc4
Parents: 1f8954f
Author: Christopher Tubbs <ct...@apache.org>
Authored: Tue Jun 16 15:32:05 2015 -0400
Committer: Christopher Tubbs <ct...@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 {