This is an automated email from the ASF dual-hosted git repository.
hapylestat pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new ad5abae [AMBARI-25315][AMBARI-25211] Fix the logic on constucting
JDBC URL for Spark2 thrift server alert (#3021)
ad5abae is described below
commit ad5abae4392822736b130a9577037d2714a829cd
Author: Jungtaek Lim <[email protected]>
AuthorDate: Mon Jun 24 17:15:13 2019 +0900
[AMBARI-25315][AMBARI-25211] Fix the logic on constucting JDBC URL for
Spark2 thrift server alert (#3021)
[AMBARI-25315] Fix the logic on constucting JDBC URL for Spark2 thrift
server alert (Jungtaek Lim via dgrinenko)
---
.../scripts/alerts/alert_spark2_thrift_port.py | 19 ++++++++-----------
1 file changed, 8 insertions(+), 11 deletions(-)
diff --git
a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/alerts/alert_spark2_thrift_port.py
b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/alerts/alert_spark2_thrift_port.py
index dbbbabf..92d5ef3 100644
---
a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/alerts/alert_spark2_thrift_port.py
+++
b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/alerts/alert_spark2_thrift_port.py
@@ -147,22 +147,19 @@ def execute(configurations={}, parameters={},
host_name=None):
if host_name is None:
host_name = socket.getfqdn()
+ beeline_url = ["jdbc:hive2://{host_name}:{port}/default",
"transportMode={transport_mode}"]
if security_enabled:
+ beeline_url.append("principal={hive_principal}")
+ if transport_mode == "http":
+ beeline_url.append("httpPath=cliservice")
if spark_ssl_enabled:
- beeline_url =
['"jdbc:hive2://{host_name}:{port}/default;principal={hive_principal};transportMode={transport_mode};ssl=true;sslTrustStore={spark_truststore_path};trustStorePassword={spark_truststore_pass!p};httpPath=cliservice"']
- else:
- beeline_url =
["jdbc:hive2://{host_name}:{port}/default;principal={hive_principal}","transportMode={transport_mode}"]
- else:
- if spark_ssl_enabled:
- beeline_url =
['"jdbc:hive2://{host_name}:{port}/default;transportMode={transport_mode};ssl=true;sslTrustStore={spark_truststore_path};trustStorePassword={spark_truststore_pass!p};httpPath=cliservice"']
- else:
- beeline_url =
["jdbc:hive2://{host_name}:{port}/default","transportMode={transport_mode}"]
-
+ beeline_url.extend(["ssl=true",
"sslTrustStore={spark_truststore_path}",
"trustStorePassword={spark_truststore_pass!p}"])
+
# append url according to used transport
beeline_cmd = os.path.join(spark_home, "bin", "beeline")
- cmd = "! beeline -u %s -e '' 2>&1| awk '{print}'|grep -i -e
'Connection refused' -e 'Invalid URL'" % \
- (format(" ".join(beeline_url)))
+ cmd = "! beeline -u '%s' -e '' 2>&1| awk '{print}'|grep -i -e
'Connection refused' -e 'Invalid URL'" % \
+ (format(";".join(beeline_url)))
start_time = time.time()
try:
