WebHCat Check

module.exports = header: 'WebHCat Check', handler: ({options}) ->
  # TODO, maybe we could test hive:
  # curl --negotiate -u : -d execute="show+databases;" -d statusdir="test_webhcat" http://front1.hadoop:50111/templeton/v1/hive

Assert HTTP

  @connection.assert
    header: 'HTTP'
    servers: options.wait.http.filter (server) -> server.host is options.fqdn
    retry: 3
    sleep: 3000

Check status

  @system.execute
    header: 'Status'
    cmd: mkcmd.test options.test_krb5_user, """
    if hdfs dfs -test -f #{options.fqdn}-webhcat; then exit 2; fi
    curl -s --negotiate -u : http://#{options.fqdn}:#{options.webhcat_site['templeton.port']}/templeton/v1/status
    hdfs dfs -touchz #{options.fqdn}-webhcat
    """
    code_skipped: 2
  , (err, executed, stdout) ->
    return if err
    return unless executed
    throw Error "WebHCat not started" if JSON.parse(stdout).status isnt 'ok'

Dependencies

mkcmd = require '../../lib/mkcmd'