flink 深度优先搜索

Question

我的flink集群有3个taskmanager，每个taskmanager有一个slot，我从hdfs中读取英文数据流，flink进行深度优先搜索，slot 抽象为节点，我在flink中想实现一个小算法。先将所有节点的访问状态标记为红色，表示节点未被访问过。初始化一个二维表，用于记录每个节点的发现和完成时间。 然后从源点开始，对每个节点执行深度优先搜索。 当节点首次被发现时，标记为黄色，并记录当前时间为节点的发现时间。 继续DFS，访问当前节点的所有后继节点。如果后继节点是红色，则递归访问；如果后继节点是蓝色，则直接使用其之前的发现和完成时间。 当节点的所有后继都被访问完毕，且由该节点发出的数据元组到达汇点后，标记该节点为蓝色，并记录当前时间为节点的完成时间，我放在flink中一直编译不了，请给一下代码(用各种gpt的先能成功运行再给我好吧，谢谢您了)

Answer 1

深入理解Flink基于StreamGraph构建JobGraph的流程_flink streamgraph jobgraph-CSDN博客 文章浏览阅读338次。构建JobGraph_flink streamgraph jobgraph https://blog.csdn.net/qq_36299025/article/details/128460440