我正在尝试计算社交媒体下图中的 AdamicAdar 关系指数。我使用 apache flink-gelly lirbrarie 设置了我的边、顶点、数据集和图形。这是我的代码：
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.graph.Graph;
import org.apache.flink.graph.library.similarity.AdamicAdar;
import org.apache.flink.types.NullValue;
import org.apache.flink.types.StringValue;
import java.util.List;
public class MyMain {
public static void main(String[] args) {
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSource> edgeDataSet = env.
readCsvFile(String.valueOf(MyMain.class.getResource("dataset/edges.csv"))).
types(StringValue.class, StringValue.class);
Graph graph = Graph.fromTuple2DataSet(edgeDataSet, env);
List list = null;
try {
list = graph.run(new AdamicAdar()).collect();
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(list.get(0));
}
}
这是我得到的错误：
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.configuration.ConfigUtils.decodeListFromConfig(Lorg/apache/flink/configuration/ReadableConfig;Lorg/apache/flink/configuration/ConfigOption;Lorg/apache/flink/util/function/FunctionWithException;)Ljava/util/List;
at org.apache.flink.client.cli.ExecutionConfigAccessor.getJars(ExecutionConfigAccessor.java:75)
at org.apache.flink.client.deployment.executors.PipelineExecutorUtils.getJobGraph(PipelineExecutorUtils.java:61)
at org.apache.flink.client.deployment.executors.LocalExecutor.getJobGraph(LocalExecutor.java:98)
at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:79)
at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:962)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:878)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:862)
at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
at MyMain.main(MyMain.java:23)
Process finished with exit code 1
这也是我使用的 edges.csv 文件的一部分：
5 122
5 156
5 158
5 169
5 180
5 187
5 204
5 213
5 235
5 315
5 316
6 89
6 95
6 147
6 219
6 319
7 22
其中 5 316 表示顶点 5 连接到顶点 216，这定义了一条边。
这是我的 pom.xml 文件 pom.xml