Failed to send RPC 4836332656886554080 to wn05.itversity.com/172.16.1.108:35461: java.nio.channels.ClosedChannelException


#1

when i run the following code in pyspark,
orders=sqlContext.read.format(“com.databricks.spark.avro”).load("/user/hariharanp1094/problem1/orders")
orderitems=sqlContext.read.format(“com.databricks.spark.avro”).load("/user/hariharanp1094/problem1/order-items")

orders.registerTempTable(“orders”)
orderitems.registerTempTable(“orderitems”)

sqlContext.sql(“select b.order_date as Order_Date,order_status as Order_status,count(b.order_id) as total_orders,sum(a.order_item_subtotal) as total_amount from orderitems a inner join orders b group by b.order_date,b.order_status”).limit(10).show()

I’m getting exception as
java.io.IOException: Failed to send RPC 4836332656886554080 to wn05.itversity.com/172.16.1.108:35461: java.nio.channels.ClosedChannelException

the exception occurs when i execute the sqlContext.sql() given above…