scala - ApacheFlink での DataSet の結合

Question

Flink でSeq[DataSet(Long,Long,Double)]a を singleに結合しようとしています:DataSet[(Long,Long,Double)]

     val neighbors= graph.map(el => zKnn.neighbors(results,
      el.vector, 150, metric)).reduce(
     (a, b) => a.union(b)
      ).collect()

グラフは通常の scala コレクションですが、DataSet に変換できます。results は であり、DataSet[Vector]収集すべきではなく、neighbors メソッドで必要とされます

私は常に FlinkRuntime Exeption を受け取ります:

現在、64 を超える出力を持つノードを処理できません。org.apache.flink.optimizer.CompilerException: 現在、64 を超える出力を持つノードを処理できません。org.apache.flink.optimizer.dag.OptimizerNode.addOutgoingConnection(OptimizerNode.java:347) で org.apache.flink.optimizer.dag.SingleInputNode.setInput(SingleInputNode.java:202) で