我想在stream.map()中使用一个不可序列化的对象，如下所示 val obj = new SomeUnserializableClass()
obj.doSomething在Spark中，我可以使用mapPartition来做这件事。但在flink stream api中，我不知道。
浏览 35提问于2020-03-03得票数 1
回答已采纳
Spark有mapPartition API，而Flink DataStream API没有。有谁能帮助解释原因吗？我想要做的是在Flink上实现一个类似于星火reduceByKey的API。
浏览 2提问于2015-10-28得票数 7
回答已采纳
我正在尝试从Flink 1.12.x DataSet api迁移到Flink 1.14.x DataStream api。mapPartition在Flink DataStream中不可用。我们的代码使用Flink 1.12.x DataSet .<few operations>
.mapPartition(new SomeMapParitionFn())
浏览 9提问于2022-02-09得票数 0
我想创建一个用scala编写的flink项目。当我导入时'flink-streaming-scala_2.11'我可以运行如下代码：但我看到每一个都是这样：
flink-
浏览 6提问于2017-07-23得票数 0
回答已采纳
1回答
当我将Flink Java应用程序从1.12.2升级到1.12.3时，我会得到一个新的运行时错误。不会触发Flink版本1.12.2的任何错误。(BlinkPlannerFactory.java:48) at org
浏览 8提问于2021-04-29得票数 0
回答已采纳
我实现了一个ProcessFunction，它使用Guava缓存来过滤传入的事件流。时，我收到以下错误： Caused by: org.apache.flink.api.common.InvalidProgramException: The implementation of the(StreamExecutionEnvironment.java:1560)
at org.apache.flink.streaming.api.datastream.DataStream.
浏览 132提问于2019-04-02得票数 0
在Fink源码中，有flink-stream-java和flink-stream-scala模块。为什么我们需要两个模块来实现flink流？
浏览 0提问于2019-02-25得票数 3
我的代码就像：tableEnv.createTemporaryView("input_tablereturns(rti);新代码工作正常，但在我看来有点扭曲，因为我必须添加一个基本不做任何事情的映射因此，我的问题是，将java LocalDateTime映射到
浏览 3提问于2021-08-02得票数 0
回答已采纳
file for org.apache.flink.streaming.api.scala.DataStream not foundCassandraSink.addSink(dataStream我使用代码中导入的下列依赖项：import org.apache.flink.api.java.tuple.Tup
浏览 2提问于2018-03-24得票数 4
回答已采纳
1回答
我有一个Flink应用程序，它保持与这个错误的错误。 com.org.ads.audience.traffic.MyClass@6eaa21d8 is not serializable.org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:140)
org.apache.flink.api.java.ClosureCleaner.clean(StreamExecutionEn
浏览 448提问于2019-09-25得票数 1
1回答
将Apache flink和scala与mockito结合使用。尝试在模拟DataStream中注入一个字符串，以测试两个测试用例。我不确定如何用一些数据模拟Flink的DataStream对象。有什么想法吗？import org.apache.commons.lang3.StringUtilsimport
浏览 1提问于2017-07-13得票数 1
问题
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction对于窗口操作，就像在org.apache.flink.streaming.<
浏览 1提问于2019-07-07得票数 0
我是Apache的新手，我尝试过滤以字母"N“开头的单词，并得到输出，但是我如何获得不以单词"N”开头的单词，这是我正在使用的代码import org.apache.flink.api.common.functions.FlatMapFunction;
浏览 1提问于2020-05-12得票数 0
回答已采纳
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:99) at org.apache.flink.streaming.api.datastrea
浏览 0提问于2018-04-18得票数 0
我正在使用flink dataset API进行迭代计算。如果我在不保存结果的情况下使用flink dataset API进行批量迭代，代码如下所示： (result,result)end.count()
但是，如果我试图在迭代(_.writeAsTex
浏览 4提问于2016-05-14得票数 2
回答已采纳
2回答
我在流的世界里是个新手，在我的第一次尝试中我遇到了一些问题。 更具体地说，我正在尝试使用Flink在滑动窗口中实现计数和groupBy功能。我在一个普通的DateStream中做过，但是我不能让它在WindowedStream中工作。 你对我该怎么做有什么建议吗？evidence$28: org.apache.flink.api.common.typeinfo.TypeInformation[R])org.apache.flink.s
浏览 18提问于2019-05-02得票数 1
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;import org.apache.flink.str
浏览 3提问于2017-07-11得票数 1
回答已采纳
我有一个条件列表(来自json的获取规则).Data(Json)来自kafka服务器。我想用这个列表过滤数据。但它不起作用。我该怎么做呢？对于keyedstream和警报，我不是很确定。flink能像这样工作吗？org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.env
浏览 1提问于2017-09-21得票数 0
我对MapPartition没有得到明确的理解。请有人用地图分区的一些用例解释一下，它与FlatMap有何不同？
浏览 4提问于2017-08-09得票数 2
回答已采纳
我有一个像这样的流：<_time(timestamp), uri(string), userId(int)>。CommonCalc.scala:44) at org.apache.flink.table.plan.nodes.datastream
浏览 1提问于2018-03-02得票数 1
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
