GEOMESA-3388 Add retry on Accumulo table creation (#3159)

locationtech · Aug 28, 2024 · 2b5f12d · 2b5f12d
1 parent e509c37
commit 2b5f12d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...cumulo-datastore/src/main/scala/org/locationtech/geomesa/accumulo/util/TableManager.scala b/...cumulo-datastore/src/main/scala/org/locationtech/geomesa/accumulo/util/TableManager.scala
@@ -157,7 +157,7 @@ object TableManager {
       tableCache.get(table, _ => {
         withLock(tablePath(table), timeoutMillis, {
           val tableOps = client.tableOperations()
-          if (!tableOps.exists(table)) {
+          while (!tableOps.exists(table)) {
             try {
               tableOps.create(table, new NewTableConfiguration().setTimeType(timeType))
               created = true
@@ -182,7 +182,7 @@ object TableManager {
       nsCache.get(ns, _ => {
         withLock(nsPath(ns), timeoutMillis, {
           val nsOps = client.namespaceOperations
-          if (!nsOps.exists(ns)) {
+          while (!nsOps.exists(ns)) {
             try { nsOps.create(ns) } catch {
               case _: NamespaceExistsException => onNamespaceExists(ns)
             }