Code review changes

hpcc-systems · Jul 16, 2024 · 97fe9c8 · 97fe9c8
1 parent ca378b4
commit 97fe9c8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
@@ -1755,6 +1755,7 @@ private void makeActive() throws HpccFileException
                 try
                 {
                     String msg = makeGetVersionRequest();
+                    System.out.println(msg);
                     int msgLen = msg.length();
 
                     this.dos.writeInt(msgLen);

diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/Utils.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/Utils.java
@@ -55,15 +55,18 @@ public static Span createSpan(String name)
                                         .setSpanKind(SpanKind.CLIENT)
                                         .startSpan();
         span.makeCurrent();
+
         return span;
     }
 
     public static Span createChildSpan(Span parentSpan, String name)
     {
-        return Utils.getTelemetryTracer().spanBuilder(name)
+        Span span = Utils.getTelemetryTracer().spanBuilder(name)
                                         .setParent(Context.current().with(parentSpan))
                                         .setSpanKind(SpanKind.CLIENT)
                                         .startSpan();
+        span.makeCurrent();
+        return span;
     }
 
 }