Use batch span processor, increase memory limits for the benchmark

Signed-off-by: Juraci Paixão Kröhling <[email protected]>

opentelemetry-benchmark-simple-java/src/main/java/io/opentelemetry/benchmark/config/TracerConfiguration.java

@@ -1,86 +1,77 @@
 package io.opentelemetry.benchmark.config;
 
-import io.opentelemetry.api.trace.Tracer;
+import java.util.concurrent.TimeUnit;
+
 import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
 import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.api.trace.Tracer;
 import io.opentelemetry.exporter.jaeger.JaegerGrpcSpanExporter;
 import io.opentelemetry.exporter.otlp.trace.OtlpGrpcSpanExporter;
 import io.opentelemetry.sdk.OpenTelemetrySdk;
+import io.opentelemetry.sdk.autoconfigure.OpenTelemetrySdkAutoConfiguration;
 import io.opentelemetry.sdk.resources.Resource;
 import io.opentelemetry.sdk.trace.SdkTracerProvider;
-import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
 import io.opentelemetry.sdk.trace.export.BatchSpanProcessor;
-import io.opentelemetry.sdk.autoconfigure.OpenTelemetrySdkAutoConfiguration;
 import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
-import java.util.concurrent.TimeUnit;
 
 public class TracerConfiguration {
 
     public static Tracer getTracer(String tracername) {
-        switch(tracername){
+        switch (tracername) {
             case "jaeger":
                 return initJaeger("localhost", 14250);
-
-
+
             case "otlp":
-                return initOtlp("localhost",9411);
-
-
+                return initOtlp("localhost", 9411);
+
         }
-        return null;  
-        
+        return null;
+
     }
 
     private static Tracer initJaeger(String jaegerHostName, int jaegerPort) {
         // Create a channel towards Jaeger end point
-        ManagedChannel jaegerChannel =
-        ManagedChannelBuilder.forAddress(jaegerHostName, jaegerPort).usePlaintext().build();
-    // Export traces to Jaeger
-    JaegerGrpcSpanExporter jaegerExporter =
-        JaegerGrpcSpanExporter.builder()
-            .setChannel(jaegerChannel)
-            .setTimeout(30, TimeUnit.SECONDS)
-            .build();
-
-    Resource serviceNameResource =
-        Resource.create(Attributes.of(ResourceAttributes.SERVICE_NAME, "otel-jaeger-example"));
-
-    // Set to process the spans by the Jaeger Exporter
-    SdkTracerProvider tracerProvider =
-        SdkTracerProvider.builder()
-            .addSpanProcessor(SimpleSpanProcessor.create(jaegerExporter))
-            .setResource(Resource.getDefault().merge(serviceNameResource))
-            .build();
-    OpenTelemetrySdk openTelemetry =
-        OpenTelemetrySdk.builder().setTracerProvider(tracerProvider).build();
-
-    // it's always a good idea to shut down the SDK cleanly at JVM exit.
-    Runtime.getRuntime().addShutdownHook(new Thread(tracerProvider::close));
-    return openTelemetry.getTracer("io.opentelemetry.jaeger");
-
-}
+        ManagedChannel jaegerChannel = ManagedChannelBuilder.forAddress(jaegerHostName, jaegerPort).usePlaintext()
+                .build();
+        // Export traces to Jaeger
+        JaegerGrpcSpanExporter jaegerExporter = JaegerGrpcSpanExporter.builder().setChannel(jaegerChannel)
+                .setTimeout(30, TimeUnit.SECONDS).build();
+
+        Resource serviceNameResource = Resource
+                .create(Attributes.of(ResourceAttributes.SERVICE_NAME, "otel-jaeger-example"));
+
+        BatchSpanProcessor batchSpansProcessor = BatchSpanProcessor.builder(jaegerExporter)
+                .setMaxExportBatchSize(1_000)
+                .setMaxQueueSize(1_000_000)
+                .setExporterTimeout(5, TimeUnit.SECONDS)
+                .build();
 
-    private static Tracer initOtlp(String ip, int port){
+        // Set to process the spans by the Jaeger Exporter
+        SdkTracerProvider tracerProvider = SdkTracerProvider.builder().addSpanProcessor(batchSpansProcessor)
+                .setResource(Resource.getDefault().merge(serviceNameResource)).build();
+        OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder().setTracerProvider(tracerProvider).build();
+
+        // it's always a good idea to shut down the SDK cleanly at JVM exit.
+        Runtime.getRuntime().addShutdownHook(new Thread(tracerProvider::close));
+        return openTelemetry.getTracer("io.opentelemetry.jaeger");
+
+    }
+
+    private static Tracer initOtlp(String ip, int port) {
         OtlpGrpcSpanExporter spanExporter = OtlpGrpcSpanExporter.builder().setTimeout(2, TimeUnit.SECONDS).build();
-        BatchSpanProcessor spanProcessor =
-            BatchSpanProcessor.builder(spanExporter)
-            .setScheduleDelay(100, TimeUnit.MILLISECONDS)
-            .build();
-
-        SdkTracerProvider tracerProvider =
-            SdkTracerProvider.builder()
-            .addSpanProcessor(spanProcessor)
-            .setResource(OpenTelemetrySdkAutoConfiguration.getResource())
-            .build();
-        OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder().setTracerProvider(tracerProvider).buildAndRegisterGlobal();
+        BatchSpanProcessor spanProcessor = BatchSpanProcessor.builder(spanExporter)
+                .setScheduleDelay(100, TimeUnit.MILLISECONDS).build();
+
+        SdkTracerProvider tracerProvider = SdkTracerProvider.builder().addSpanProcessor(spanProcessor)
+                .setResource(OpenTelemetrySdkAutoConfiguration.getResource()).build();
+        OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder().setTracerProvider(tracerProvider)
+                .buildAndRegisterGlobal();
 
         Runtime.getRuntime().addShutdownHook(new Thread(tracerProvider::close));
         Tracer tracer = openTelemetry.getTracer("io.opentelemetry.OtlpTracer");
         return tracer;
 
     }
 
-
-
 }

opentelemetry-benchmark-simple-java/src/main/java/io/opentelemetry/benchmark/main/Main.java

@@ -23,7 +23,7 @@ public static void main(String[] args) {
                 .threads(1)
                 .resultFormat(resultsFileOutputType)
                 .result(buildResultsFileName(resultFilePrefix, resultsFileOutputType))
-                .jvmArgs("-server", "-Xms2048m", "-Xmx2048m")
+                .jvmArgs("-server", "-Xms2048m", "-Xmx16384m")
                 .build();
         try {
             new Runner(opt).run();

runner/run-on-remote.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
-REMOTE_HOST=${REMOTE_HOST:-147.75.80.139}
+REMOTE_HOST=${REMOTE_HOST:-145.40.68.181}
 REMOTE_RESULTS_DIR=${REMOTE_RESULTS_DIR:-/results}
 RESULTS_DIR=${RESULTS_DIR:-./results-$(date -u +%s)}
 

runner/setup-on-remote.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
-REMOTE_HOST=${REMOTE_HOST:-147.75.80.139}
+REMOTE_HOST=${REMOTE_HOST:-145.40.68.181}
 SETUP_OPTS=${SETUP_OPTS:-""}
 
 while getopts f: flag