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_r394828407
##########
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:
@jojochuang - any updates here? Does the Open-telemetry support better
logging? I can try that anyway with some sample code. But do you have any heads
up on that?
----------------------------------------------------------------
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
