Provides Hadoop2 utility functions
Function to restart hadoop services on the cluster master
This may be used if you're using a different version of Java, for example
- restart_master_services()
- restart_worker_services()
- restart_hadoop_services()
- use_java8()
- wait_until_namenode_running()
Function to restart hadoop services on the cluster master
This may be used if you're using a different version of Java, for example
restart_master_services
Function has no arguments.
Function to restart hadoop services on the cluster workers
This only restarts the datanode service since the nodemanager is started after the bootstrap is run
restart_worker_services
Function has no arguments.
Generic function to restart hadoop services
restart_hadoop_services
Function has no arguments.
Use Java 8 for hadoop daemons and jobs
By default, the hadoop daemons and jobs on Qubole clusters run on Java 7. Use this function if you would like to use Java 8. This is only required if your cluster:
- is in AWS, and
- is running Hive or Spark < 2.2
use_java8
Function has no arguments.
Wait until namenode is out of safe mode
wait_until_namenode_running 25 5
- $1 (int): Number of attempts function will make to get namenode out of safemode. Defaults to 50
- $2 (int): Number of seconds each attempt will sleep for, waiting for namenode to come out of sleep mode. Defaults to 5