腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Flink
集群上找不到FlinkKafkaConsumer011
scala
、
apache-flink
、
flink-streaming
我试图
在
集群上运行
Flink
作业。这项工作
在
我
的
开发(本地)环境上运行良好。但是,当我使用命令将它部署到集群上时:如果出现错误,它将失败:Caused by: java.lang.ClassNot
浏览 1
提问于2018-07-23
得票数 1
回答已采纳
1
回答
在
Flink
1.7.2
中
接收异步异常-使用KeyedProcessFunction和RocksDB状态后端进行有状态处理
scala
、
apache-kafka
、
apache-flink
、
rocksdb
我使用
Flink
1.7.2编写了一个简单
的
字数统计应用程序,同时使用
Kafka
2.2作为消费者和生产者。我对
Kafka
生产者使用只有一次
的
语义,使用KeyedProcessFunction进行有状态处理,使用MapState保持我
的
状态,使用增量检查点
的
RocksDB作为我
的
状态后端。当我
在
IntelliJ上运行这个应用程序时,它工作得很好,但是当我把它提交到我本地
的
Flink
集群时,我收到了A
浏览 37
提问于2019-07-05
得票数 0
回答已采纳
1
回答
flink
: scala版本冲突?
java
、
scala
、
intellij-idea
、
apache-flink
我试图从
在
IntelliJ
中
编译卡夫卡
示例
。在对
依赖
关系进行了大量讨论之后,我遇到了一个我似乎无法解决
的
问题:at java.lang.ClassLoader.loadClass(ClassLoader.java:357)我遇到了一些概念,认为这是scala版本
的
一个问题
浏览 7
提问于2015-10-25
得票数 5
回答已采纳
1
回答
FlinkKafkaConsumer无法从LZ4压缩主题中读取
apache-flink
、
lz4
我们有几个阅读卡夫卡主题
的
flink
应用程序,它们工作得很好。但最近,我们向现有的
flink
作业添加了一个新主题,它在启动时立即开始失败,并出现以下根错误: Caused by: org.apache.
kafka
.common.KafkaException: java.lang.NoClassDefFoundError将lz4
依赖
项
直接添加到应用程序
中
不起作用
,奇怪
的
是,它在本地运行良好,但在远程集群上失败。
flink</em
浏览 5
提问于2020-07-31
得票数 1
回答已采纳
2
回答
Apache错误java.lang.ClassNotFoundException
java
、
maven
、
apache-kafka
、
apache-flink
我试图运行Apache,我使用
Kafka
主题作为输入,
在
尝试运行
Flink
时,我得到了以下错误: 线程"main“
中
的
异常:org/apache/
flink
/util/ org.apache.
flink
.cep.pattern.Pattern.wherejava.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppCl
浏览 3
提问于2017-11-20
得票数 1
2
回答
使用卡夫卡主题时
的
org.apache.
flink
.streaming.api.checkpoint.CheckpointNotifier :ClassNotFoundException
apache-kafka
、
apache-flink
、
flink-streaming
我使用
的
是最新
的
Flink
-1.1.2-Hadoop-27和
flink
-
连接器
-
kafka
-0.10.2-Hadoop 1罐。
Flink
消费者如下: properties = new Properties(); InputStream props = R
浏览 2
提问于2016-10-14
得票数 7
回答已采纳
2
回答
org.apache.
flink
.connector.
kafka
.source.KafkaSource java.lang.ClassNotFoundException:
Flink
apache-kafka
、
apache-flink
、
flink-streaming
我使用
Kafka
作为
Flink
job
的
数据源。当我将作业部署到
flink
集群作业管理器时,我收到一个错误ClassNotFoundException:Caused by: java.lang.ClassNotFoundException: org.apache.
flink
.connector.
kafka
.source.KafkaSource下面是我
的
pom.xml
依赖
项
<dependencies>
浏览 489
提问于2021-08-28
得票数 0
回答已采纳
1
回答
用实例建立
kafka
flink
连接器
项目
apache-kafka
、
apache-flink
由于我是卡夫卡
flink
连接器
的
新手,请帮助我提出一些简单
的
示例
程序,其中
kafka
在
一个主题中写作,
flink
侦听它,并与
pom.xml
一起显示值。
浏览 4
提问于2020-01-19
得票数 0
回答已采纳
3
回答
以卡夫卡为来源
的
Flink
kafka-consumer-api
、
apache-flink
、
flink-streaming
我正在尝试阅读卡夫卡主题
的
数据,
在
Flink
流
中
。我正在尝试运行下面的
示例
代码,作为APACHE 1.1.3文档
中
的
示例
: Apache
连接器
,import org.apache.
flink
.streaming.api.environment.StreamExecutionEnvironment; import org.apache.
flink</e
浏览 4
提问于2017-01-09
得票数 2
回答已采纳
1
回答
pom.xml
中
的
依赖
项
在
flink
kafka
连接器
示例
中
不起作用
java
、
maven
、
apache-kafka
、
apache-flink
;import org.apache.
flink
.streaming.util.serialization.SimpleStringSchemaand
Flink
says: " + value; }).print(); } }
pom.xml
<em
浏览 29
提问于2020-01-19
得票数 0
3
回答
如何在Scala中使用
Flink
的
KafkaSource?
scala
、
apache-kafka
、
apache-flink
我试图用
Flink
的
KafkaSource运行一个简单
的
测试程序。我使用
的
方法如下: import org.
浏览 3
提问于2015-07-15
得票数 5
1
回答
为什么
Flink
快速启动scala建议
在
默认范围
中
添加
连接器
依赖
项
,而
Flink
Hive集成文档则相反。
hive
、
apache-flink
、
flink-sql
连接器
依赖
项
应该在默认范围内。 <!-- Add connector dependencies here.>
flink
-connector-
kafka
_${scala.binary.version}</artifactId> <version>${
flink
.version}</version我们建议将应用程序代码及其所有必需
的
依赖
<e
浏览 2
提问于2021-04-08
得票数 0
回答已采纳
1
回答
Flink
:为什么Maven Central上没有Hive
依赖
项
flink
-sql
连接器
-hive?
maven
、
hive
、
apache-flink
根据 添加
浏览 4
提问于2021-04-02
得票数 0
回答已采纳
2
回答
从
Kafka
读到
Flink
Scala Shell
scala
、
apache-kafka
、
apache-flink
、
scala-shell
我正在尝试连接到本地机器上
的
Kafka
(2.1),并在随
Flink
(1.7.2)附带
的
shell
中
阅读。我正在做
的
事情是::require
flink
-connector-
kafka
-base_2.11-1.7.1.jar import org.apache.
flink
.streaming.conne
浏览 0
提问于2019-03-11
得票数 1
回答已采纳
2
回答
Apache
Flink
: Python流API
中
的
Kafka
连接器
,“无法加载用户类”
python
、
apache-kafka
、
apache-flink
、
flink-streaming
、
pyflink
/
flink
-1.6.1/bin/pyflink-stream.sh examples/read_from_
kafka
.py运行我
的
脚本。python脚本相当简单,我只是尝试使用现有主题中
的
内容,并将所有内容发送到标准输出(或日志目录
中
的
*.out文件,默认情况下,输出方法将在该文件中发出数据)。-0.9.0.1.jar,并将它们复制到
Flink
的
lib目录
中
。除非我误解了文档,否则这应该足以让
浏览 0
提问于2018-10-10
得票数 4
1
回答
kafka
-apache
flink
执行log4j错误
apache-kafka
、
apache-flink
、
flink-streaming
我试着用
Kafka
inegration运行一个简单
的
Apache
Flink
脚本,但我一直
在
执行
中
遇到问题。脚本应该读取来自
kafka
制作人
的
消息,详细说明它们,然后再次将处理结果发送回另一个主题。(LocalStreamEnvironment.java:46)
在
org.apache.
flink
.streaming.api.environment.LocalStreamEnvironment.executeFlinkK
浏览 5
提问于2017-07-27
得票数 0
回答已采纳
1
回答
Kafka
Consumer Java Maven模板
apache-kafka
、
confluent-platform
我想在confluent
kafka
之上编写一个
kafka
消费者。 目前最适合
kafka
用户
的
java maven模板是什么?
浏览 0
提问于2017-11-20
得票数 0
1
回答
除了一个胖jar之外,所有东西都会在停靠
的
flink
集群
中
失败。
apache-flink
、
flink-streaming
我有一个容器化
的
flink
集群,具有独立
的
JobManager和2个任务管理器。当我提交一个包含我需要
的
连接器
和代码
的
胖jar时,一切都会正常运行,但是一个只有我
的
代码
的
jar将失败--尽管我已经将
连接器
jar添加到/opt/
flink
/lib,容器进程显示它们将被添加到类路径
中
。我需要做什么才能让
flink
理解我放置
在
/o
浏览 0
提问于2019-04-12
得票数 1
回答已采纳
2
回答
对象FlinkKafkaConsumer010不是package org.apache.
flink
.streaming.connectors.
kafka
的
成员
apache-kafka
、
sbt
、
apache-flink
、
flink-streaming
import org.apache.
flink
.streaming.util.serialization.SimpleStringSchema } 我
的
问题是,当试图用这个包汇编我
的
程序时,编译器返回一个错误“build.sbt FlinkKafkaConsumer010不是包org.apache.
flink
.streami
浏览 0
提问于2020-06-01
得票数 0
1
回答
如何修复
Flink
错误:无法推断FlinkKafkaConsumer011<>
的
类型参数
java
、
apache-flink
下面是使用
Flink
和
Kafka
的
例子。我只找到像this page这样
的
结果,它们不能正确编译,并且给出了很难查找
的
错误消息。org.apache.
flink
.streaming.util.serialization.SimpleStringSchema; import org.apache.
flink
.streaming.connectors.
kafka
.FlinkKafkaConsumer011FlinkKafkaConsumer011<&
浏览 170
提问于2019-05-24
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
《从0到1学习Flink》——如何自定义 Data Source?
官宣:Apache Flink 1.14.0 发布
Flink-Connector-Kafka(一)
当 TiDB 与 Flink 相结合:高效、易用的实时数仓
当Flink遇到Kafka-FlinkKafkaConsumer使用详解
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券