apache-flink

0热度

1回答

是否可以序列化ElasticSearch片和甲流我有类似 stream.addSink(new ElasticsearchSink<>(config, transports, new IndexRequestBuilder<ObjectNode>() { ... } return eventStream; ，但它说，ElasticsearchSink在Apache中弗林克

1热度

1回答

flink-streaming-java在Apache Flink中不可用

我正在尝试运行Apache Flink，但因为依赖项不可用而出现错误。模块flink-streaming-java仍然可用。 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java</artifactId> <version>0.10-SNAPSHOT</ve

4热度

2回答

如何在Zeppelin中将Flink var的内容写入屏幕？

我尝试在Apache Zeppelin中运行以下简单命令。 %flink var rabbit = env.fromElements( "ARTHUR: What, behind the rabbit?", "TIM: It is the rabbit!", "ARTHUR: You silly sod! You got us all worked up!", "TIM: Well, t

1热度

1回答

flink：Flink Shell引发NullPointerException

我正在使用Flink交互式Shell执行WordCount。它适用于10MB的文件大小。但随着一个100MB的文件壳抛出一个NullPointerException：： java.lang.NullPointerException at org.apache.flink.api.common.accumulators.SerializedListAccumulator.deserial

7热度

1回答

使用一个集合$ UnmodifiableCollection与Apache弗林克

虽然使用Apache弗林克用下面的代码： DataStream<List<String>> result = source.window(Time.of(1, TimeUnit.SECONDS)).mapWindow(new WindowMapFunction<String, List<String>>() { @Override public void mapWindow(

5热度

2回答

Apache Flink DataStream API没有mapPartition转换

Spark DStream有mapPartition API，而Flink DataStream API没有。有没有人可以帮助解释原因。我想要做的是在Flink上实现类似于Spark reduceByKey的API。

1热度

1回答

阿帕奇弗林克fromCollection java.lang.IllegalStateException：读数据块

我使用Scala和弗林克1.0快照上的数据组执行leftOuterJoin，我得到以下异常： 11:54:15,921 INFO org.apache.flink.runtime.taskmanager.Task - CHAIN DataSource (at com.mycompany.FlinkTest$.main(FlinkTest.scala:99) (org.apache.flink.ap

5热度

1回答

flink：在窗口流上应用多个聚合

我有一些数据作为id，float，float，float进来。我想按顺序分别（），max（）和sum（）字段，并按ID值分组。使用flatMap我有一个Tuple4与位，但我不知道如何将它发送到下一个步骤。我有什么： dataStream.flatMap(new mapper()).keyBy(0) .timeWindowAll(Time.of(5, TimeUnit.SECONDS

0热度

1回答

Google Cloud Dataflow的替代管道转轮

我读到了Google Cloud Dataflow管道转轮上的Cloudera adapted以在Spark上运行，还有Data Artisans adapted它在Flink上运行。目前还不清楚Cloudera是否实现了批量和窗口流式传输，一个职位表示不支持，但其他职位似乎不提及它，就好像它包含在内，而Data Artisan清楚地表明流式支持正在为Flink工作。是否有来自Google或另一

4热度

1回答

翻译弗林克斯卡拉到Java

的弗林克DOC给出了SVM算法Scala的例子： val trainingDS: DataSet[LabeledVector] = env.readLibSVM(pathToTrainingFile) val svm = SVM() .setBlocks(10) // Learn the SVM model svm.fit(trainingDS) 将如何调用“适合”转换为Java？