腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
运行
Flink
应用程序需要JAR文件吗?
、
我正在阅读费边·韦斯克和瓦西利基·卡拉维里的“Stream Processing with Apache
Flink
”一
书
。 这本书包括一个例子
Flink
应用程序,我想知道如何运行该文件。
浏览 2
提问于2022-01-20
得票数 0
回答已采纳
1
回答
如何在Hadoop中可视化日志文件?
、
、
、
在四处搜索之后,我可以想出一些解决方案:2/流数据处理:流Spark或Apache
Flink
我是不是遗漏了什么?Spark和
Flink
我应该使用哪一个?我有一个机器集群,我已经安装了Ambari,HDP 2.4.2,HDFS 2.7,YARN 2.7,Spark 1.6,Kafka。有什么
书
或课程吗?P/s: 我读过databrick的git
书
,但它只提到了spark。我还找到了一些如何使
浏览 0
提问于2016-07-07
得票数 0
3
回答
如何运行Apache的第一个示例
、
我试图从oreilly
书
“用Apache进行流处理”和
flink
项目中运行第一个示例。每个错误都是不同的 .https://github.c
浏览 7
提问于2020-04-05
得票数 1
回答已采纳
1
回答
StreamExecutionEnvironment和StreamTableEnvironment在
Flink
中的区别是什么?
、
、
我读过官方医生的
书
,但还是找不出他们的不同之处。 此外,我试图编写一个
Flink
流作业,它接收来自Kafka的数据。在这种情况下,我应该使用哪种环境?
浏览 1
提问于2020-05-30
得票数 0
回答已采纳
1
回答
需要关于从
Flink
DataStream作业迁移到
Flink
状态函数3.1的建议
、
、
我有一个工作
Flink
工作建立在
Flink
数据流上。我想根据
Flink
有状态函数3.1重写整个作业。我的目标我读过医生的
书
,并有了一些想法。我的计划是: --不再需要处理卡夫卡了,Kafka Ingress()处理它,基于java重写我的工作。合并很简单。但是窗口functions?Maybe我应该使用持久化状态与TTL来模拟窗口函数behav
浏览 4
提问于2022-01-08
得票数 0
回答已采纳
1
回答
Flink
检查点持续失败(等待InitProducerId时超时)
、
Flink
中的每个检查点都由于超时而失败,在作业的异常部分中,它会显示以下错误,但是作业本身并没有失败: org.apache.kafka.common.errors.TimeoutException:
Flink
书
“使用Apache进行流处理”建议仔细修改Kafka配置,例如acks、log.flush.interval.messages、log.flush.interval.ms和log.flush不过,我们已经在
Flink
1.9.1下进行了这项工作,但是自从我们升级到1.11.1之后,它就不再工作了。另外,
F
浏览 19
提问于2020-09-24
得票数 2
回答已采纳
1
回答
除了一个胖jar之外,所有东西都会在停靠的
flink
集群中失败。
、
flink
Dockerfile: ADD http://central.maven.org/maven2/org/apache/
flink
/
flink
-connector-kafkaorg/apache/
flink
/
flink
-avro-confluent-registry/1.7.2/
flink
-avro-con
浏览 0
提问于2019-04-12
得票数 1
回答已采纳
2
回答
AbstractCassandraTupleSink的实现是不可序列化的。
、
、
token, 1)); } } 运行这段代码后,我得到了以下错误: 线程"main“org.apache.
flink
.api.common.InvalidProgramException
浏览 0
提问于2018-12-24
得票数 0
回答已采纳
2
回答
Apache 1.14.0 -无法通过Java中的SQL使用python
、
、
input_types=[DataTypes.INT()], result_type=DataTypes.INT()) return a + 1➜
flink
-1.14.0 .ret1 = tEnv.executeSql("select add1(3)"); }然后通过
Flink
客户端运行作业:
flink
run
浏览 6
提问于2021-12-03
得票数 3
1
回答
找不到org.apache.
flink
.streaming.api.scala.DataStream的Apache类文件
、
我使用代码中导入的下列依赖项:import org.apache.
flink
.api.java.tuple.Tuple2;import org.apache.
flink
.streaming.api.environment.StreamExecutionEnvironment; impo
浏览 2
提问于2018-03-24
得票数 4
回答已采纳
2
回答
intellij找不到
Flink
测试Harness util
、
、
、
我试图使用Apache (org.apache.
flink
.streaming.util.OneInputStreamOperatorTestHarness)中的OneInputStreamOperatorTestHarness
浏览 5
提问于2021-12-20
得票数 -1
1
回答
Flink
与kafka Sink未能执行: java.lang.LinkageError:加载程序约束违反
、
、
:
flink
-annotations</exclude> <exclude>org.apache.<
浏览 0
提问于2018-11-19
得票数 0
2
回答
使用卡夫卡主题时的org.apache.
flink
.streaming.api.checkpoint.CheckpointNotifier :ClassNotFoundException
、
、
我使用的是最新的
Flink
-1.1.2-Hadoop-27和
flink
-连接器-kafka-0.10.2-Hadoop 1罐。
Flink
消费者如下:以下是执行后得到的例外情况: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache&
浏览 2
提问于2016-10-14
得票数 7
回答已采纳
2
回答
IntelliJ集成开发环境警告
Flink
CEP未知错误
、
、
、
我开始研究用Scala语言编写的Apache
Flink
的CEP库,当我试图通过执行https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/
flink
-cep-scala libraryDependencies += "org.apache.
flink
" %% "
flink
-cep-scala" % "1.9
浏览 50
提问于2020-01-14
得票数 0
回答已采纳
1
回答
Flink
群集启动错误:无法解决ResourceManager地址akka
我试图在win10专业版的桌面上运行
flink
集群。文档:ADD build/libs/demoapp-service-all.jar /opt/
flink
/usrlib/demoapp-service-all.jarADD conf/
flink
-conf.yaml /opt/
flink
&
浏览 2
提问于2020-11-25
得票数 3
1
回答
如何从Kubernetes中的
flink
docker镜像启动我的jar应用程序?
、
、
我用maven编译了我的项目https://github.com/felipegutierrez/explore-
flink
,并用这个Dockerfile扩展了默认的
flink
图像
flink
:1.11.1/java/explore-
flink
/opt/explore-
flink
RUN mvn clean install FROM
浏览 89
提问于2020-09-21
得票数 1
回答已采纳
2
回答
如何使用
Flink
的TestHarness类?
、
通过阅读,我得出结论,我应该使用per:https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling我原以为它可能是在
flink
-test-utils-junit中实现的,但事实并非如此。
浏览 104
提问于2019-02-16
得票数 0
回答已采纳
2
回答
在Scala中找不到RestHighLevelClient
、
、
、
我的目标是从
Flink
获得一个流,并将其插入到ElasticSearch中,感谢您的帮助。
浏览 0
提问于2020-02-05
得票数 0
1
回答
波束闪动: org.apache.beam.runners.
flink
.translation.wrappers.streaming.WorkItemKeySelector :ClassNotFoundException
、
、
、
我正在尝试使用光束和
Flink
runner设置一个流处理管道。
Flink
是具有以下docker-compose文件的本地会话部署: version: "3" jobmanager: container_name:
flink
-jobmanager
FLINK
_PROPERTIES: "jobmanager.rpc
浏览 94
提问于2021-01-29
得票数 3
1
回答
Flink
1.12找不到在类路径中实现'org.apache.
flink
.table.factories.DynamicTableFactory‘的标识符“kafka”的任何工厂
我有一个在本地运行良好的
Flink
作业,但是当我尝试在集群上
flink
run作业时失败了。它基本上是读卡夫卡,做一些转换,并写到一个水槽。这是我的pom.xml,包括
flink
-connector-kafka。 </dependency> <groupId>org.apache.
flink</e
浏览 16
提问于2021-03-10
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Flink CDC 如何与其他 Flink 特性集成?
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券