From 062cae2e18f431503e588b43016268740c570891 Mon Sep 17 00:00:00 2001
From: YevhenBondarenko <ybondarenko@thingsboard.io>
Date: Mon, 3 Aug 2020 16:49:46 +0300
Subject: [PATCH] Cassandra ts latest improvements

---
 .../migrate/CassandraTsLatestToSqlMigrateService.java      | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/application/src/main/java/org/thingsboard/server/service/install/migrate/CassandraTsLatestToSqlMigrateService.java b/application/src/main/java/org/thingsboard/server/service/install/migrate/CassandraTsLatestToSqlMigrateService.java
index ab22e3748c..1e996d3b01 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/migrate/CassandraTsLatestToSqlMigrateService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/migrate/CassandraTsLatestToSqlMigrateService.java
@@ -55,6 +55,8 @@ import static org.thingsboard.server.service.install.migrate.CassandraToSqlColum
 @Slf4j
 public class CassandraTsLatestToSqlMigrateService implements TsLatestMigrateService {
 
+    private static final int LATEST_KEY_LENGTH = 255;
+
     @Autowired
     private EntityDatabaseSchemaService entityDatabaseSchemaService;
 
@@ -168,6 +170,11 @@ public class CassandraTsLatestToSqlMigrateService implements TsLatestMigrateServ
     }
 
     protected Integer getOrSaveKeyId(String strKey) {
+        if (strKey.length() > LATEST_KEY_LENGTH) {
+            log.warn("Key is long. Max key length is 255\n{}", strKey);
+            strKey = strKey.substring(0, LATEST_KEY_LENGTH);
+        }
+
         Integer keyId = tsKvDictionaryMap.get(strKey);
         if (keyId == null) {
             Optional<TsKvDictionary> tsKvDictionaryOptional;