我正在遵循Apache Flink的docs来接收数据，这是我的代码： consumeRecord.keyBy("gameType") .reduce(new MyReduceFunction(),new MyProcessWindowFunction());private static class MyReduceFunction implements ReduceFunc
浏览 52提问于2020-04-10得票数 0
回答已采纳
(el => zKnn.neighbors(results, (a, b) => a.union(b)).collect()
当前无法处理超过64个输出的节点。org.apache.flink.optimizer.Compi
浏览 1提问于2015-07-24得票数 4
回答已采纳
全,java.lang.IllegalArgumentExceptionat org.apache.flink.ml.math.BLAS$.axpy(BLAS.scala:60)
浏览 4提问于2016-02-04得票数 1
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析重载方法<
浏览 50提问于2020-01-14得票数 0
回答已采纳
我使用了10秒时间窗口，当我打印结果时，它会显示正确的结果，但是当我使用queryable状态并使用QueryableClient进行查询时，即使时间窗口发生变化，它也会缓存时间窗口的最后一个结果。所以我有两个问题：
import org.apache.flink
浏览 0提问于2018-03-23得票数 1
回答已采纳
我不得不为窗口的()方法编写自定义逻辑。这是代码： override def reduce(a, Int), windowFunction: (org.apache.flink.api.java.tuple.Tuple, org.apache.flink.streaming.api.windowing.windows.TimeWindow,
浏览 2提问于2016-04-28得票数 3
回答已采纳
我编写了一个Flink程序来解析流数据。我可以毫无问题地运行它。但是，当我创建一个jar文件时，jar文件不会运行。jar文件已经构建；即使我无法运行它。当我想运行它时，我会收到以下错误：
线程"main“中的异常:无法在org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:276) at org.a
浏览 0提问于2019-05-16得票数 1
回答已采纳
我试图使用Apache (org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness)中的OneInputStreamOperatorTestHarness，但是Intellj无法解析符号。
浏览 5提问于2021-12-20得票数 -1
有些东西稍后会出现，但目前的问题是，数据以JSON字符串的形式正确地到达了我的使用者。我想把它扔到flink表中，我用以下语句创建了flink表：接下来，我想打开机器，用"SELECT * FROM RawData“检查我的数据，并得到以下错误：
错误无法执行SQL语句。原因: org.apache.flink.kafka.shaded.org.apache.kafka.common.config.Co
浏览 0提问于2020-06-14得票数 1
我使用的是最新的Flink-1.1.2-Hadoop-27和flink-连接器-kafka-0.10.2-Hadoop 1罐。Flink消费者如下：以下是执行后得到的例外情况：
Exception in thread "main" java.lang.NoClas
浏览 2提问于2016-10-14得票数 7
回答已采纳
我甚至还使用过assignTimeStamp接口，但我遇到了错误 DataStream<Tuple2<Long, String>> sum = data.map(new MapFunction<String}) .reduceReduceFunction<Tuple2<Long, String>>()
浏览 65提问于2021-02-01得票数 2
portName("MyPortName") .buildConfig();at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)
at org.apache.flink.streaming.api.operators.Strea
浏览 32提问于2017-03-04得票数 0
回答已采纳
我确信端口没有被使用，防火墙被关闭。
root@maple-PC:/home/maple/Downloads/flink-1.4.2# .}, ProcessingTimeTrigger(), WindowedStream.reduce(WindowedStream.java:241)) -> Sink: Unnamed(1/1) switched}, ProcessingTimeTrigger(), WindowedStream.reduce(WindowedStr
浏览 516提问于2018-12-15得票数 3
1回答
2022-01-04 15:58:17 java.lang.NoClassDefFoundError:无法初始化org.apache.flink.streaming.connectors.elasticsearch7:102) at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58) at org.apache.flink.streaming.runt
浏览 6提问于2022-01-04得票数 0
当我使用Flink 1.12批时，我的代码：<dependency> <artifactId>flink-java</artifactId><ve
浏览 11提问于2021-01-14得票数 0
回答已采纳
我正在尝试使用Apache连接twitter，使用官方文档进行流传输。虽然我能够成功地使用api解析示例TwitterExampleData，但是当我试图使用相同的方法连接真实的数据时，我就得到了ClassNotFoundException。java.lang.NoClassDefFoundError: org/apache/flink/twitter/shaded/
浏览 6提问于2017-10-03得票数 2
回答已采纳
下面是SBT配置libraryDependencies += "org.apache.flink由于我无法通过sbt添加flink-连接器-kafka，所以我下载了jar并将其放在sbt项目中的lib(created )文件夹中。下面是我从Kafka
浏览 1提问于2020-02-27得票数 1
回答已采纳
我试图使用Apache的JsonNodeDeserializerSchema解析传入的事件，它属于包org.apache.flink.formats.json，当我试图在POM.xml中导入依赖项时，它说Jar没有找到，但是flink的文档显示它是可用的。
浏览 0提问于2018-03-19得票数 0
回答已采纳
我在Flink站点中使用了一段代码将Apache Flink连接到Elastic Search。我想通过maven项目从NetBeans软件运行这段代码。(new ReduceFunction<WordWithCount>() { public WordWithCount reduce(@Override return word + " :
浏览 2提问于2019-11-11得票数 0
2回答
我正在尝试从运行在clojure中的Apache中获得一个小示例，但是现在我被困住了，因为clojure中的类型暗示和flink中的一些奇怪的怪癖。这是我的代码： (:import (org.apache.flink.api.common.functionsFlatMapFunction)
(org.apache.flin
浏览 2提问于2015-08-20得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
