Fix cassandra database upgrade service.

Igor Kulikov
1 parent 7e0871d5
Showing 1 changed file with 2 additions and 0 deletions
application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
--- a/application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
View file @19e32dd
+++ b/application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
View file @19e32dd
@@ -66,6 +66,8 @@ public class CassandraDatabaseUpgradeService implements DatabaseUpgradeService {
 
                 //Dump devices, assets and relations
 
+                cluster.getSession();
+
                 KeyspaceMetadata ks = cluster.getCluster().getMetadata().getKeyspace(cluster.getKeyspaceName());
 
                 log.info("Dumping devices ...");