我正在使用Flink ()提供的集群示例，并尝试扩展它的功能。目标是通过计算由每个质心之间的距离组成的多维数组来减少距离计算的次数，以便可以在double[][]数组中找到这些距离。该数组必须在每次迭代开始时计算，并在为点分配群集时进行广播。new Tuple3<>(centroid.f0.id, centroid.f1.id, centroid.f0
浏览 3提问于2020-02-29得票数 0
回答已采纳
我正在使用flink dataset API进行迭代计算。如果我在不保存结果的情况下使用flink <e
浏览 4提问于2016-05-14得票数 2
回答已采纳
在提供了Flink的原始Kmeans聚类示例中，每个点在每次迭代中都被分配给一个新的质心，并且关于分配给哪个质心的信息不会传递到下一个迭代中。我的目标是将这些信息传递到下一次迭代。我尝试的第一个解决方案是在循环之前将每个点分配给一个ID为0的不存在的质心，然后更新这个DataSet</
浏览 0提问于2020-03-05得票数 0
回答已采纳
2回答
所以我在一个DataStream上运行一个映射函数，在这个映射函数中，我想连接两个独立的DataSets。我只是想知道这在Flink中是否可行。我知道map函数本身是作为单独分区的单独任务运行的，所以我想知道map函数内部是否允许分布式连接？
浏览 17提问于2018-01-21得票数 0
我使用双倍创建了这个示例程序log4j:WARN No appenders could be found for logger (org.apache.flink.api.scala.ClosureCleanerat org.apache.flink.api.common.PlanExecutor.createLocalExecutor(PlanExecutor.java:161)
at org
浏览 0提问于2016-09-06得票数 0
我遇到了一个奇怪的问题:当我在其他处理(BulkIteration)之前对DataSet使用count()时，apache flink将只为count()执行该计划，而跳过我的其他操作。我在日志里找不到这方面的任何东西。那么:这是一个普遍的问题吗？我如何才能解决这个问题，而不需要自己计
浏览 0提问于2017-10-27得票数 1
我正在尝试计算社交媒体跟踪图中关系的AdamicAdar指数。我使用apache flink-gelly lirbrarie设置我的边、顶点、数据集和图。下面是我的代码： import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.o
浏览 97提问于2020-09-10得票数 0
我开始在Flink中训练一个多元线性回归算法。我正在跟踪可怕的和。我正在使用齐柏林飞艇来开发这个代码。(x._1,x._2,x._3)) }
mapped: org.apache.flink.api.scala.DataSet[org.apache.flink.ml.common.LabeledVector] = org.apache</
浏览 10提问于2017-05-31得票数 0
回答已采纳
1回答
我正在尝试使用flink scala表api连接两个表。我有一个表有两个(a，b)列，另一个表有一个( c)列，我想把这两个表连接到一个更大的表，这个表有三个(a，b，c)列。我只是想加入他们，我不想使用任何条件(Where子句)来加入他们。但是Flink抛给我一个使用Where子句的错误，这是一种在where子句中不带任何条件地连接表的方法吗？如果我想使用where子句，我应该给出什么条件？下面是
浏览 2提问于2015-07-10得票数 2
2回答
我正在尝试从运行在clojure中的Apache中获得一个小示例，但是现在我被困住了，因为clojure中的类型暗示和flink中的一些奇怪的怪癖。这是我的代码： (:import (org.apac
浏览 2提问于2015-08-20得票数 5
回答已采纳
我正在尝试执行Flink中的基本WordCount示例，该示例位于以下链接- 中Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache</e
浏览 0提问于2017-03-17得票数 2
我在Apache flink 1.3.2中尝试了几个Flink translate()函数:一个来自BatchTableEnvironment，另一个来自StreamTableEnvironment。它只使用应与结果所需完全匹配的类型信息。但是它不工作，有什么帮助吗？我想我提供了所有的details...the
import org.apache.flink.api.common.typeinfo.TypeInfor
浏览 0提问于2017-10-29得票数 0
1回答
我想多次使用org.apache.flink.api.scala.DataSet对象：
等。对于这些操作，Flink完全重新计算DataSet的值，而不是缓存它。我找不到像在Spark中那样的缓存()或持久化()函数。我正在使用最新的Flin
浏览 2提问于2017-09-15得票数 2
回答已采纳
在Apache Flink 1.3.2和Scala 2.10中执行迭代时，是否可以访问当前迭代索引？val initialData: DataSet[(ItemSet[T], Int)]
current: DataSetcurrent根据我到目前为止的搜索，简短的答案是“不”，稍微长一点的答案是，也许可以<em
浏览 0提问于2017-11-19得票数 2
我是斯卡拉的新人。因此，我想在Java中处理Apache的DataSet。但是我在Scala代码中有一个DataSet，我想在Java的方法中传递它。例如:在Scala中：在SampleJavaClass.java中有一个类似于sendDs(D
浏览 5提问于2016-02-27得票数 4
回答已采纳
我决定尝试一下apache。我决定使用scala控制台(或者更准确地说是)从csv文件中读取一些内容，并在本地打印它.只是为了调试结束实验。import org.apache.flink.api.scala
浏览 3提问于2020-02-25得票数 2
回答已采纳
我使用的是配置为使用flink-table jar的本地Flink 1.6集群(这意味着我的程序的jar不包括flink-table)。使用以下代码import org.apache.flink.api
浏览 0提问于2018-09-13得票数 0
回答已采纳
1回答
我正在尝试使用Scala的case类构建一个数据集(我希望在元组上使用case类，因为我希望按名称连接字段)。下面是我正在处理的连接的一个迭代：
campaignPartners.join(partnerInput:任务不可串行化在org.apache.flink.api.scala.C
浏览 0提问于2016-03-16得票数 0
回答已采纳
1回答
我有两个任务管理器，当我们运行一个图形算法(例如连接的组件)时，程序会失败，出现以下错误：
线程"main“org.apache.flink.runtime.client.JobExecutionException: java.lang.RuntimeException中的异常:内存耗尽。(LocalEnvironment.java:91) at org.apache.flink.api.java.LocalEnvironment.exec
浏览 0提问于2018-07-25得票数 2
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
