Showing posts with label flink. Show all posts
Showing posts with label flink. Show all posts

Thursday, October 31, 2019

Flink Gelly examples

Try to run around some flink gelly examples.

Finally, I resolve the tab delimiter in command line by turning off tab key lookup.

cmd.exe /f:off

Then, I am able to run it.

D:\apps\flink-1.9.0>.\bin\flink run -q examples/gelly/flink-gelly-examples_*.jar --algorithm GraphMetrics --order undirected --input CSV --type integer --simplify undirected --input_filename /apps/flink-1.9.0/com-lj.ungraph.txt --input_field_delimiter "   " --output print
log4j:WARN No appenders could be found for logger (org.apache.flink.client.cli.CliFrontend).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Starting execution of program

Vertex metrics:
  vertex count: 3,997,962
  edge count: 34,681,189
  average degree: 17.349
  density: 0.00000434
  triplet count: 4,255,768,195
  maximum degree: 14,815
  maximum triplets: 109,734,705

Edge metrics:
  triangle triplet count: 449,751,622
  rectangle triplet count: 1,388,670,456
  maximum triangle triplets: 137,026
  maximum rectangle triplets: 251,258
Program execution finished
Job with JobID 813dd189c8acdb842d2b85ced4deea8c has finished.
Job Runtime: 196314 ms
Accumulator Results:
- afd94e67e8302a263a83f876c246edab-tripletCount (java.lang.Long): 4255768195
- afd94e67e8302a263a83f876c246edab-maximumDegree (java.lang.Long): 14815
- a6c4a7d4de750ab0e0c89269b443946d-maximumTriangleTriplets (java.lang.Long): 137026
- afd94e67e8302a263a83f876c246edab-maximumTriplets (java.lang.Long): 109734705
- a6c4a7d4de750ab0e0c89269b443946d-rectangleTripletCount (java.lang.Long): 1388670456
- a6c4a7d4de750ab0e0c89269b443946d-triangleTripletCount (java.lang.Long): 449751622
- a6c4a7d4de750ab0e0c89269b443946d-maximumRectangleTriplets (java.lang.Long): 251258
- afd94e67e8302a263a83f876c246edab-vertexCount (java.lang.Long): 3997962
- afd94e67e8302a263a83f876c246edab-edgeCount (java.lang.Long): 69362378


D:\apps\flink-1.9.0>

Flink ports

In window, start-cluster.bat sprouts task manager and job manager consoles.

And listening port 6123, 8081.

Once close two java consoles, the listing ports gone.