Hi RAMALINGESWARA, Are you sure it's reading your input date correctly? Asking this because I saw the default input date (which is applied if there is no input data offered) is just 15 elements.
Actually the default number of iterations is 10. You could pass a parameter "--iterations $the_number_you_wanted" to change the default behavior. I'm not sure whether it is what you exactly want or not. You could find the source code of this example here [1]. Maybe it could help. 1. https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java Thanks, Biao /'bɪ.aʊ/ On Fri, 20 Sep 2019 at 01:02, RAMALINGESWARA RAO THOTTEMPUDI < tr...@iitkgp.ac.in> wrote: > Respected Sir, > > It is reading the data but giving only 15 results. for example for > pagerank only it is giving 15 elements node ranking. But I need each node > ranking for 20000 nodes. > > ------------------------------ > *From: *"Biao Liu" <mmyy1...@gmail.com> > *To: *"Vijay Bhaskar" <bhaskar.eba...@gmail.com> > *Cc: *"RAMALINGESWARA RAO THOTTEMPUDI" <tr...@iitkgp.ac.in>, "user" < > user@flink.apache.org> > *Sent: *Thursday, September 19, 2019 1:06:53 PM > *Subject: *Re: Running flink examples > > Hi, > I guess the specific input (--input /path/to/input) didn't work. > I just checked the PageRank example program, it accepts "--pages" and > "--links" as input parameters. > > Thanks, > Biao /'bɪ.aʊ/ > > > > On Thu, 19 Sep 2019 at 14:56, Vijay Bhaskar <bhaskar.eba...@gmail.com> > wrote: > >> Can you check whether its able to read the supplied input file properly >> or not? >> Regards >> Bhaskar >> >> On Wed, Sep 18, 2019 at 1:07 PM RAMALINGESWARA RAO THOTTEMPUDI < >> tr...@iitkgp.ac.in> wrote: >> >>> Hi Sir, >>> >>> I am trying to run the flink programs particularl Pagerank. >>> >>> I have used the following command : >>> >>> ./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input >>> >>> It is running but it is showing only 15 elements ranking for my data. >>> But I need to find the ranking of all elements of my data. >>> Because the original program is running only for fixed number of >>> iterations which is 15. How can I modify to run for full data elements. >>> >>> I have to change the value of fixed number of iterations. >>> >>> >>> >>> Thanking You, >>> >>> TR RAO >>> >> >
