Michael Harris
Wed, 02 Apr 2008 10:47:46 -0700
Hello, I have written a pig application that does a fixed set of queries on-demand through a web interface. I am trying to get the progress of the queries from the PigServer, but I have noticed that the source of the progress data is all static fields in the MapReduceLauncher. Clearly my webapp must be able to handle multiple concurrent pig queries (and be thread-safe) and I would like to report the progress of each individual query (job set) to the end user. Do these static fields indicate that I would get the progress of multiple concurrent queries initiated by different PigServer instances? or would I get the overall progress of the MapReduceLauncher for all queries currently being executed? Thanks, Michael