Commit e97edd61f253a9a15a5808c47afb28af9fed3155
1 parent
aee7e09c
Fix cassandra timeseries dao install mode
Showing
1 changed file
with
7 additions
and
7 deletions
@@ -108,13 +108,13 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD | @@ -108,13 +108,13 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD | ||
108 | super.startExecutor(); | 108 | super.startExecutor(); |
109 | if (!isInstall()) { | 109 | if (!isInstall()) { |
110 | getFetchStmt(Aggregation.NONE, DESC_ORDER); | 110 | getFetchStmt(Aggregation.NONE, DESC_ORDER); |
111 | - Optional<NoSqlTsPartitionDate> partition = NoSqlTsPartitionDate.parse(partitioning); | ||
112 | - if (partition.isPresent()) { | ||
113 | - tsFormat = partition.get(); | ||
114 | - } else { | ||
115 | - log.warn("Incorrect configuration of partitioning {}", partitioning); | ||
116 | - throw new RuntimeException("Failed to parse partitioning property: " + partitioning + "!"); | ||
117 | - } | 111 | + } |
112 | + Optional<NoSqlTsPartitionDate> partition = NoSqlTsPartitionDate.parse(partitioning); | ||
113 | + if (partition.isPresent()) { | ||
114 | + tsFormat = partition.get(); | ||
115 | + } else { | ||
116 | + log.warn("Incorrect configuration of partitioning {}", partitioning); | ||
117 | + throw new RuntimeException("Failed to parse partitioning property: " + partitioning + "!"); | ||
118 | } | 118 | } |
119 | } | 119 | } |
120 | 120 |