Skip to content

Commit 6ada4fc

Browse files
committed
Minor improvement to ES MetricsConsumer
1 parent 83ea36f commit 6ada4fc

File tree

1 file changed

+4
-3
lines changed
  • external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/metrics

1 file changed

+4
-3
lines changed

external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/metrics/MetricsConsumer.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,10 +134,11 @@ private void handleDataPoints(final TaskInfo taskInfo,
134134
* @return elastic index name
135135
*/
136136
private String getIndexName(Date timestamp) {
137+
if (dateFormat == null)
138+
return indexName;
139+
137140
StringBuilder sb = new StringBuilder(indexName);
138-
if (dateFormat != null) {
139-
sb.append("-").append(dateFormat.format(timestamp));
140-
}
141+
sb.append("-").append(dateFormat.format(timestamp));
141142
return sb.toString();
142143
}
143144

0 commit comments

Comments
 (0)