forked from sburn/docker-apache-atlas
-
Notifications
You must be signed in to change notification settings - Fork 0
/
atlas_start.py.patch
62 lines (57 loc) · 2.13 KB
/
atlas_start.py.patch
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
--- atlas_start.py.orig 2019-05-03 08:22:00.000000000 +0300
+++ atlas_start.py 2020-01-16 01:37:16.147611498 +0300
@@ -18,6 +18,9 @@
import os
import sys
import traceback
+import os.path
+import time
+from time import sleep
import atlas_config as mc
@@ -114,6 +117,9 @@
mc.configure_hbase(atlas_home)
mc.run_hbase_action(mc.hbaseBinDir(atlas_home), "start", hbase_conf_dir, logdir)
print "hbase started."
+ if is_setup:
+ print "Sleeping 60s due too setup (init run)..."
+ sleep(60)
#solr setup
if mc.is_solr_local(confdir):
@@ -128,6 +134,9 @@
mc.run_solr(mc.solrBinDir(atlas_home), "start", mc.get_solr_zk_url(confdir), mc.solrPort(), logdir)
print "solr started."
+ if is_setup:
+ print "Sleeping 60s due too setup (init run)..."
+ sleep(60)
print "setting up solr collections..."
mc.create_solr_collection(mc.solrBinDir(atlas_home), mc.solrConfDir(atlas_home), "vertex_index", logdir)
@@ -145,8 +154,27 @@
web_app_path = mc.convertCygwinPath(web_app_path)
if not is_setup:
start_atlas_server(atlas_classpath, atlas_pid_file, jvm_logdir, jvm_opts_list, web_app_path)
- mc.wait_for_startup(confdir, 300)
- print "Apache Atlas Server started!!!\n"
+ mc.wait_for_startup(confdir, 600)
+ print "Apache Atlas Server process started!\n"
+
+ atlas_pid_file = mc.pidFile(atlas_home)
+ try:
+ pf = file(atlas_pid_file, 'r')
+ pid = int(pf.read().strip())
+ pf.close()
+ print("Running Apache Atlas with PID " + str(pid) + "...\n")
+ except:
+ pid = None
+ if not pid:
+ sys.stderr.write("No PID file found! Server is not running?\nCheck logs: /opt/apache-atlas-2.1.0/logs/application.log\n\n")
+ return
+
+
+ while os.path.exists(atlas_pid_file):
+ time.sleep(1)
+
+ print "Apache Atlas stopped!\n"
+
else:
process = mc.java("org.apache.atlas.web.setup.AtlasSetup", [], atlas_classpath, jvm_opts_list, jvm_logdir)
return process.wait()