Merge "Store {} when value_meta is empty"
This commit is contained in:
commit
d9436392e9
@ -95,9 +95,9 @@ public class InfluxV9MetricRepo extends InfluxMetricRepo {
|
||||
|
||||
String valueMetaJSONString = measurement.getValueMetaJSONString();
|
||||
|
||||
if (valueMetaJSONString == null) {
|
||||
if (valueMetaJSONString == null || valueMetaJSONString.isEmpty()) {
|
||||
|
||||
valueMap.put("value_meta", "");
|
||||
valueMap.put("value_meta", "{}");
|
||||
|
||||
} else {
|
||||
|
||||
|
@ -535,7 +535,7 @@ class MetricPersister(AbstractPersister):
|
||||
|
||||
else:
|
||||
|
||||
value_meta = ''
|
||||
value_meta = {}
|
||||
|
||||
LOG.debug('value_meta: %s', value_meta)
|
||||
|
||||
@ -551,8 +551,7 @@ class MetricPersister(AbstractPersister):
|
||||
"fields": {
|
||||
"value": value,
|
||||
"value_meta": json.dumps(value_meta,
|
||||
ensure_ascii=False).encode(
|
||||
'utf8') if value_meta else value_meta.encode('utf8')
|
||||
ensure_ascii=False).encode('utf8')
|
||||
},
|
||||
"tags": tags}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user