Home / CSE MCQs / Hadoop MCQs :: Discussion

Discussion :: Hadoop MCQs

  1. Which of the following script is used to check scripts that have failed jobs ?
  2. A.

    a = load '/mapred/history/done' using HadoopJobHistoryLoader() as (j:map[], m:map[], r:map[]);

    b = foreach a generate (Chararray) j#'STATUS' as status, j#'PIG_SCRIPT_ID' as id, j#'USER' as user, j#'JOBNAME' as script_name, j#'JOBID' as 


    job;

    c = filter b by status != 'SUCCESS';

    dump c;

    B.

    a = load '/mapred/history/done' using HadoopJobHistoryLoader() as (j:map[], m:map[], r:map[]);

    b = foreach a generate j#'PIG_SCRIPT_ID' as id, j#'USER' as user, j#'JOBNAME' as script_name, (Long) r#'NUMBER_REDUCES' as reduces;

    c = group b by (id, user, script_name) parallel 10;

    d = foreach c generate group.user, group.script_name, MAX(b.reduces) as max_reduces;

    e = filter d by max_reduces == 1;

    dump e; 

    C.

    a = load '/mapred/history/done' using HadoopJobHistoryLoader() as (j:map[], m:map[], r:map[]);

    b = foreach a generate j#'PIG_SCRIPT_ID' as id, j#'USER' as user, j#'QUEUE_NAME' as queue;

    c = group b by (id, user, queue) parallel 10;

    d = foreach c generate group.user, group.queue, COUNT(b);

    dump d;

    D.
    None of the mentioned

    View Answer

    Workspace

    Answer : Option A

    Explanation :

    Pig provides the ability to register a listener to receive event notifications during the execution of a script.


Be The First To Comment