diff options
| author | Yang Song <songy23@users.noreply.github.com> | 2018-02-08 17:05:56 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-02-08 17:05:56 -0800 |
| commit | ad1a3fb10f5d8a1d958a3d82be264e22ca9e5c5c (patch) | |
| tree | 0d2f8615a5905662ae940e4b879ddc6c490b2e49 /exporters | |
| parent | da08eb4d6c1022286b98c6f0da880cbaa72607ab (diff) | |
| download | opencensus-java-ad1a3fb10f5d8a1d958a3d82be264e22ca9e5c5c.tar.gz | |
Increase batch export size of StackdriverStatsExporter to 200 (#988)
Diffstat (limited to 'exporters')
2 files changed, 3 insertions, 3 deletions
diff --git a/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorker.java b/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorker.java index 1eefa6a0..9d9b21fb 100644 --- a/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorker.java +++ b/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorker.java @@ -60,7 +60,8 @@ final class StackdriverExporterWorker implements Runnable { private static final Logger logger = Logger.getLogger(StackdriverExporterWorker.class.getName()); - @VisibleForTesting static final int MAX_BATCH_EXPORT_SIZE = 3; + // Stackdriver Monitoring v3 only accepts up to 200 TimeSeries per CreateTimeSeries call. + @VisibleForTesting static final int MAX_BATCH_EXPORT_SIZE = 200; private final long scheduleDelayMillis; private final String projectId; @@ -173,7 +174,6 @@ final class StackdriverExporterWorker implements Runnable { Span span = tracer.getCurrentSpan(); span.addAnnotation("Export Stackdriver TimeSeries."); try (Scope scope = tracer.withSpan(span)) { - // Batch export 3 TimeSeries at one call, to avoid exceeding RPC header size limit. CreateTimeSeriesRequest request = CreateTimeSeriesRequest.newBuilder() .setName(projectName.toString()) diff --git a/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorkerTest.java b/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorkerTest.java index c569dcd5..ac739a8f 100644 --- a/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorkerTest.java +++ b/exporters/stats/stackdriver/src/test/java/io/opencensus/exporter/stats/stackdriver/StackdriverExporterWorkerTest.java @@ -110,7 +110,7 @@ public class StackdriverExporterWorkerTest { @Test public void testConstants() { - assertThat(StackdriverExporterWorker.MAX_BATCH_EXPORT_SIZE).isEqualTo(3); + assertThat(StackdriverExporterWorker.MAX_BATCH_EXPORT_SIZE).isEqualTo(200); } @Test |