在我使用Flink的Scala代码中，我已经能够像这样从Kafka主题中读取内容： new SimpleStringSchema(), properties_demographic))
stream_demographic val的类型为DataStreamSource。但是，当我尝试<
浏览 33提问于2021-05-25得票数 0
我的代码就像：tableEnv.createTemporaryView("input_table", src, $("name"), $("dt"));DataStreamSource<Tuple2<String, L
浏览 3提问于2021-08-02得票数 0
回答已采纳
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;
importorg.apache.flink.cep.pattern.
浏览 3提问于2017-07-11得票数 1
回答已采纳
我正在尝试执行Flink中的基本WordCount示例，该示例位于以下链接- 中Exception in thread "main" java.lang.NoSuchMethodError:118)
at org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$2.apply(Flin
浏览 0提问于2017-03-17得票数 2
1回答
我正试图将一个CSV文件映射到一个Tuple4中，该文件已经由Flink消费，由Kafka生产。我的CSV文件有4列，我想将每一行映射到一个Tuple4中。问题是我不知道如何实现map()和csv2Tuple函数。这就是我被困的地方：
ParameterTool
浏览 0提问于2018-08-25得票数 0
回答已采纳
我在flink上做了一些poc，但我找不到关于如何在kafka流中实现类似于KGroupTable的用例的文档，如下所示我想从收到的交易中汇总账户余额的用例如果我得到现有事
浏览 5提问于2020-05-23得票数 0
我在流环境中使用Flink的Table和/或Flink的SQL支持(Flink 1.3.1，Scala2.11)。导致：
不支持线程"main“中的异常: org.apache.flink.table.api.TableException$.apply(exceptions.scala:53) at org.apache.flink.table.calcite.FlinkTyp
浏览 2提问于2017-08-02得票数 1
回答已采纳
我正在使用flink 1.12.0。试图将数据流转换为表A，并在tableA上运行sql查询，以便按下面的方式通过窗口进行聚合，我使用f2列作为时间戳数据类型字段。ConfluentRegistryAvroDeserializationSchema.forSpecific( props);
}
当我执行上述代码时
浏览 5提问于2021-02-15得票数 0
回答已采纳
在Scala中，无论我尝试什么，我都会得到这样一个错误： import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala</
浏览 2提问于2021-01-28得票数 1
3回答
我使用了最新的flink版本(1.10.0)和sbt(1.3.7)。转换为
case x => MergeStrategy.first我读到了一个类似的案例，其中包含了，这就是答案：
在之后，flink客户端将使用默认的子优先解决顺序.如果用户jar有一些冲突依赖项，则会出现一些问题。我的问题是:如何
浏览 3提问于2020-02-27得票数 0
将字符串流转换为一般数据流时出现异常。:406)在mapper中初始化架构后，获得强制转换异常。cannot be cast to java.util.Map通过强制转换通过如下方式度过了强制转换异常：
record.put(0,scala.collection.JavaConverters.mapAsJavaMapConverter,"body":"\"{\\
浏览 16提问于2020-07-24得票数 0
我正在尝试测试简单的flink代码，如下所示。原始数据集的序列是1,2,3,4。 在读取文件之后，流的顺序是‘1，4，2，3’。此外，每当我测试它时，顺序都是不同的。如何将输入数据集的顺序固定为与原始上下文相同？ 下面是我的simpel代码。DataStreamSource<Integer> integerDataStreamSource = env.fromElements(1, 2,
浏览 17提问于2020-04-20得票数 0
回答已采纳
我的目标是调试这段代码，以便按照中的建议查看它的运行情况。Cannot find a class with the main method in the folder 'frauddetection'.launch",
"m
浏览 15提问于2020-06-08得票数 1
回答已采纳
我正在尝试(未成功)在Apache Flink中运行一个简单的hello world类型的程序。代码从Apache Kafka获取一条消息，并添加一个“。并将新字符串打印到stdout。我在REPL提示符下尝试了这个函数，scala代码在那里可以正常工作。Scala代码：input: String = hello
scala> val o
浏览 1提问于2016-11-22得票数 0
我正在尝试为Apache编写一些用例。[SomeType]val newStreamInput = see.addSource(la
浏览 0提问于2016-06-20得票数 25
回答已采纳
我有一个在本地运行良好的Flink作业，但是当我尝试在集群上flink run作业时失败了。它基本上是读卡夫卡，做一些转换，并写到一个水槽。当试图通过'connector' = 'kafka'从Kafka加载数据时，会发生错误。<!>1.12.0</flink.version>
浏览 16提问于2021-03-10得票数 0
回答已采纳
我们已经用1.4版本部署了一个新的Flink实例。在尝试从旧的1.2.1部署恢复保存点时，尝试还原的所有作业都会出现相同的错误： at org.apache.fli
浏览 6提问于2018-01-04得票数 2
回答已采纳
在集成测试中测试flink mini集群上的流时，我遇到了一个问题。该流映射一个生成的Avro Java类( SpecificRecord )。 流作业是用Scala编写的。flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCa
浏览 38提问于2020-09-25得票数 0
1回答
问题是在进行案例类提取时，映射函数中存在问题。case类不可序列化。我已经隐式地定义了DefaultFormats格式。将作为线程"main“org.apache.flink.api.common.InvalidProgramException:任务中的GenericType异常处理，在org.apache.flink.api.scala.ClosureCleaner$.ensureSerializable
浏览 3提问于2017-05-02得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
