问题标签 [gelly]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

21 问题

0 投票

1 回答

1404 浏览

maven - 运行 Apache Flink 作业时链接失败

我在 Flink 0.9 中开发了一份使用图形模块（Gelly）的工作。该作业在 IDE (Eclipse) 中成功运行，但在使用 maven (mvn clean install) 将其导出到 JAR 后，它无法在本地 flink 实例上执行，并出现以下错误

“由于链接失败，无法加载程序的入口点类‘myclass’”

知道为什么会发生这种情况以及如何解决吗？

0 投票

1 回答

162 浏览

scala - Flink：PageRank 类型不匹配错误

我想PageRank从格式如下的边缘的 CSV 文件中计算：

我的代码：

我从 Flink Scala Shell 收到以下错误：

我究竟做错了什么？

（并且每个顶点的初始值 0.0 和每个边的初始值 1.0 是否正确？）

scala apache-flink gelly

0 投票

1 回答

185 浏览

scala - Flink Gelly - 创建图形时类型不匹配

我是 Apache Flink 和 Gelly 的新手，我使用 Scala API。我有一个顶点数据集和一个边数据集，我正在尝试创建一个这样的图：

我收到以下错误：

scala apache-flink gelly

0 投票

4 回答

358 浏览

scala - Flink：Connected Components - 类型不匹配错误

我正在尝试使用 Scala API 在图形上运行连接组件算法，如编程指南和其他示例中所示。

我收到以下错误：

即使我添加

我得到：

我的进口是这些：

有人可以解释为什么会这样吗？

scala apache-flink gelly

0 投票

1 回答

561 浏览

apache-flink - Apache Flink 创建不正确的计划

我为 Apache Flink 创建了一个简单的 Job，它使用 Gelly 提供的 PageRank 实现。

在本地，在 IDE 中运行，一切都很好。但是，我尝试使用 JobManager Web 界面将我的 Job 的 JAR 提交到在我的机器上运行的 Flink 实例。但是，Flink 并没有为 Job 获取正确的计划并执行 PageRank，而是提出并执行了一个非常奇怪的计划，该计划只计算图的顶点数。

我做了一些研究和调试，发现 Gelly 提供的 PageRank 的实现开始计算图的顶点数，当它没有作为参数提供给算法时：

这个计算意味着一个嵌入的工作。由于操作员是惰性的，因此不会触发任何计算。在 Flink 服务器中，首先要做的是获取作业计划。这是由一个特殊的环境来完成的OptimizerPlanEnvironment，它提供了以下result方法：

问题来自这里。一旦ProgramAbortException抛出，程序就会返回到目前为止计算的计划。但是只计算了内部作业计划，所以这种方式永远不会计算或执行主作业计划。

这是我使用的代码：

如果提供了顶点数，例如graph.run(new PageRank<Long>(0.85, 5, 10))，没有问题，则正确计算计划并计算PageRank。

我的问题是：我做错了什么？或者这是 Flink 中的一些实际错误？

apache-flink gelly

0 投票

1 回答

1653 浏览

serialization - Flink 序列化错误

我正在尝试在我的 Apache Flink Gelly Graph 上运行标签传播协议。
这是我的代码：

我收到以下错误消息：

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(DataSet.java:186) 在 org.apache.flink.api。 java.operators.CoGroupOperator$CoGroupOperatorSets$CoGroupOperatorSetsPredicate$CoGroupOperatorWithoutFunction.with(CoGroupOperator.java:619) at org.apache.flink.graph.Graph.joinWithVertices(Graph.java:587) at tu.master.ConceptDetection.TextProcessor.clustering( TextProcessor.java:405) 在 tu.master.ConceptDetection.TextProcessor$4.actionPerformed(TextProcessor.java:210)

谢谢您的帮助：）

serialization apache-flink gelly

0 投票

1 回答

87 浏览