Description
Seems like I can't pass multiple argument via knox shell as follow:
jobId = Job.submitPig(session) \ .arg( "-p" ) \ .arg( "someparam=somevalue" ) \ .arg( "-v" ) \ ...
Looking at code looks like Pig code can only take one arg.
Would expect code to be as follow:
public Request arg( String arg ) { addParam( params, "arg", value ); return this; }
protected Callable<Response> callable() { return new Callable<Response>() { @Override public Response call() throws Exception { URIBuilder uri = uri( Job.SERVICE_PATH, "/pig" ); List<NameValuePair> params = new ArrayList<NameValuePair>(); addParam( params, "group", group ); addParam( params, "file", file ); addParam( params, "statusdir", statusDir ); UrlEncodedFormEntity form = new UrlEncodedFormEntity( params ); HttpPost request = new HttpPost( uri.build() ); request.setEntity( form ); return new Response( execute( request ) ); } }; }