腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
scala
中
的
flink
批处理
(
无
输出
)
flink-batch
我正在用
flink
scala
编写一个简单
的
程序,它显示消费(csm)超过某个阈值(100)
的
客户
的
姓名和in。程序
的
编译已经成功完成,但是我遇到了以下异常,并且看不到
输出
。我使用
的
是集成开发环境IntelliJ。 任何帮助..。谢谢。client_sample.filter(p => p.csm> thresold); // execute progr
浏览 23
提问于2021-02-01
得票数 0
1
回答
Flink
1.5
中
的
批处理
表API问题--对流API需求
的
抱怨
apache-flink
、
flink-sql
我试图用
Flink
1.5.0创建一个面向
批处理
的
Flink
作业,并希望使用Table和SQL来处理数据。我
的
问题是试图创建一个编译错误
的
BatchTableEnviroment <groupId>org.apache.
flink
<
浏览 1
提问于2018-06-19
得票数 0
2
回答
如何使用
Flink
的
TestHarness类?
unit-testing
、
apache-flink
我需要测试一个共享状态
的
CoFlatMapFunction。通过阅读,我得出结论,我应该使用per:https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling
的
TestHarness类 因为它不是公共api
的
一部分,所以我不知道如何在不复制和粘贴类本
浏览 104
提问于2019-02-16
得票数 0
回答已采纳
1
回答
Flink
两种不同
的
ProcessWindowFunction包
scala
、
apache-flink
、
window-functions
问题 org.apache.
flink
.streaming.api.
scala
.function.ProcessWindowFunction对于窗口操作,就像在org.apache.
flink
.streaming.a
浏览 1
提问于2019-07-07
得票数 0
2
回答
Flink
Scala
缺失导入
scala
、
maven
、
apache-flink
在我
的
Flink
项目中,我找不到连接器
的
某些库(具体来说,我需要吃一次CSV,在
批处理
或流模式下读取几个块数据
的
TBs )。/
scala
.binary.version><
flink
.version>1.15.1</
flink
.version> 我是否需要一个与Java不同
的
<
浏览 26
提问于2022-11-14
得票数 0
2
回答
是否可以在流式
flink
作业
中
创建批量
flink
作业?
scala
、
apache-flink
我有一个使用Apache
Flink
(
flink
版本: 1.8.1)
的
作业流,使用
scala
。有如下流作业要求: Kafka ->写入Hbase ->再次发送到kafka使用不同
的
主题 在写入Hbase
的
过程
中
,需要从另一个表
中
检索数据。
Flink
可以做到这一点吗?如果是,您能提供与我
的
需求类似的情况
的
示例吗? 编辑:我
的
意思是,对于我在内容
中
描述<
浏览 46
提问于2020-12-21
得票数 1
1
回答
Flink
-
scala
中
的
Avro支持
scala
、
avro
、
apache-flink
如何从avro
中
的
Flink
中
读取
scala
?
批处理
/流/表:StreamExecutionEnvironment/ ExecutionEnvironment / TableEnvironment是否相同?下面是(),但是在任何地方都找不到
scala
: AvroInputFormat<User> users = new AvroInputFormat<User>(in, User.class);
浏览 0
提问于2017-05-28
得票数 1
回答已采纳
5
回答
Flink
插槽删除异常
apache-flink
(Actor.
scala
:502)at akka.actor.ActorCell.receiveMessage(ActorCell.
scala
:526)at akka.dispatch.Mailbox.processMailbox(Mailbox.
scala
:257) at
浏览 0
提问于2019-01-08
得票数 5
2
回答
批处理
执行模式下
的
Apache
Flink
FileSink :正在进行
的
文件没有转换到完成状态。
apache-flink
、
flink-batch
我们正在尝试做
的
事情,:我们正在评估
Flink
,以便使用执行
批处理
。application");}预期结果:/Users/user1/output/文件夹
中
的
“最终”文件。据FileSink 说 如果
Flink
接收器和UDF在一般情况下不区分正常作业终止(例如有限输入流)和由于失败而终止,则在作业正常终止时,最后正在进行
的
文件将不会转换到“已
浏览 39
提问于2021-07-13
得票数 1
回答已采纳
1
回答
Flink
1.12找不到在类路径
中
实现'org.apache.
flink
.table.factories.DynamicTableFactory‘
的
标识符“kafka”
的
任何工厂
apache-flink
我有一个在本地运行良好
的
Flink
作业,但是当我尝试在集群上
flink
run作业时失败了。它基本上是读卡夫卡,做一些转换,并写到一个水槽。这是我
的
pom.xml,包括
flink
-connector-kafka。 <
scala
.binary.version>2.11</
scala
.binary.version>
浏览 16
提问于2021-03-10
得票数 0
回答已采纳
1
回答
Flink
hadoop实施问题-找不到'hdfs‘方案
的
文件系统实施
apache-flink
、
flink-sql
、
flink-batch
我正在为集成hdfs到
flink
而苦苦挣扎。
Flink
(集群)版本: 1.10.1 <version>${
flink
.version}</&g
浏览 2
提问于2020-06-24
得票数 0
3
回答
对象流不是package org.apache.
flink
.test
的
成员
apache-flink
我从github克隆了
flink
代码,并用Intellij Idea打开它,我没有在IJ或代码
中
做任何配置(我已经安装了IJ
scala
插件和
scala
sdk),我直接在Intellij Idea
中
运行以下两个示例我能够成功地运行
批处理
模式字数统计示例(代码是类org.apache.
flink
.examples.
scala
.wordcount.WordCount in
flink
-examples-batch_但是当我尝试运行流单词
浏览 2
提问于2019-01-12
得票数 1
1
回答
Flink
卡夫卡流相对于星火卡夫卡流
的
好处?卡夫卡流过弗林克?
apache-kafka
、
spark-streaming
、
apache-storm
、
apache-flink
、
apache-kafka-streams
在火花流
中
,我们设置了几乎实时
的
微
批处理
的
批处理
间隔。在
Flink
(DataStream)或Storm
中
,流是实时
的
,所以我想没有这样
的
批处理
间隔
的
概念。在卡夫卡,消费者在拉,我想象星火使用批参数从卡夫卡经纪人提取消息,那么
Flink
和Storm是如何做到
的
呢?我设想
Flink
和Storm在一个快速循环中拉出Kafka消息形成实时流源,如果是这
浏览 5
提问于2016-10-24
得票数 7
回答已采纳
2
回答
Flink
流示例: Kafka010Example.
scala
不工作
apache-kafka
、
apache-flink
、
flink-streaming
我正在尝试运行正式
的
"Kafka010Example.
scala
",但是它并没有像预期
的
那样从输入主题中读取和写入
输出
。我错过了什么或者做错了什么?任何帮助或暗示都很感激。我就是这样做
的
: $ docker run -d -p 2181:2181 -p 9092:9092 spotify/kafka:latest $ docke
浏览 0
提问于2017-10-14
得票数 1
2
回答
如何重命名导入
的
Maven包
的
groupID以删除连字符?
scala
、
maven
、
intellij-idea
、
maven-3
、
apache-flink
我正在通过来创建一个简单
的
应用程序来读取文件
中
的
数据并对其进行过滤。我使用
Scala
作为编写
Flink
应用程序
的
语言,最后
的
代码如下所示:<dependency> <groupId>com.data-artisans<
浏览 3
提问于2017-07-01
得票数 1
回答已采纳
2
回答
如何将DataSet写入变量而不是文件
scala
、
apache-flink
我有一个用
scala
编写
的
DataSet
批处理
程序,它会生成我感兴趣
的
最终数据集。我希望在我
的
程序
中
以变量或值
的
形式获得该数据集(例如,一个列表或字符串序列),而不必将其写入任何文件。有可能吗?我已经看到
flink
允许收集数据接收器以便进行调试(他们
的
文档
中
唯一
的
例子是Java)。然而,这只允许在本地执行,而且我不知道它在
Scala
中
的
等价物。我
浏览 1
提问于2017-10-27
得票数 3
1
回答
合并多个
flink
作业
的
输出
并返回单个
输出
scala
、
apache-flink
、
flink-streaming
我有多个
flink
作业,它有相同
的
输入源,kafka主题和
输出
格式也是一样
的
。源->
flink
作业1 ->
输出
源->
flink
作业3 ->
输出
。。源->
flink
作业n ->
输出
输出</em
浏览 4
提问于2022-09-20
得票数 0
回答已采纳
2
回答
添加
Flink
ML依赖项
scala
、
apache-flink
我正在尝试创建一个sbt
Scala
项目,添加一些来自
Flink
的
代码。我已经成功地添加了除
Flink
-ML以外
的
大多数
Flink
项目。我尝试添加不同
的
依赖项,错误如下:resolvers += Resolver.mavenLocal // I have downloaded the
Flink
projectIntelliJIdea15/system/log/sbt.las
浏览 2
提问于2016-02-23
得票数 1
1
回答
Flink
Scala
“参数不足”
scala-ide
、
apache-flink
我在使用Apache时遇到了麻烦 }
Scala
为行val text = env.fromElements
输出
以下内容 -这不仅仅是fromElements方法:即使我从一个文件
中
读取,然后尝试做一些像ds.map(r => r)这样简单
的
事情,我也得到了非常相似
浏览 0
提问于2015-04-09
得票数 11
回答已采纳
2
回答
Apache与Hadoop上
的
Mapreduce相比如何?
hadoop
、
mapreduce
、
apache-flink
Apache与Hadoop上
的
Mapreduce相比如何?在哪些方面更好,为什么呢?
浏览 9
提问于2015-04-28
得票数 14
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink 从0到1实战实时风控系统|同步追更
官宣:Apache Flink 1.14.0 发布
Flink应用开发入门
Flink基础教程(二):初探Flink
程序猿张开大嘴,一口含住Hadoop的脑袋,原来大数据如此简单
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券