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.