LAG throws exceptions

[pandees waran]

Hi,

I am executing the below query using lag in 0.11 in Amazon EMR cluster.

SELECT
      id  ,
      MARKET_ID,
      city,
      product_id,
      SALE_DAY,
      isbn,
      seller_ID,
      currency,
      lag(quantity,1,0) over (partition by
isbn,ID,MARKET_ID,city,seller_ID,currency order by SALE_DAY)  AS
start_quantity
    FROM test_table

This simple query ended with below exceptions:

Exception in thread "Thread-758" java.lang.ClassFormatError:
org/apache/hadoop/mapred/TaskLogServlet
        at 
org.apache.hadoop.hive.shims.Hadoop20SShims.getTaskAttemptLogUrl(Hadoop20SShims.java:49)
        at 
org.apache.hadoop.hive.ql.exec.JobDebugger$TaskInfoGrabber.getTaskInfos(JobDebugger.java:190)
        at 
org.apache.hadoop.hive.ql.exec.JobDebugger$TaskInfoGrabber.run(JobDebugger.java:146)
        at java.lang.Thread.run(Thread.java:724)
Counters:
FAILED: Execution Error, return code 2 from
org.apache.hadoop.hive.ql.exec.MapRedTask

Any thoughts on this? Please let me know, if i am doing something wrong.
-- 
Thanks,
Pandeeswaran