Memory Mode support: Adding memory mode, and implementing it for Asynchronous Instruments #5709

asafm · 2023-08-13T14:18:14Z

Epic

This is the first PR out of several which implements #5105.

The problem

Issue #5105 describes it quite well, so I'll add a very short motivation.
Currently the SDK uses immutable objects during metric collection, where the bulk of the work is located at the LeasedMetricProducer.
The side effect of immutable objects is that they generate a lot of garbage collected objects. Given enough instruments and/or attribute sets, this can amount to such a substantial amount, the garbage collector will start to kick in more often, and for longer periods of time.
There are systems which are ultra sensitive to latency, like databases and messaging systems (e.g. Apache Pulsar). Those systems will have a problem using OpenTelemetry as it is today.

The solution

The SDK will have two modes of operation:

Immutability - in which it behaves as it is now during metric collection and uses immutable objects.
Reusability - in which most objects used during collection would be reusable - mutable objects that are pooled into an object pool between collection runs.

What does this PR include?

This PR is focused on adding support for reusability, and implementing it for Asynchronous Instruments.

The introduction of a MemoryMode enum dictating the two different modes.
Adding a memoryMode property to MetricReader. This is used by the SDK collection process (in this PR only the Asynchronous Instrument related code) to switch between using immutable objects of reusable objects (from a pool).
For PeriodicMetricReader we've added memoryMode property to MetricExporter as well, so both the metric exporter can act upon it, and also the PeriodicMetricReader delegates the value of memoryMode to the MetricExporter it has.
A set of mutable implementations of DoublePointData and LongPointData. This are used to carry the current value for each (instrument, attributes) pair.
Adding a mutable version of Measurement, by changing it from an abstract class into an interface and creating two classes implementing it: ImmutableMeasurement and LeasedMeasurement.
SdkObservableMeasurement has been changed to object reuse if reusable memory mode is selected, for the active metric reader. Since it only creates Measurement object only as DTO for calling AsynchronousMetricStorage.record(measurement), I've added a single LeasedMeasurement object and keep re-using it across calls to record() from the callbacks. It was named "leased" since the SdkObserableMeasurement leases the measurement to AsynchronousMetricStorage for the duration of the record() call - it should not store it hence "leased".

Data structures for reusable objects

I've added an ObjectPool class which as it sounds, allows you to borrow an object from the pool. If the pool is empty it uses an objectCreator function to generate one and return it. When the object is done with, instead of being garbage collected, it is returned back to the pool using returnObject(o).
The pool it self must avoid any O(n) memory allocations upon borrow or return operations, hence using a simple array-based stack I wrote ArrayBasedStack. I decided to write one instead of using ArrayDequeue since I want in next PR improve the extra space it occupies (instead of x2 switching to changing double factor, or trim after x collections)
Also I've added PooledHashMap, which is a bucket-based HashMap implementation, which uses an object pool when it needs a MapEntry object. This is needed primarily in AsynchronousMetricStorage.

Storage

AsynchronousMetricStorage - here the bulk of the work was done in this PR. This is where all the callback record() calls gets funneled into. The primary changes were:
- Using PooledHashMap instead of HashMap to reduce MapEntry memory allocations which were O(n). The maps are used to store the recordings (attributes -> point) and in case of DELTA temporality, the previous data points.
- in record(measurement), the measurement is now converted into a reusable data point, coming from a pool of
  reusable data points, in the case of REUSABLE memory mode.
- The result returned by collect() is now a reusable list (array-based), in the case of REUSABLE memory mode. Array-based removes any internal wrapper objects allocations.
- In collect() it return a list of reusable points, which needs to return back to the pool. We do so when the next collect() is called. We "save" the list returned, return each reusable data point back to the pool, and reset the list for another usage.
- The DELTA mode was a bit refactored to allow for easier reasoning when reading it.
The *Aggregator classes were modified to allow for reusable data points to avoid allocations.

Benchmark tests

Garbage Collection (memory allocation) benchmark

AsynchronousMetricStorageGarbageCollectionBenchmarkTest runs a JMH benchmark named AsynchronousMetricStorageGarbageCollectionBenchmark with gc profiler, which measures the number
of objects (and size) the garbage collector collected (unused objects).

The AsynchronousMetricStorageGarbageCollectionBenchmark benchmark creates 10 asynchronous counters (any asynchronous instrument will do as the code path that was changes is almost the same for all async instrument types), and 1000 attribute sets. Each time the test runs, it calls flush which effectively calls the callback for each counter. Each such callback records a random number for each of the 1000 attribute sets. The result list ends up in NoOpMetricExporter which does nothing with it.

This is repeated 100 times, collectively called operation in the statistics and each such Operation is repeated 20 times - known as Iteration.

Each such test is repeated, with a brand new JVM, for all combinations of memory mode (REUSBLE_DATA, IMMUTABLE_DATA) and aggregation temporality (CUMULATIVE, DELTA). This is done since each combination has a different code path.

The statistics of this run can be seen in the output of the test and also pasted here below:

Benchmark                                                                                (aggregationTemporality)    (memoryMode)  Mode  Cnt          Score          Error   Units
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect                                        DELTA   REUSABLE_DATA    ss   20  253203950.050 ± 14647630.858   ns/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate                          DELTA   REUSABLE_DATA    ss   20          0.968 ±        0.038  MB/sec
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate.norm                     DELTA   REUSABLE_DATA    ss   20     257078.800 ±     8031.841    B/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.count                               DELTA   REUSABLE_DATA    ss   20            ≈ 0                 counts
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect                                        DELTA  IMMUTABLE_DATA    ss   20  181222052.050 ± 20645573.792   ns/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate                          DELTA  IMMUTABLE_DATA    ss   20       1437.476 ±      125.219  MB/sec
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate.norm                     DELTA  IMMUTABLE_DATA    ss   20  271877200.400 ±   527883.090    B/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.count                               DELTA  IMMUTABLE_DATA    ss   20         18.000                 counts
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.time                                DELTA  IMMUTABLE_DATA    ss   20         75.000                     ms
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect                                   CUMULATIVE   REUSABLE_DATA    ss   20  191358368.900 ± 13650017.689   ns/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate                     CUMULATIVE   REUSABLE_DATA    ss   20          1.166 ±        0.074  MB/sec
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate.norm                CUMULATIVE   REUSABLE_DATA    ss   20     233689.200 ±     8675.469    B/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.count                          CUMULATIVE   REUSABLE_DATA    ss   20            ≈ 0                 counts
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect                                   CUMULATIVE  IMMUTABLE_DATA    ss   20  142355889.500 ± 15351913.671   ns/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate                     CUMULATIVE  IMMUTABLE_DATA    ss   20       1403.485 ±      125.334  MB/sec
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.alloc.rate.norm                CUMULATIVE  IMMUTABLE_DATA    ss   20  208828913.600 ±   407209.901    B/op
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.count                          CUMULATIVE  IMMUTABLE_DATA    ss   20         13.000                 counts
AsynchronousMetricStorageGarbageCollectionBenchmark.recordAndCollect:gc.time                           CUMULATIVE  IMMUTABLE_DATA    ss   20         66.000                     ms

If we focus only on the normalized rate:

Benchmark                                            (aggregationTemporality)    (memoryMode)  Mode  Cnt          Score          Error   Units
recordAndCollect:gc.alloc.rate.norm                     DELTA   REUSABLE_DATA    ss   20     257078.800 ±     8031.841    B/op
recordAndCollect:gc.alloc.rate.norm                     DELTA  IMMUTABLE_DATA    ss   20  271877200.400 ±   527883.090    B/op
recordAndCollect:gc.alloc.rate.norm                CUMULATIVE   REUSABLE_DATA    ss   20     233689.200 ±     8675.469    B/op
recordAndCollect:gc.alloc.rate.norm                CUMULATIVE  IMMUTABLE_DATA    ss   20  208828913.600 ±   407209.901    B/op

You can see that for DELTA aggregation temporality, REUSABLE_DATA scores a rate of 257,078 [bytes/operation] compared with 271,877,200 [bytes/operation], which means REUSABLE_DATA memory mode reduced the size of
garbage collected objects by 99.9% compared with IMMUTABLE_DATA memory mode. Similar results (99.88%) exists for CUMULATIVE.

The test verifies that. Aside from the convenience of running this inside your code editor with one click, it protects from any future regression that can easily arise from a simple refactor or change.

Memory usage benchmark

IMMUTABLE_DATA "pays" with lots of one-off objects which almost immediately gets garbage collected. Memory is allocated to certain peak and then released. On the other hand, REUSABLE_DATA uses reusable objects, located in object pools, which stays in memory even after the collection finished. So it "pays" with constant memory usage. In a perfect implementation the peak memory consumption would almost be equal in both cases.

The object pools are not yet tuned, so they aggressively allocates more than what they need. In subsequent PRs I would like to minimize that effect, so the max heap for both is not far off each other.

You can run AsynchronousCounterMemoryUsageBenchmark main() method to view the memory usage for each combination of aggregation temporality, memory mode, number of asynchronous instruments and number of attribute sets.

The results are:

Cumulative

	Counter	Attribute Sets	Max used heap	Heap After
IMMUTABLE	1	100k	34 [mb]	21 [mb]
REUSABLE	1	100k	41 [mb]	37 [mb]
IMMUTABLE	50	100k	581 [mb]	21 [mb]
REUSABLE	50	100k	958 [mb]	822 [mb]

Delta

	Counter	Attribute Sets	Max used heap	Heap After
IMMUTABLE	1	100k	38 [mb]	30 [mb]
REUSABLE	1	100k	45 [mb]	41 [mb]
IMMUTABLE	50	100k	644 [mb]	474 [mb]
REUSABLE	50	100k	1195 [mb]	1029 [mb]

So you can see for example that for 50 counters and 100k attribute sets each, the maximum used memory is 958mb for reusable data and 581mb for immutable data, meaning 64% more memory needed. For 1 instrument, it's 20%. The reason it's bigger percentage as it has more attribute sets is because currently the object pool grows by 2 each time it runs out of capacity. This is something to be be tuned in next PRs.

`opentelemetry-sdk-metrics.txt`

Comparing source compatibility of  against 
+++  NEW ENUM: PUBLIC(+) FINAL(+) io.opentelemetry.sdk.metrics.export.MemoryMode  (compatible)
	+++  CLASS FILE FORMAT VERSION: 52.0 <- n.a.
	+++  NEW INTERFACE: java.lang.constant.Constable
	+++  NEW INTERFACE: java.lang.Comparable
	+++  NEW INTERFACE: java.io.Serializable
	+++  NEW SUPERCLASS: java.lang.Enum
	+++  NEW FIELD: PUBLIC(+) STATIC(+) FINAL(+) io.opentelemetry.sdk.metrics.export.MemoryMode REUSABLE_DATA
	+++  NEW FIELD: PUBLIC(+) STATIC(+) FINAL(+) io.opentelemetry.sdk.metrics.export.MemoryMode IMMUTABLE_DATA
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode valueOf(java.lang.String)
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode[] values()
***  MODIFIED INTERFACE: PUBLIC ABSTRACT io.opentelemetry.sdk.metrics.export.MetricExporter  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode getMemoryMode()
***  MODIFIED INTERFACE: PUBLIC ABSTRACT io.opentelemetry.sdk.metrics.export.MetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode getMemoryMode()
***  MODIFIED CLASS: PUBLIC FINAL io.opentelemetry.sdk.metrics.export.PeriodicMetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode getMemoryMode()
***  MODIFIED CLASS: PUBLIC FINAL io.opentelemetry.sdk.metrics.ViewBuilder  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.metrics.ViewBuilder setAttributeFilter(java.util.Set<java.lang.String>)

`opentelemetry-sdk-testing.txt`

Comparing source compatibility of  against 
***  MODIFIED CLASS: PUBLIC io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader$InMemoryMetricReaderBuilder builder()
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader create(io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector)
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.metrics.export.MemoryMode getMemoryMode()
+++  NEW CLASS: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader$InMemoryMetricReaderBuilder  (not serializable)
	+++  CLASS FILE FORMAT VERSION: 52.0 <- n.a.
	+++  NEW SUPERCLASS: java.lang.Object
	+++  NEW CONSTRUCTOR: PUBLIC(+) InMemoryMetricReader$InMemoryMetricReaderBuilder()
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader build()
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader$InMemoryMetricReaderBuilder setAggregationTemporalitySelector(io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector)
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader$InMemoryMetricReaderBuilder setDefaultAggregationSelector(io.opentelemetry.sdk.metrics.export.DefaultAggregationSelector)
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader$InMemoryMetricReaderBuilder setMemoryMode(io.opentelemetry.sdk.metrics.export.MemoryMode)

Future PRs

Tune ObjectPool so it won't occupy so much space - change growth factor as size increases, or introduce trimming.
Activate the memory mode. I haven't changed any exporter not reader yet.

…edHashMap

# Conflicts: # sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java

asafm · 2023-08-14T13:35:47Z

@jack-berg First PR 🎉

jack-berg

Thanks @asafm! This code will definitely reduce the readability of the code, but the performance improvement is so significant that I think its worth it to incur the additional complexity. I left a variety of comments, which are mostly small. I'm very supportive of the overall direction.

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/data/DoublePointData.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/MemoryMode.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/MetricExporter.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/MetricReader.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/ObjectPool.java

sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/internal/state/PooledHashMapTest.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/ArrayBasedStack.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/ObjectPool.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/data/MutableLongPointData.java

…MemoryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

…MetricExporter.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

…MetricReader.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

…l/state/ObjectPool.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

… with other factory methods

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/MemoryMode.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/MetricExporter.java

...metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/data/MutableDoublePointData.java

mateuszrzeszutek · 2023-08-29T15:44:15Z

...ics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java

+              ? ImmutableMeasurement.doubleMeasurement(
+                  start, measurement.epochNanos(), measurement.doubleValue(), processedAttributes)
+              : ImmutableMeasurement.longMeasurement(
+                  start, measurement.epochNanos(), measurement.longValue(), processedAttributes);


Measurement withAttributes(Attributes); Measurement withStartEpochNanos(long);

Wouldn't having 2 methods result in making 2 immutable copies? Perhaps a single

Measurement update(Attributes, long);

method would generate a bit less garbage

...ics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java

jkwatson · 2023-09-05T20:25:43Z

@jsuereth / @jkwatson would be good to get your opinion on the direction of this PR, given how substantial a change it is.

I'm unlikely to have time to dig into this at all in the forseeable future. If you're ok with it, and happy to support it, then I'm fine with it.

...ics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/MutableMeasurement.java

...ava/io/opentelemetry/sdk/metrics/internal/state/AsynchronousCounterMemoryUsageBenchmark.java

...testing/src/main/java/io/opentelemetry/sdk/testing/exporter/InMemoryMetricReaderBuilder.java

jack-berg

Very close IMO, just a few final cleanups!

…geCollectionBenchmarkTest

sdk/common/src/main/java/io/opentelemetry/sdk/common/export/MemoryMode.java

jack-berg · 2023-09-22T01:33:05Z

Looks good to me @asafm! Thanks for sticking with it. I'm out for a long weekend but when I get back I can help get the build passing if still stuck.

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

asafm · 2023-09-26T12:39:56Z

@jack-berg the build fails on API compare.
The diff I have:

Comparing source compatibility of  against 
+++  NEW ENUM: PUBLIC(+) FINAL(+) io.opentelemetry.sdk.common.export.MemoryMode  (compatible)
	+++  CLASS FILE FORMAT VERSION: 52.0 <- n.a.
	+++  NEW INTERFACE: java.lang.constant.Constable
	+++  NEW INTERFACE: java.lang.Comparable
	+++  NEW INTERFACE: java.io.Serializable
	+++  NEW SUPERCLASS: java.lang.Enum
	+++  NEW FIELD: PUBLIC(+) STATIC(+) FINAL(+) io.opentelemetry.sdk.common.export.MemoryMode REUSABLE_DATA
	+++  NEW FIELD: PUBLIC(+) STATIC(+) FINAL(+) io.opentelemetry.sdk.common.export.MemoryMode IMMUTABLE_DATA
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.common.export.MemoryMode valueOf(java.lang.String)
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.common.export.MemoryMode[] values()

and

Comparing source compatibility of  against 
***  MODIFIED INTERFACE: PUBLIC ABSTRACT io.opentelemetry.sdk.metrics.export.MetricExporter  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.common.export.MemoryMode getMemoryMode()
***  MODIFIED INTERFACE: PUBLIC ABSTRACT io.opentelemetry.sdk.metrics.export.MetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.common.export.MemoryMode getMemoryMode()
***  MODIFIED CLASS: PUBLIC FINAL io.opentelemetry.sdk.metrics.export.PeriodicMetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.common.export.MemoryMode getMemoryMode()

and

Comparing source compatibility of  against 
***  MODIFIED CLASS: PUBLIC io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader  (not serializable)
	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
	+++  NEW METHOD: PUBLIC(+) STATIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReaderBuilder builder()
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.common.export.MemoryMode getMemoryMode()
+++  NEW CLASS: PUBLIC(+) FINAL(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReaderBuilder  (not serializable)
	+++  CLASS FILE FORMAT VERSION: 52.0 <- n.a.
	+++  NEW SUPERCLASS: java.lang.Object
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader build()
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReaderBuilder setAggregationTemporalitySelector(io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector)
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReaderBuilder setDefaultAggregationSelector(io.opentelemetry.sdk.metrics.export.DefaultAggregationSelector)
	+++  NEW METHOD: PUBLIC(+) io.opentelemetry.sdk.testing.exporter.InMemoryMetricReaderBuilder setMemoryMode(io.opentelemetry.sdk.common.export.MemoryMode)

jack-berg · 2023-09-26T15:07:50Z

Can you run ./gradlew japicmp? That should generate api change documentation that is required for the build to pass.

asafm · 2023-09-26T15:53:28Z

@jack-berg Here's the output. What should I do next?

➜  opentelemetry-java git:(memory-allocations-async) ✗ ./gradlew japicmp

Deprecated Gradle features were used in this build, making it incompatible with Gradle 9.0.

You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.

For more on this, please refer to https://docs.gradle.org/8.3/userguide/command_line_interface.html#sec:command_line_warnings in the Gradle documentation.

BUILD SUCCESSFUL in 4s
141 actionable tasks: 3 executed, 138 up-to-date
➜  opentelemetry-java git:(memory-allocations-async) ✗ git status
On branch memory-allocations-async
Your branch is up to date with 'origin/memory-allocations-async'.

Changes not staged for commit:
  (use "git add <file>..." to update what will be committed)
  (use "git restore <file>..." to discard changes in working directory)
	modified:   docs/apidiffs/current_vs_latest/opentelemetry-sdk-common.txt
	modified:   docs/apidiffs/current_vs_latest/opentelemetry-sdk-metrics.txt
	modified:   docs/apidiffs/current_vs_latest/opentelemetry-sdk-testing.txt

no changes added to commit (use "git add" and/or "git commit -a")
➜  opentelemetry-java git:(memory-allocations-async) ✗

Commit those files?

codecov · 2023-09-26T17:53:47Z

Codecov Report

Attention: 80 lines in your changes are missing coverage. Please review.

Files	Coverage Δ
...io/opentelemetry/sdk/common/export/MemoryMode.java	`100.00% <100.00%> (ø)`
...entelemetry/sdk/metrics/export/MetricExporter.java	`100.00% <100.00%> (ø)`
...opentelemetry/sdk/metrics/export/MetricReader.java	`100.00% <100.00%> (ø)`
...metry/sdk/metrics/export/PeriodicMetricReader.java	`85.91% <100.00%> (+0.20%)`	⬆️
...trics/internal/aggregator/DoubleSumAggregator.java	`100.00% <100.00%> (ø)`
...metrics/internal/aggregator/LongSumAggregator.java	`100.00% <100.00%> (ø)`
...ry/sdk/metrics/internal/export/MetricProducer.java	`50.00% <ø> (ø)`
...ry/sdk/metrics/internal/state/ArrayBasedStack.java	`100.00% <100.00%> (ø)`
...rics/internal/state/AsynchronousMetricStorage.java	`98.92% <100.00%> (+7.49%)`	⬆️
...k/metrics/internal/state/ImmutableMeasurement.java	`100.00% <100.00%> (ø)`
... and 12 more

... and 1 file with indirect coverage changes

📢 Thoughts on this report? Let us know!.

asafm added 11 commits July 23, 2023 15:19

With pool that is based on array

cb35698

Async now work at 99.8% less memory allocations

cd5a0f7

Working code, with beautified code (almost all) and less code in Pool…

216a6f5

…edHashMap

Code looks good. Next are tests

8639239

Unit tests done

7c7507d

jmh test almost ready with prototype

01d2215

test/code is ready

e8ac068

Merge remote-tracking branch 'origin/main' into memory-allocations-async

bcc1a73

# Conflicts: # sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java

Fixed all Gradle check task errors

d667889

Small rename

8cce0c4

Removed JOL. Added javadocs.

501f819

asafm requested a review from a team as a code owner August 13, 2023 14:18

Removed draft code

0ecb4ec

jack-berg reviewed Aug 21, 2023

View reviewed changes

asafm and others added 11 commits August 27, 2023 16:59

Update sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/…

93f25eb

…MemoryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/…

4aea7c9

…MetricExporter.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/export/…

01513f3

…MetricReader.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/interna…

25ced28

…l/state/ObjectPool.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Added internal warning

4a35ccd

Change naming of ImmutableMeasurement factory method to be consistent…

52278e6

… with other factory methods

Making code more readable with 2 with* methods on Measurement

d14f275

Making code more readable with replacing switch with if for memory mode

62a71bd

PR fixes, including perf improvement.

6648c7c

PR fixes

031f2c2

More PR fixes

6093c38

mateuszrzeszutek reviewed Aug 29, 2023

View reviewed changes

asafm added 3 commits August 30, 2023 11:45

Merging

e2a9007

Merge remote-tracking branch 'origin/main' into memory-allocations-async

098ca71

spotless fixes

a7a481e

More PR fixes

8e52652

mateuszrzeszutek reviewed Sep 6, 2023

View reviewed changes

...ics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/AsynchronousMetricStorage.java Show resolved Hide resolved

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/MutableMeasurement.java Outdated Show resolved Hide resolved

jack-berg reviewed Sep 12, 2023

View reviewed changes

...ava/io/opentelemetry/sdk/metrics/internal/state/AsynchronousCounterMemoryUsageBenchmark.java Outdated Show resolved Hide resolved

jack-berg reviewed Sep 12, 2023

View reviewed changes

...testing/src/main/java/io/opentelemetry/sdk/testing/exporter/InMemoryMetricReaderBuilder.java Outdated Show resolved Hide resolved

jack-berg reviewed Sep 12, 2023

View reviewed changes

asafm added 3 commits September 21, 2023 17:47

More PR fixes

cfbf50c

Trying to see if this fixes failure of AsynchronousMetricStorageGarba…

59c713e

…geCollectionBenchmarkTest

Merge remote-tracking branch 'origin/main' into memory-allocations-async

ea04e14

jack-berg approved these changes Sep 22, 2023

View reviewed changes

asafm and others added 7 commits September 26, 2023 11:56

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

0e3f1c1

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

5b2f3ba

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

87c9073

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

4964d6a

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

b6f1ef6

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

Update sdk/common/src/main/java/io/opentelemetry/sdk/common/export/Me…

52582d8

…moryMode.java Co-authored-by: jack-berg <34418638+jack-berg@users.noreply.github.com>

style check fixes

8cf00ba

asafm added 2 commits September 26, 2023 20:24

Add API changes and improved instructions a bit

0d09946

MD fixes

b5378c5

jack-berg merged commit b0c337b into open-telemetry:main Sep 26, 2023
18 checks passed

asafm deleted the memory-allocations-async branch September 26, 2023 18:44

asafm mentioned this pull request Sep 28, 2023

Support large number of metric data points by reducing memory allocation #5105

Closed

jack-berg mentioned this pull request Sep 28, 2023

Reuse MetricData #5178

Closed

asafm mentioned this pull request Jan 3, 2024

[PIP-264] Parent issue for implementation apache/pulsar#21121

Open

57 tasks

asafm mentioned this pull request Apr 1, 2024

REQUEST: New membership for asafm open-telemetry/community#2029

Closed

6 tasks

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Memory Mode support: Adding memory mode, and implementing it for Asynchronous Instruments #5709

Memory Mode support: Adding memory mode, and implementing it for Asynchronous Instruments #5709

asafm commented Aug 13, 2023 •

edited

asafm commented Aug 14, 2023

jack-berg left a comment

mateuszrzeszutek Aug 29, 2023

jkwatson commented Sep 5, 2023

jack-berg left a comment

jack-berg commented Sep 22, 2023

asafm commented Sep 26, 2023

jack-berg commented Sep 26, 2023

asafm commented Sep 26, 2023

codecov bot commented Sep 26, 2023

Memory Mode support: Adding memory mode, and implementing it for Asynchronous Instruments #5709

Memory Mode support: Adding memory mode, and implementing it for Asynchronous Instruments #5709

Conversation

asafm commented Aug 13, 2023 • edited

Epic

The problem

The solution

What does this PR include?

Data structures for reusable objects

Storage

Benchmark tests

Garbage Collection (memory allocation) benchmark

Memory usage benchmark

opentelemetry-sdk-metrics.txt

opentelemetry-sdk-testing.txt

Future PRs

asafm commented Aug 14, 2023

jack-berg left a comment

Choose a reason for hiding this comment

mateuszrzeszutek Aug 29, 2023

Choose a reason for hiding this comment

jkwatson commented Sep 5, 2023

jack-berg left a comment

Choose a reason for hiding this comment

jack-berg commented Sep 22, 2023

asafm commented Sep 26, 2023

jack-berg commented Sep 26, 2023

asafm commented Sep 26, 2023

codecov bot commented Sep 26, 2023

Codecov Report

asafm commented Aug 13, 2023 •

edited

`opentelemetry-sdk-metrics.txt`

`opentelemetry-sdk-testing.txt`