GEOMESA-3442 Accumulo - Fix spurious warnings when table creation is …

…slow (#3268)
locationtech · Jan 31, 2025 · 9e427b3 · 9e427b3
1 parent 6beee21
commit 9e427b3
Showing 1 changed file with 10 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,13 +157,17 @@ object TableManager {
       tableCache.get(table, _ => {
         withLock(tablePath(table), timeoutMillis, {
           val tableOps = client.tableOperations()
-          while (!tableOps.exists(table)) {
+          if (!tableOps.exists(table)) {
             try {
               tableOps.create(table, new NewTableConfiguration().setTimeType(timeType))
               created = true
             } catch {
               case _: TableExistsException => onTableExists(table)
             }
+            val start = System.currentTimeMillis()
+            while (!tableOps.exists(table) && System.currentTimeMillis() - start < timeoutMillis) {
+              Thread.sleep(10)
+            }
           }
         })
         java.lang.Boolean.FALSE
@@ -182,10 +186,14 @@ object TableManager {
       nsCache.get(ns, _ => {
         withLock(nsPath(ns), timeoutMillis, {
           val nsOps = client.namespaceOperations
-          while (!nsOps.exists(ns)) {
+          if (!nsOps.exists(ns)) {
             try { nsOps.create(ns) } catch {
               case _: NamespaceExistsException => onNamespaceExists(ns)
             }
+            val start = System.currentTimeMillis()
+            while (!nsOps.exists(ns) && System.currentTimeMillis() - start < timeoutMillis) {
+              Thread.sleep(10)
+            }
           }
         })
         java.lang.Boolean.FALSE