The command is: yarn logs -applicationId <appId>
Sorry for typo. -Priyanka On Mon, Aug 29, 2016 at 2:09 PM, Priyanka Gugale <[email protected]> wrote: > Hitesh, > > Can you please share code of your MeanOperator and > StandardDeviationOperator. > Also please share the application logs. After shutting down application > you can run "yan logs -applicationId <appId> to collect logs. > > -Priyanka > > On Mon, Aug 29, 2016 at 10:39 AM, Hitesh Goyal < > [email protected]> wrote: > >> Hi team, >> >> >> >> I am trying to process some data using Operators. >> >> >> >> @SuppressWarnings("unchecked") >> >> @Override >> >> *public* *void* populateDAG(DAG dag, Configuration conf) { >> >> System.*setProperty*("viewmode", "production"); >> >> CouchBasePOJOInputOperator inputOperator = dag.addOperator( >> "inputOperator", CouchBasePOJOInputOperator.*class*); >> >> inputOperator.setStore(*new* CouchBaseStore()); >> >> MedOperator med = dag.addOperator("median", MedOperator. >> *class*); >> >> MeanOperator mean=dag.addOperator("mean", MeanOperator. >> *class*); >> >> StandardDeviationOperator sdo=dag.addOperator("sdo", >> StandardDeviationOperator.*class*); >> >> ConsoleOutputOperator cons = dag.addOperator("cons", *new* >> ConsoleOutputOperator()); >> >> ConsoleOutputOperator cons1 = dag.addOperator("cons1", >> *new* ConsoleOutputOperator()); >> >> ConsoleOutputOperator cons2 = dag.addOperator("cons2", >> *new* ConsoleOutputOperator()); >> >> dag.addStream("inputFormatter", inputOperator.outputPort, >> med.data,mean.meandata,sdo.meandata); >> >> dag.addStream("cons", med.median, cons.input >> ).setLocality(Locality.*THREAD_LOCAL*); >> >> dag.addStream("cons1", mean.mean, cons1.input >> ).setLocality(Locality.*THREAD_LOCAL*); >> >> dag.addStream("cons2", sdo.deviation, cons2.input >> ).setLocality(Locality.*THREAD_LOCAL*); >> >> } >> >> There is no error in the code but when I launch this application in >> Data Torrent, the status of operators remains pending instead of >> Running/Active. Physical DAG view is clearly showing right connection of >> one stream to another. >> >> >> >> >> >> Regards, >> >> *Hitesh Goyal* >> >> Simpli5d Technologies >> >> Cont No.: 9599803307 >> >> >> > >
