ramkrish86 commented on a change in pull request #1210: HBASE-23757.
[OpenTracing] Migrate from HTrace to OpenTracing (Java code)
URL: https://github.com/apache/hbase/pull/1210#discussion_r386890589
##########
File path:
hbase-common/src/main/java/org/apache/hadoop/hbase/trace/TraceUtil.java
##########
@@ -17,103 +17,169 @@
*/
package org.apache.hadoop.hbase.trace;
+import io.opentracing.Scope;
+import io.opentracing.SpanContext;
+import io.opentracing.mock.MockTracer;
+import io.opentracing.propagation.Format;
+import io.opentracing.propagation.TextMapExtractAdapter;
+import io.opentracing.propagation.TextMapInjectAdapter;
+import io.opentracing.Span;
+import io.opentracing.SpanContext;
+import io.opentracing.Tracer;
+import io.opentracing.propagation.Format;
+import io.opentracing.propagation.TextMapExtractAdapter;
+import io.opentracing.propagation.TextMapInjectAdapter;
+import io.opentracing.util.GlobalTracer;
+import org.apache.commons.codec.binary.Hex;
import org.apache.hadoop.conf.Configuration;
import org.apache.htrace.core.HTraceConfiguration;
import org.apache.htrace.core.Sampler;
-import org.apache.htrace.core.Span;
import org.apache.htrace.core.SpanReceiver;
import org.apache.htrace.core.TraceScope;
-import org.apache.htrace.core.Tracer;
+import io.jaegertracing.Configuration.SamplerConfiguration;
+
+import org.apache.hadoop.tracing.TraceUtils;
+import
org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesting;
import org.apache.yetus.audience.InterfaceAudience;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
+import java.util.HashMap;
+import java.util.Map;
/**
* This wrapper class provides functions for accessing htrace 4+ functionality
in a simplified way.
*/
@InterfaceAudience.Private
public final class TraceUtil {
- private static HTraceConfiguration conf;
- private static Tracer tracer;
+ static final Logger LOG = LoggerFactory.getLogger(TraceUtils.class);
+
+ private static io.jaegertracing.Configuration conf;
+ private static io.opentracing.Tracer tracer;
+
+ public static final String HBASE_OPENTRACING_TRACER =
"hbase.opentracing.tracer";
+ public static final String HBASE_OPENTRACING_TRACER_DEFAULT = "jaeger";
+ public static final String HBASE_OPENTRACING_MOCKTRACER = "mock";
private TraceUtil() {
}
- public static void initTracer(Configuration c) {
- if (c != null) {
- conf = new HBaseHTraceConfiguration(c);
+ public static void initTracer(Configuration c, String serviceName) {
+ if (GlobalTracer.isRegistered()) {
+ LOG.info("A tracer is already registered.");
+ return;
}
- if (tracer == null && conf != null) {
- tracer = new Tracer.Builder("Tracer").conf(conf).build();
+ switch(c.get(HBASE_OPENTRACING_TRACER, HBASE_OPENTRACING_TRACER_DEFAULT)) {
+ case HBASE_OPENTRACING_TRACER_DEFAULT:
+ io.jaegertracing.Configuration conf =
io.jaegertracing.Configuration.fromEnv(serviceName);
+ tracer = conf.getTracerBuilder().build();
+ break;
+ case HBASE_OPENTRACING_MOCKTRACER:
+ tracer = new MockTracer();
+ break;
+ default:
+ throw new RuntimeException("Unexpected tracer");
}
+
+
+ GlobalTracer.register(tracer);
Review comment:
One more question - suppose I want to store my traces to some storage - I
know Jaeger supports Cassandra and Elastic search backends but that is not
exposed to us - so that we can have our own way of backend storage like even
dumping to a local file? or say even in hbase system table itself? Is there any
thoughts or future plans for this support ?
----------------------------------------------------------------
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]
With regards,
Apache Git Services
