fix rollover

Signed-off-by: Pavol Loffay <p.loffay@gmail.com>
jaegertracing · Aug 11, 2021 · e9b5bdb · e9b5bdb
1 parent dd7664c
commit e9b5bdb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/plugin/storage/es/esRollover.py b/plugin/storage/es/esRollover.py
@@ -239,7 +239,11 @@ def get_request_session(username, password, tls, ca, cert, key, skipHostVerify):
 def get_version(client):
     esVersion = os.getenv('ES_VERSION')
     if esVersion is None or esVersion == '':
-        esVersion = client.info()['version']['number'][0]
+        pingResult = client.info()
+        if "OpenSearch" in pingResult['tagline'] and pingResult['version']['number'][0] == '1':
+            print('Detected openSearch Version {}'.format(pingResult['version']))
+            return 7
+        esVersion = pingResult['version']['number'][0]
         print('Detected ElasticSearch Version {}'.format(esVersion))
         esVersion = int(esVersion)
     return esVersion