我试图在我的apache flink gelly图上运行标签传播协议。
这是我的密码：

Graph<String, Long, String> ugraph = Graph.fromDataSet(vertex, edgeSet, env).getUndirected();
        DataSet<Tuple2<String, Long>> idsWithInitialLabels = DataSetUtils
            .zipWithUniqueId(graph.getVertexIds())
            .map(new MapFunction<Tuple2<Long, String>, Tuple2<String, Long>>() {
                public Tuple2<String, Long> map(Tuple2<Long, String> tuple2) throws Exception {
                    return new Tuple2<String, Long>(tuple2.f1, tuple2.f0);
                }
            }); 
        DataSet<Vertex<String, Long>> verticesWithCommunity = graph.joinWithVertices(idsWithInitialLabels,
            new VertexJoinFunction<Long, Long>() {
            public Long vertexJoin(Long vertexValue, Long inputValue) {
            return inputValue;
        }})
    .run(new LabelPropagation<String, Long, String>(10));

我收到以下错误消息：
org.apache.flink.api.common.invalidprogramexception:对象org.apache.flink.graph。graph$applycogrouptovertexvalues@4dde0543 不能在org.apache.flink.api.java.closurecleaner.ensureserializable（closurecleaner）上序列化。java:99)在org.apache.flink.api.java.closurecleaner.clean（closurecleaner。java:61)在org.apache.flink.api.java.dataset.clean（数据集。java:186)位于org.apache.flink.api.java.operators.cogroupoperator$cogroupoperatorsets$cogroupoperatorsets预测$cogroupoperatorwithoutfunction.with（cogroupoperator）。java:619)在org.apache.flink.graph.graph.joinwithvertices（图。java:587)在tu.master.conceptdetection.textprocessor.clustering（textprocessor。java:405)在tu.master.conceptdetection.textprocessor$4.actionperformed（textprocessor。java:210)
感谢您的帮助：）