A scalable, distributed Time Series Database.

I've hit too many open files, digging into this:

[root@ny-devtsdb04 fd]# ps aux | grep opentsdb.conf
root      2076  3.8  1.5 5489036 260496 pts/0  Sl   Mar21  61:23 java -enableassertions -enablesystemassertions -classpath /usr/local/share/opentsdb/asynchbase-1.4.1.jar:/usr/local/share/opentsdb/guava-13.0.1.jar:/usr/local/share/opentsdb/jackson-annotations-2.2.3.jar:/usr/local/share/opentsdb/jackson-core-2.2.3.jar:/usr/local/share/opentsdb/jackson-databind-2.2.3.jar:/usr/local/share/opentsdb/log4j-over-slf4j-1.7.2.jar:/usr/local/share/opentsdb/logback-classic-1.0.9.jar:/usr/local/share/opentsdb/logback-core-1.0.9.jar:/usr/local/share/opentsdb/netty-3.6.2.Final.jar:/usr/local/share/opentsdb/slf4j-api-1.7.2.jar:/usr/local/share/opentsdb/suasync-1.4.0.jar:/usr/local/share/opentsdb/tsdb-2.0.0.jar:/usr/local/share/opentsdb/zookeeper-3.3.6.jar:/usr/local/share/opentsdb net.opentsdb.tools.TSDMain --port=4242 --staticroot=build/staticroot --cachedir=/tmp/tsd --zkquorum=ny-devtsdb01,ny-devtsdb03,ny-devtsdb04 --config /root/dev/opentsdb.conf
root     23362  0.0  0.0 103256   872 pts/0    S+   17:32   0:00 grep opentsdb.conf
[root@ny-devtsdb04 fd]# ls -l /proc/2076/fd | grep socket | wc -l
4049
[root@ny-devtsdb04 fd]# netstat -ap | grep 2076 | wc -l
6
[root@ny-devtsdb04 fd]# lsof -p 2076 | grep sock | head
java    2076 root   17u  sock                0,6      0t0 13372319 can't identify protocol
java    2076 root   49u  sock                0,6      0t0 13394689 can't identify protocol
java    2076 root   50u  sock                0,6      0t0 13394637 can't identify protocol
java    2076 root   51u  sock                0,6      0t0 13395575 can't identify protocol
java    2076 root   52u  unix 0xffff880437c5a0c0      0t0 12977998 socket
java    2076 root   53u  sock                0,6      0t0 12977996 can't identify protocol
java    2076 root   54u  sock                0,6      0t0 13394738 can't identify protocol
java    2076 root   56u  sock                0,6      0t0 13395172 can't identify protocol
java    2076 root   57u  sock                0,6      0t0 13394785 can't identify protocol
java    2076 root   58u  sock                0,6      0t0 13376378 can't identify protocol

I was doing some maintenance the other day on my hbase cluster and restarting region servers, so maybe when stuff "disappears" in the cluster they don't get closed properly?

(Still need to update async base, maybe that is part of it..?)

Aligned the start time of downsampling by the given downsampling interval so that the same set of data points belongs to the same downsampling period regardless of the start time of a user-requested time range.

• Made the start time of a downsampling period its representative timestamp without computing the average of the timestamps of the data points of the period.
• Factored downsampling code out from Span.java to its own class to make it easier to write unit tests.
• Made the type of downsampling result double regardless of the original type to get rid of the loop that checked the type of the raw input data points. By using double, we could handle very small integers and very big integers within a reasonable error margin. Some values are too small to round off. For example, the integer average of four values (2, 2, 2, 1) is 1, which is far from the real average of 1.75. Some values are so big that it could cause long-integer overflow while downsampling.

Grabbed source tarball from https://github.com/OpenTSDB/opentsdb/releases/download/v2.2.0/opentsdb-2.2.0.tar.gz and extracted, and went to that dir.

There's lots of output when I try and build opentsdb, but I think the most relevant error is: No rule to make target 'net/opentsdb/core/AggregationIterator.class', needed by 'tsdb-2.2.0.jar'. Stop.

Full output

bash-4.3$ ./build.sh 
+ test -f configure
+ test -d build
+ mkdir build
+ cd build
+ test -f Makefile
+ ../configure
checking for a BSD-compatible install... /usr/bin/install -c
checking whether build environment is sane... yes
checking for a thread-safe mkdir -p... ../build-aux/install-sh -c -d
checking for gawk... no
checking for mawk... no
checking for nawk... no
checking for awk... awk
checking whether make sets $(MAKE)... yes
checking whether make supports nested variables... yes
checking for md5sum... no
checking for md5... /sbin/md5
checking for java... /Library/Java/JavaVirtualMachines/jdk1.8.0_72.jdk/Contents/Home/bin/java
checking for javac... /Library/Java/JavaVirtualMachines/jdk1.8.0_72.jdk/Contents/Home/bin/javac
checking for jar... /Library/Java/JavaVirtualMachines/jdk1.8.0_72.jdk/Contents/Home/bin/jar
checking for true... /usr/bin/true
checking for javadoc... /Library/Java/JavaVirtualMachines/jdk1.8.0_72.jdk/Contents/Home/bin/javadoc
checking for wget... no
checking for curl... /usr/bin/curl
checking that generated files are newer than configure... done
configure: creating ./config.status
config.status: creating Makefile
config.status: creating opentsdb.spec
config.status: creating build-aux/fetchdep.sh
+ MAKE=make
++ uname -s
+ '[' Darwin = FreeBSD ']'
+ exec make
../build-aux/gen_build_data.sh src/tools/BuildData.java net.opentsdb.tools 2.2.0
Generating src/tools/BuildData.java
fatal: Not a git repository (or any of the parent directories): .git
fatal: Not a git repository (or any of the parent directories): .git
/Applications/Xcode.app/Contents/Developer/usr/bin/make  all-am
rm -f tsdb tsdb.tmp
script=tsdb; pkgdatadir=''; \
          abs_srcdir='/private/tmp/opentsdb20160224-99228-12y38mp/opentsdb-2.2.0/build/..'; abs_builddir='/private/tmp/opentsdb20160224-99228-12y38mp/opentsdb-2.2.0/build'; \
          srcdir=''; test -f ./$script.in || srcdir=../; sed -e "s:@pkgdatadir[@]:$pkgdatadir:g" -e "s:@abs_srcdir[@]:$abs_srcdir:g" -e "s:@abs_builddir[@]:$abs_builddir:g" -e "s:@configdir[@]:$configdir:g" ${srcdir}$script.in >$script.tmp
make[1]: *** No rule to make target `net/opentsdb/core/AggregationIterator.class', needed by `tsdb-2.2.0.jar'.  Stop.
make[1]: *** Waiting for unfinished jobs....
chmod +x tsdb.tmp
chmod a-w tsdb.tmp
mv tsdb.tmp tsdb
/Library/Java/JavaVirtualMachines/jdk1.8.0_72.jdk/Contents/Home/bin/javac -Xlint -source 6 -encoding utf-8 -d . -cp ../third_party/hbase/asynchbase-1.7.1.jar:../third_party/guava/guava-18.0.jar:../third_party/slf4j/log4j-over-slf4j-1.7.7.jar:../third_party/logback/logback-classic-1.0.13.jar:../third_party/logback/logback-core-1.0.13.jar:../third_party/jackson/jackson-annotations-2.4.3.jar:../third_party/jackson/jackson-core-2.4.3.jar:../third_party/jackson/jackson-databind-2.4.3.jar:../third_party/netty/netty-3.9.4.Final.jar:../third_party/protobuf/protobuf-java-2.5.0.jar:../third_party/slf4j/slf4j-api-1.7.7.jar:../third_party/suasync/async-1.4.0.jar:../third_party/zookeeper/zookeeper-3.4.5.jar:../third_party/apache/commons-math3-3.4.1.jar:  ../src/core/AggregationIterator.java ../src/core/Aggregator.java ../src/core/Aggregators.java ../src/core/AppendDataPoints.java ../src/core/BatchedDataPoints.java ../src/core/ByteBufferList.java ../src/core/ColumnDatapointIterator.java ../src/core/CompactionQueue.java ../src/core/Const.java ../src/core/DataPoint.java ../src/core/DataPoints.java ../src/core/DataPointsIterator.java ../src/core/Downsampler.java ../src/core/DownsamplingSpecification.java ../src/core/FillingDownsampler.java ../src/core/FillPolicy.java ../src/core/IncomingDataPoint.java ../src/core/IncomingDataPoints.java ../src/core/IllegalDataException.java ../src/core/Internal.java ../src/core/MutableDataPoint.java ../src/core/Query.java ../src/core/QueryException.java ../src/core/RateOptions.java ../src/core/RateSpan.java ../src/core/RowKey.java ../src/core/RowSeq.java ../src/core/SaltScanner.java ../src/core/SeekableView.java ../src/core/Span.java ../src/core/SpanGroup.java ../src/core/TSDB.java ../src/core/Tags.java ../src/core/TsdbQuery.java ../src/core/TSQuery.java ../src/core/TSSubQuery.java ../src/core/WritableDataPoints.java ../src/graph/Plot.java ../src/meta/Annotation.java ../src/meta/TSMeta.java ../src/meta/TSUIDQuery.java ../src/meta/UIDMeta.java ../src/query/QueryUtil.java ../src/query/filter/TagVFilter.java ../src/query/filter/TagVLiteralOrFilter.java ../src/query/filter/TagVNotKeyFilter.java ../src/query/filter/TagVNotLiteralOrFilter.java ../src/query/filter/TagVRegexFilter.java ../src/query/filter/TagVWildcardFilter.java ../src/search/SearchPlugin.java ../src/search/SearchQuery.java ../src/search/TimeSeriesLookup.java ../src/stats/Histogram.java ../src/stats/StatsCollector.java ../src/stats/QueryStats.java ../src/tools/ArgP.java ../src/tools/CliOptions.java ../src/tools/CliQuery.java ../src/tools/CliUtils.java ../src/tools/DumpSeries.java ../src/tools/Fsck.java ../src/tools/FsckOptions.java ../src/tools/MetaPurge.java ../src/tools/MetaSync.java ../src/tools/Search.java ../src/tools/TSDMain.java ../src/tools/TextImporter.java ../src/tools/TreeSync.java ../src/tools/UidManager.java ../src/tree/Branch.java ../src/tree/Leaf.java ../src/tree/Tree.java ../src/tree/TreeBuilder.java ../src/tree/TreeRule.java ../src/tsd/AbstractHttpQuery.java ../src/tsd/AnnotationRpc.java ../src/tsd/BadRequestException.java ../src/tsd/ConnectionManager.java ../src/tsd/GnuplotException.java ../src/tsd/GraphHandler.java ../src/tsd/HttpJsonSerializer.java ../src/tsd/HttpSerializer.java ../src/tsd/HttpQuery.java ../src/tsd/HttpRpc.java ../src/tsd/HttpRpcPlugin.java ../src/tsd/HttpRpcPluginQuery.java ../src/tsd/LineBasedFrameDecoder.java ../src/tsd/LogsRpc.java ../src/tsd/PipelineFactory.java ../src/tsd/PutDataPointRpc.java ../src/tsd/QueryRpc.java ../src/tsd/RpcHandler.java ../src/tsd/RpcPlugin.java ../src/tsd/RpcManager.java ../src/tsd/RTPublisher.java ../src/tsd/SearchRpc.java ../src/tsd/StaticFileRpc.java ../src/tsd/StatsRpc.java ../src/tsd/StorageExceptionHandler.java ../src/tsd/SuggestRpc.java ../src/tsd/TelnetRpc.java ../src/tsd/TreeRpc.java ../src/tsd/UniqueIdRpc.java ../src/tsd/WordSplitter.java ../src/uid/FailedToAssignUniqueIdException.java ../src/uid/NoSuchUniqueId.java ../src/uid/NoSuchUniqueName.java ../src/uid/RandomUniqueId.java ../src/uid/UniqueId.java ../src/uid/UniqueIdInterface.java ../src/utils/ByteArrayPair.java ../src/utils/Config.java ../src/utils/DateTime.java ../src/utils/Exceptions.java ../src/utils/FileSystem.java ../src/utils/JSON.java ../src/utils/JSONException.java ../src/utils/Pair.java ../src/utils/PluginLoader.java ../src/utils/Threads.java ../src/tools/BuildData.java
warning: [options] bootstrap class path not set in conjunction with -source 1.6
../src/uid/UniqueId.java:197: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public long maxPossibleId() {
              ^
../src/uid/UniqueId.java:441: warning: [rawtypes] found raw type: Deferred
      final Deferred d;
            ^
  missing type arguments for generic class Deferred<T>
  where T is a type-variable:
    T extends Object declared in class Deferred
../src/core/TSSubQuery.java:237: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public Map<String, String> getTags() {
                             ^
../src/core/TSSubQuery.java:295: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public void setTags(Map<String, String> tags) {
              ^
../src/meta/TSUIDQuery.java:92: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public TSUIDQuery(final TSDB tsdb) {
         ^
../src/meta/TSUIDQuery.java:226: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public void setQuery(final String metric, final Map<String, String> tags) {
              ^
../src/meta/TSUIDQuery.java:550: warning: [dep-ann] deprecated item is not annotated with @Deprecated
  public static Deferred<IncomingDataPoint> getLastPoint(final TSDB tsdb, 
                                            ^
../src/tools/Fsck.java:809: warning: [cast] redundant cast to float
                Float.floatToRawIntBits((float)value_as_float));
                                        ^
../src/tools/Fsck.java:853: warning: [cast] redundant cast to float
                Float.floatToRawIntBits((float)value_as_float));
                                        ^
../src/tsd/AbstractHttpQuery.java:129: warning: [deprecation] getHeaders() in HttpMessage has been deprecated
        request.getHeaders().size());
               ^
../src/tsd/AbstractHttpQuery.java:130: warning: [deprecation] getHeaders() in HttpMessage has been deprecated
    for (final Entry<String, String> header : request.getHeaders()) {
                                                     ^
../src/tsd/AbstractHttpQuery.java:155: warning: [deprecation] getHeaders() in HttpMessage has been deprecated
        request.getHeaders().size());
               ^
../src/tsd/AbstractHttpQuery.java:156: warning: [deprecation] getHeaders() in HttpMessage has been deprecated
    for (final Entry<String, String> header : request.getHeaders()) {
                                                     ^
../src/tsd/AbstractHttpQuery.java:451: warning: [deprecation] toStringHelper(Object) in Objects has been deprecated
    return Objects.toStringHelper(this)
                  ^
../src/tsd/QueryRpc.java:374: warning: [deprecation] getLastPoint(TSDB,byte[],boolean,int,long) in TSUIDQuery has been deprecated
          deferreds.add(TSUIDQuery.getLastPoint(tsdb, entry.getKey(), 
                                  ^
../src/tsd/GraphHandler.java:188: warning: [rawtypes] found raw type: HashSet
    final HashSet<String>[] aggregated_tags = new HashSet[nqueries];
                                                  ^
  missing type arguments for generic class HashSet<E>
  where E is a type-variable:
    E extends Object declared in class HashSet
../src/tsd/LogsRpc.java:115: warning: [cast] redundant cast to ILoggingEvent
        final ILoggingEvent event = (ILoggingEvent) logbuf.get(nevents);
                                    ^
../src/utils/JSON.java:214: warning: [deprecation] createJsonParser(String) in JsonFactory has been deprecated
      return jsonMapper.getFactory().createJsonParser(json);
                                    ^
../src/utils/JSON.java:236: warning: [deprecation] createJsonParser(byte[]) in JsonFactory has been deprecated
      return jsonMapper.getFactory().createJsonParser(json);
                                    ^
../src/utils/JSON.java:258: warning: [deprecation] createJsonParser(InputStream) in JsonFactory has been deprecated
      return jsonMapper.getFactory().createJsonParser(json);
                                    ^
../src/utils/PluginLoader.java:69: warning: [rawtypes] found raw type: Class
  private static final Class<?>[] PARAMETER_TYPES = new Class[] {
                                                        ^
  missing type arguments for generic class Class<T>
  where T is a type-variable:
    T extends Object declared in class Class
22 warnings
make: *** [all] Error 2

Duplicate timestamps are handled automatically with last-written wins. In addition, the compaction code is cleaned up and unified - instead of having separate code paths for trivial and complex compactions, there is only one code path. However, it is faster than the trivial path was before, particularly for large rows - on my laptop, a row of 3600 1-sample values was 10-20% faster, and 3600000 1-sample values was nearly twice as fast. It is even faster compared to the previous complex path.

Hello maintainers,

I would love to contribute to OpenTSDB but setting up development environment is too complex. Is there a simpler way of setting up a local OpenTSDB environment and developing on top of it.

This would be great for the community and we can have rapid development on the project.

resetValue inside rateOptions does not seem to be working. For example with the following query I get values that exceed 10,000:

curl -X POST -H "Content-Type: application/json" -d '{"start":"2014/02/06-22:23:25","end":"2014/02/06-22:31:25","queries":[{"aggregator":"sum","metric":"haproxy.frontend.stot","rate":true,"rateOptions":{"counter":true,"resetValue":10000}}]}' http://ny-devtsdb04:4242/api/query [{"metric":"haproxy.frontend.stot","tags":{"svname":"FRONTEND"},"aggregateTags":["pxname","tier","host"],"dps":{"1391725408":1011.9333333333335,"1391725419":1012.2000000000002,"1391725423":1030.6000000000004,"1391725434":1030.5333333333335,"1391725438":986.4666666666669,"1391725439":979.2875,"1391725449":979.2875,"1391725454":943.3666666666669,"1391725469":984.7333333333333,"1391725482":-5216934.290909092,"1391725484":-5216906.624242427,"1391725497":1011.9757575757577,"1391725499":1000.3090909090909,"1391725514":1021.309090909091,"1391725523":1021.2475524475525,"1391725529":1052.047552447553,"1391725538":-789292.7583333332,"1391725544":-789342.5583333333,"1391725553":1002.5333333333334,"1391725559":992.3333333333331,"1391725568":992.1999999999999,"1391725570":992.4999999999999,"1391725574":1014.3,"1391725585":-3020989.6645833333,"1391725589":-3021003.397916666,"1391725600":1000.2,"1391725604":1047.2666666666669,"1391725615":1047.6000000000001,"1391725619":1042.4666666666667,"1391725630":1042.2,"1391725634":1018.8000000000002,"1391725645":1019.0000000000002,"1391725649":1022.9333333333336,"1391725660":1022.666666666667,"1391725664":1022.4000000000002,"1391725675":1022.8666666666669,"1391725679":1000.3333333333333,"1391725690":999.7999999999998,"1391725694":1015.9333333333335,"1391725705":1016.0000000000001,"1391725709":1049.0666666666668,"1391725710":1033.2749999999999,"1391725720":1033.8083333333334,"1391725725":964.9000000000002,"1391725735":964.7000000000003,"1391725740":1000.6666666666667,"1391725751":1000.3000000000001,"1391725755":792.7666666666669,"1391725766":3229.5333333333333,"1391725770":2439.8000000000006,"1391725781":3102.733333333334,"1391725796":3063.4000000000005,"1391725811":1604.4666666666667,"1391725826":1037.3333333333333,"1391725830":-8446318.749999998,"1391725841":-8446356.416666664,"1391725845":999.1333333333336,"1391725856":992.4000000000004,"1391725860":992.5333333333338,"1391725871":1009.4000000000005,"1391725876":1009.766666666667}}]

Note the 1391725830":-8446318.749999998,"1391725841":-8446356.416666664.

When I pass what I believe to be the same query via the web interface, it seems to be working:

#start=2014/02/06-22:23:25&end=2014/02/06-22:31:25&m=sum:rate%7Bcounter,,10000%7D:haproxy.frontend.stot&o=&yrange=%5B-1000:%5D&wxh=800x600

Am I missing some difference between the two, or is there something not working here?

Hi, when dealing with a lot of metrics (esp. tag=*) it'd be nice to be able to say "give me only the top-n entries", main reason being that even with more than an handful of metrics the graph is likely to be cluttered and having an indication of what are the top-n metrics could be useful (e.g. latency graphs to identify outliers) Not sure how easy it is to implement this however and/or it can be done on hbase side though

Please release 2.3. RC1 if possible sometime in near future. Will test query matching and expressions using Grafana with that release candidate.

Thanks

Made corresponding code changes

1. Added OpenTSDB Timestamp as HBase Cell Timestamp while writing a metric
2. For OpenTSDB compaction, it will use the maximum Timestamp out of all the stamps being compacted and use it to write for HBase Cell Timestamp.
3. Adding TS to scanner.

Similar to the last comment in #772 , since upgrading to CDH 5.7, I am getting this constantly in my logs:

org.hbase.async.RemoteException: Call queue is full on /0.0.0.0:60020, too many items queued ? org.hbase.async.RemoteException: Call queue is full on /0.0.0.0:60020, too many items queued ? Caused by: org.hbase.async.RemoteException: Call queue is full on /0.0.0.0:60020, too many items queued ?

I ran it with DEBUG, and most of the time, especially for writes, i see it selecting the correct region servers: id: 0x231245fe, /10.10.7.101:33714 => /10.10.7.36:60020] Sending RPC #26

but i can't seem to figure out why it's trying to go to 0.0.0.0 ..... and, this just cropped up when I upgraded to CDH 5.7 :/

When I run the following command: ./build/tsdb tsd --port=4242 --staticroot=build/staticroot --cachedir="/tmp/tsdtmp" --zkquorum ubuntu23

The follow errors appeared: 2014-02-13 18:19:39,545 INFO [main] ZooKeeper: Initiating client connection, connectString=ubuntu23 sessionTimeout=5000 watcher=org.hbase.async.HBaseClient$ZKClient@6adb93a2 2014-02-13 18:19:39,565 INFO [main] HBaseClient: Need to find the -ROOT- region 2014-02-13 18:19:39,570 INFO [main-SendThread(ubuntu23:2181)] ClientCnxn: Opening socket connection to server ubuntu23/10.45.33.23:2181. Will not attempt to authenticate using SASL (unknown error) 2014-02-13 18:19:39,574 INFO [main-SendThread(ubuntu23:2181)] ClientCnxn: Socket connection established to ubuntu23/10.45.33.23:2181, initiating session 2014-02-13 18:19:39,601 INFO [main-SendThread(ubuntu23:2181)] ClientCnxn: Session establishment complete on server ubuntu23/10.45.33.23:2181, sessionid = 0x442a5b00940013, negotiated timeout = 6000 2014-02-13 18:19:39,615 ERROR [main-EventThread] HBaseClient: The znode for the -ROOT- region doesn't exist! 2014-02-13 18:19:40,618 ERROR [main-EventThread] HBaseClient: The znode for the -ROOT- region doesn't exist! 2014-02-13 18:19:41,637 ERROR [main-EventThread] HBaseClient: The znode for the -ROOT- region doesn't exist! 2014-02-13 18:19:42,658 ERROR [main-EventThread] HBaseClient: The znode for the -ROOT- region doesn't exist!

I searched on internet,but I dont find any solutions.

Is there anybody met this problem?

In my company, we are using OpenTSDB. Our primary concern right now is to solve the security vulnerabilities in the software which we are using. I have listed down the vulnerable packages below. Please suggest me how to upgrade those packages to the latest version in OpenTSDB?

ch.qos.logback:logback-core commons-collections:commons-collections ch.qos.logback:logback-classic com.fasterxml.jackson.core:jackson-databind com.google.protobuf:protobuf-java org.apache.zookeeper:zookeeper org.apache.httpcomponents:httpclient net.sourceforge.htmlunit:htmlunit io.netty:netty com.google.guava:guava commons-io:commons-io commons-codec:commons-codec junit:junit

During our research at Oxeye Security, we found that OpenTSDB is vulnerable to Remote Code Execution vulnerability by writing user-controlled input to Gnuplot configuration file and running Gnuplot with the generated configuration.

As we don't want to publish zero days on the web without first contacting you, please provide us with a secure email address so we can communicate the description, reproduction steps, and more.

This vulnerability was discovered by Gal Goldshtein and Daniel Abeles.

Hi Team, I read from the documentation that opentsdb only need's hdfs and hbase. Do i really need yarn in production setup?...if i am only setting up haddop to use opentsdb do i really need yarn? why i need yarn if it is required? please can anyone explain me. Thanks and regards, Vadiraj

Issue

When using Count Downsampler in an environment where Rollup data is pre-aggregated, incorrect results are returned.

In the case of Raw data, the number of valid data that existed during the time of the Downsample target is being counted. This implementation is considered correct.

However, for Rollup data, this value should be output since pre-aggregated data already exists.

The existing implementation does not yield the correct aggregate data because Count Downsample is done in the same process as Raw data, even in cases where Rollup data is used.

Resolution

When Count Downsample is used and Rollup data is used, fixed to output the value of pre-aggregated data.

Per documentation, the argumentless SecureRandom constructor seems sufficient to seed the PRNG instance with true-random information. Thoughts?

https://docs.oracle.com/javase/8/docs/api/java/security/SecureRandom.html