Re: Running flink examples
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 2 nodes. > > -- > *From: *"Biao Liu" > *To: *"Vijay Bhaskar" > *Cc: *"RAMALINGESWARA RAO THOTTEMPUDI" , "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 > 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 >>> >> >
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 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 >> >
Re: Running flink examples
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 >
Re: Running flink examples
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 - Original Message - From: "RAMALINGESWARA RAO THOTTEMPUDI" To: "user" Sent: Wednesday, September 18, 2019 12:48:06 PM Subject: Running flink examples 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
Running flink examples
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
