This commit is contained in:
Stephane Nicoll 2020-03-29 18:44:48 +02:00
parent 5ad4de184d
commit a7e8829560
1 changed files with 1 additions and 2 deletions

View File

@ -57,8 +57,7 @@ public class CassandraHealthIndicator extends AbstractHealthIndicator {
@Override
protected void doHealthCheck(Health.Builder builder) throws Exception {
SimpleStatement select = SimpleStatement.newInstance("SELECT release_version FROM system.local");
ResultSet results = this.cassandraOperations.getCqlOperations().queryForResultSet(select);
ResultSet results = this.cassandraOperations.getCqlOperations().queryForResultSet(SELECT);
if (results.isFullyFetched()) {
builder.up();
return;