From 97fe9c8d15c19b61eab251af11887286af88f41e Mon Sep 17 00:00:00 2001 From: James McMullan Date: Tue, 16 Jul 2024 09:17:25 -0400 Subject: [PATCH] Code review changes --- .../org/hpccsystems/dfs/client/RowServiceInputStream.java | 1 + .../src/main/java/org/hpccsystems/dfs/client/Utils.java | 5 ++++- 2 files changed, 5 insertions(+), 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 index 90d30794e..afbb47c42 100644 --- 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 index 0458b45fa..7ac5b74e5 100644 --- 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; } }