运行此命令时出现问题

./bin/flink run -p 4 -q examples/gelly/flink-gelly-examples_*.jar --algorithm PageRank --input CSV --type integer --simplify directed --input_filename WikiTalk.txt --input_field_delimiter $'\t'     --output print

我使用的是vm，我的集群由3个taskmanagers组成，主任务是jobmanager和taskmanager（4个taskmanagers和一个jobmanager）
部分例外

Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
    at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
    at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:265)
    ... 21 more
Caused by: java.lang.RuntimeException: The initialization of the DataSource's outputs caused an error: The type serializer factory could not load its parameters from the configuration due to missing classes.
    at org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:106)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.RuntimeException: The type serializer factory could not load its parameters from the configuration due to missing classes.
    at org.apache.flink.runtime.operators.util.TaskConfig.getTypeSerializerFactory(TaskConfig.java:1143)
    at org.apache.flink.runtime.operators.util.TaskConfig.getOutputSerializer(TaskConfig.java:549)
    at org.apache.flink.runtime.operators.BatchTask.getOutputCollector(BatchTask.java:1230)
    at org.apache.flink.runtime.operators.BatchTask.initOutputs(BatchTask.java:1309)
    at org.apache.flink.runtime.operators.DataSourceTask.initOutputs(DataSourceTask.java:312)
    at org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:103)
    ... 2 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.graph.Edge