我使用dataSet API,我有两种案例类。val dataKeyValue: DataSet[(Long, AntiFraudLog)] at org.apache.flink.api.scala.DataSet$$anon$5$$anonfun$flatMap$1.apply(DataSet.scala:417)(List.scala:381)
at org.ap
我使用双倍创建了这个示例程序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.apache.<
我有两个任务管理器,当我们运行一个图形算法(例如连接的组件)时,程序会失败,出现以下错误:
线程"main“org.apache.flink.runtime.client.JobExecutionException: java.lang.RuntimeException中的异常:内存耗尽。:91) at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvir
我试图在Flink (Scala)中开发一个K均值模型,使用齐柏林飞艇( Zeppelin )。这是我的简单代码的一部分:val mapped : DataSet[Vector] = data.map {x => DenseVector (x._1,x._2) }//Just to learn I use the same data predicting the model
val resul
当我尝试使用start-clusted.sh和Flink在本地运行它时,我没有问题。但是,我目前正在尝试使用Flink on try (部署在Google上)来运行我的工作,当我试图取消它时,取消状态将永远持续,并且TaskManager中仍有一个插槽。这是我得到的日志:
2016-10-18 16:56:04,053 INFO org.apache.flink.