The change adds deprecation notice and updates Readme file.
Also include links to Storyboard, and notes on configuration.
Story: 2005628
Task: 30881
Change-Id: I0d7ae536d02db4bbcb155ad3a5d0b84761a31594
Cassandra Time to Live (TTL) is applied per-column in a
row, and with a default TTL for the table. The Cassandra
driver appears to have been written with a misunderstanding
that the TTL was per-row, and as a result the update
statements were written to avoid writing all cells.
But that results in some cells in the row not being updated,
and after their TTL expires they are removed, so a metric
query may result in partial data (updated_at set but
metric_id and created_at missing).
This fix changes the statement used when a new measurement
is received to use the same insert statement for the metric
row and thus refresh the TTL for all the columns.
A follow on patch should be created to remove the Update
statements for Measurements, and consider refactoring/removing
the caching model.
Change-Id: I6b7636a52e8bdb2ce8ad97f839acb6184cd58a8b
Story: 2005832
Task: 35872
This is a workaround for Maven build failures due to bugs in openjdk-8
and surefire plugin until these packages are fixed.
Change-Id: I9115a3567cc1ca7fc59d05e3b74171c031460065
Story: 2004256
Task: 27809
This commit adds defaults for configuration settings where
that makes sense so they can be omitted. Likewise, unknown
settings will now be ignored everywhere except for the
database sections (the relevant configuration classes for that
are in monasca-common).
Change-Id: I35ae02e44a11e088c36943d8c053aac07dbe7524
Story: 2001415
Task: 6115
Increases pom version to 1.3.0 after adding cassandra integration.
Depends-On: I0c6c1d027362a0babb5d7a5473c93afc3a72bb09
Change-Id: I1f8ec63e33b8949e477afbd6a8f70f4f26b18ed7
If value meta length is larger than the size of the Vertica column,
the write will fail and cause the persister to die. Check the length
and drop the value meta if too large. This should not occur as the
value meta is validated by the API before being written to Kafka,
but this is a cheap check and ensures the persister will stay up if
some application starts writing directly to the Kafka queue
Change-Id: I893d02751217beb6ba5a88625f20448c45a1b376
Refactor code to handle errors better. Persister shuts down faster
and more reliably.
On shutdown, messages in buffer will be dropped. On restart,
messages will be read from Kafka and processed again.
Fixes problem with persister not shutting down and restarting
when a vertica node goes down.
Change-Id: I60b4ba6e06e69e68878f8400e360250e3608e5a5
Always store {} when value_meta is empty for Influxdb.
Needed because the Java Influxdb driver is
capable of storing an empty string, but the
Python Influxdb driver is not.
Change-Id: Id6b7b795454afc1a4ab2e6230c6a9d3bd94790f7
Bring contents of the example config and the mini-mon config into
line, add a note on log formatting, and a note in the README about
the sample configurations.
Change-Id: I47794b600d44a87f58825d1e11099c272f06d7aa
Make persister fail faster on errors.
Use one executor service for all perister threads.
Shutdown all threads in thread executor service on any error.
Catch java.lang.Throwable to catch java.lang.Error as well as java.lang.Exception.
Change-Id: I0dc421cf6bb4ab3f52c47e97b7f396483283b561
Check all fields that could be null and convert them to empty strings or empty JSON.
Drop events that have null tenant ids or null regions.
Change-Id: I1a0113d9dc1cd9a2662c0dd3e11ce9187c59ab4e
change 'name' to 'measurement'.
Accept 200 or 204 return on writes.
change 'timestamp' to 'time'.
add precision.
Change-Id: I4f485b6b2b88db75a86b3822fd46eeea04e5e028
Make methods protected.
Extract methods.
Clean up mixed-case in logging.
Remove unnecessary try-catch block.
Remove extra classes.
Consolidate methods in abstract class.
Change-Id: I6a8064998a2a474c9c51e4ea641387c69142fdd7
Witek Bedyk