@@ -827,12 +827,12 @@ def monitor_parcel(parcel_product, parcel_version, target_stage):
827
827
parcel_api .start_download_command (cluster_name , parcel_product , parcel_version )
828
828
target_stage = 'DOWNLOADED'
829
829
monitor_parcel (parcel_product , parcel_version , target_stage )
830
- print ("%s parcel %s version %s on cluster %s" % (target_stage , parcel_product , parcel_version , cluster_name ))
830
+ print ("\n %s parcel %s version %s on cluster %s" % (target_stage , parcel_product , parcel_version , cluster_name ))
831
831
print ("Starting Distribution for %s - %s" % (parcel_product , parcel_version ))
832
832
parcel_api .start_distribution_command (cluster_name , parcel_product , parcel_version )
833
833
target_stage = 'DISTRIBUTED'
834
834
monitor_parcel (parcel_product , parcel_version , target_stage )
835
- print ("%s parcel %s version %s on cluster %s" % (target_stage , parcel_product , parcel_version , cluster_name ))
835
+ print ("\n %s parcel %s version %s on cluster %s" % (target_stage , parcel_product , parcel_version , cluster_name ))
836
836
print ("Activating Parcel %s" % parcel_product )
837
837
parcel_api .activate_command (cluster_name , parcel_product , parcel_version )
838
838
@@ -2500,9 +2500,12 @@ def build_cloudera_cluster():
2500
2500
print ('Exception calling ClustersResourceApi -> first_run {}\n ' .format (e ))
2501
2501
active_command = 'First Run on ' + cluster_name
2502
2502
wait_for_active_cluster_commands (active_command )
2503
- print ('---> CLUSTER SETUP COMPLETE <---' )
2504
- deployment_seconds = time .time () - start_time
2505
- print ('SETUP TIME: %s ' % str (datetime .timedelta (seconds = deployment_seconds )))
2503
+ if secure_cluster == 'True' :
2504
+ pass
2505
+ else :
2506
+ print ('---> CLUSTER SETUP COMPLETE <---' )
2507
+ deployment_seconds = time .time () - start_time
2508
+ print ('SETUP TIME: %s ' % str (datetime .timedelta (seconds = deployment_seconds )))
2506
2509
2507
2510
2508
2511
def enable_kerberos ():
@@ -2543,9 +2546,6 @@ def enable_kerberos():
2543
2546
quorum_auth_enable_sasl = [cm_client .ApiConfig (name = 'quorum_auth_enable_sasl' , value = 'true' )]
2544
2547
update_service_config (service_name = 'ZOOKEEPER' , api_config_items = enableSecurity )
2545
2548
update_service_config (service_name = 'ZOOKEEPER' , api_config_items = quorum_auth_enable_sasl )
2546
- # print('-->Generate Kerberos Credentials')
2547
- # generate_kerberos_credentials()
2548
- # wait_for_active_mgmt_commands('Generating Missing Kerberos Credentials')
2549
2549
print ('-->Stop Cluster Services' )
2550
2550
cluster_action ('stop_command' )
2551
2551
wait_for_active_cluster_service_commands ('Stopping Cluster Services' )
@@ -2556,9 +2556,6 @@ def enable_kerberos():
2556
2556
print ('-->Deploy Cluster Kerberos Configuration' )
2557
2557
cluster_action ('deploy_cluster_client_config' )
2558
2558
wait_for_active_cluster_service_commands ('Deploying Cluster Kerberos Client Config' )
2559
- # print('-->Generate Kerberos Credentials')
2560
- # generate_kerberos_credentials()
2561
- # wait_for_active_mgmt_commands('Generating Missing Kerberos Credentials')
2562
2559
print ('-->Start Cluster Services' )
2563
2560
cluster_action ('start_command' )
2564
2561
wait_for_active_cluster_service_commands ('Starting Cluster Services' )
@@ -2569,6 +2566,9 @@ def enable_kerberos():
2569
2566
if debug == 'True' :
2570
2567
print ('->Listing Kerberos Principals' )
2571
2568
get_kerberos_principals ()
2569
+ print ('---> SECURE CLUSTER SETUP COMPLETE <---' )
2570
+ deployment_seconds = time .time () - start_time
2571
+ print ('SETUP TIME: %s ' % str (datetime .timedelta (seconds = deployment_seconds )))
2572
2572
2573
2573
2574
2574
#
0 commit comments