Add logs

apache · Sep 9, 2024 · 9461e2f · 9461e2f
1 parent 4c8390a
commit 9461e2f
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 3 deletions.
diff --git a/...ter-analyzer/src/main/java/org/apache/skywalking/oap/meter/analyzer/dsl/SampleFamily.java b/...ter-analyzer/src/main/java/org/apache/skywalking/oap/meter/analyzer/dsl/SampleFamily.java
@@ -83,6 +83,7 @@ public class SampleFamily {
     static SampleFamily build(RunningContext ctx, Sample... samples) {
         Preconditions.checkNotNull(samples);
         Preconditions.checkArgument(samples.length > 0);
+        log.info("Samples size: {}", samples.length);
         samples = Arrays.stream(samples).filter(sample -> !Double.isNaN(sample.getValue())).toArray(Sample[]::new);
         if (samples.length == 0) {
             return EMPTY;

diff --git a/...ain/java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryLogHandler.java b/...ain/java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryLogHandler.java
@@ -108,7 +108,7 @@ public void export(ExportLogsServiceRequest request, StreamObserver<ExportLogsSe
                         doAnalysisQuietly(service, layer, serviceInstance, logRecord);
                     }
                 });
-            responseObserver.onNext(ExportLogsServiceResponse.getDefaultInstance());
+            responseObserver.onNext(ExportLogsServiceResponse.newBuilder().build());
             responseObserver.onCompleted();
         });
     }

diff --git a/.../java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryMetricHandler.java b/.../java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryMetricHandler.java
@@ -57,7 +57,7 @@ public void export(
         final ExportMetricsServiceRequest requests,
         final StreamObserver<ExportMetricsServiceResponse> responseObserver) {
         metricRequestProcessor.processMetricsRequest(requests);
-        responseObserver.onNext(ExportMetricsServiceResponse.getDefaultInstance());
+        responseObserver.onNext(ExportMetricsServiceResponse.newBuilder().build());
         responseObserver.onCompleted();
     }
 

diff --git a/...n/java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryTraceHandler.java b/...n/java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryTraceHandler.java
@@ -126,7 +126,7 @@ public void export(ExportTraceServiceRequest request, StreamObserver<ExportTrace
             getForwardService().send(result);
         }
 
-        responseObserver.onNext(ExportTraceServiceResponse.getDefaultInstance());
+        responseObserver.onNext(ExportTraceServiceResponse.newBuilder().build());
         responseObserver.onCompleted();
     }