腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5934)
视频
沙龙
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
回答已采纳
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
2
回答
在Scala中找不到RestHighLevelClient
、
、
、
我的目标是从
Flink
获得一个流,并将其插入到ElasticSearch中,感谢您的帮助。
浏览 0
提问于2020-02-05
得票数 0
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
回答已采纳
2
回答
出现java.lang.NoSuchMethodError异常的Flick WordCount示例失败
: org.apache.
flink
.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache/
flink
/core/memory/MemorySegmentFactory:118)at org.apache.
fl
浏览 0
提问于2017-03-17
得票数 2
1
回答
从Kafka控制台生产者将数据读入
Flink
程序
、
、
、
、
现在,我想使用下面的代码在
Flink
程序中使用console-consumer生成的输出 <artifactId>
flink
-streaming-java_2.10</artifactId> <version>${
flink
.version<groupId>org.apache.
浏览 5
提问于2017-08-22
得票数 1
2
回答
如何使用bazel使用/导入
Flink
的TestHarness类?
、
、
、
、
:
flink
-core:%s" %
FLINK
_VERSION, "org.apache.
flink
:
flink
-streaming-java_%s:%s" % (SCALA_VERSION,
FLINK
_VERSION), "org.apache
浏览 0
提问于2020-05-09
得票数 1
1
回答
如何在
flink
web中查看任务日志?
、
我可以从web中查看任务管理器的日志:但是,假设我提交了一个作业,并使用log4j2将一些日志写到一个特定的文件中,我可以做一些配置以便从web查看日志吗?
浏览 0
提问于2018-12-03
得票数 1
回答已采纳
1
回答
集群上的
flink
作业- java.lang.NoClassDefFoundError: KeyedDeserializationSchema
、
、
、
我正在尝试
flink
并在
flink
集群上部署作业时遇到异常(在kubernetes上)。设置斯卡拉- 2.11.12集群上的
Flink
对接图像-
flink
:1.4.2-scala_2.11-高寒ThisBuild / resolvers" %% "
flink
-scala" % flinkVersion % "provided", "org.apache
浏览 1
提问于2018-03-15
得票数 0
3
回答
使用maven依赖项触发版本不匹配
、
、
</groupId> <version>1.3.2</version><dependency> <artifactId>
flink
-clients_2.11&
浏览 19
提问于2017-11-28
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券