腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
由于MapR工件问题,无法从源代码构建
Flink
、
摘要:找不到mapr依赖项,因此在主分支上构建
Flink
失败。Failed to execute goal on project
flink
-mapr-fs: Could not resolve Failed to collect dependencies at com.mapr.hadoop:maprfs:jar:5.2.1详细信息: org.apache.maven.
浏览 42
提问于2019-07-19
得票数 1
回答已采纳
1
回答
我可以和PyTorch/Tensorflow/ScikitLearn/Xgboost/LightGBM?一起使用PyFlink吗?
、
、
我正在探索PyFlink,我想知道是否有可能将PyFlink与ML工程师通常使用的所有ML库一起使用: PyTorch、Tensorflow、Scikit Learn、Xgboost、LightGBM等等。考虑到PyFlink类似于PySpark,我想答案可能是“不”。但是我很想再次检查一下,看看我需要做些什么来使PyFlink能够使用这些ML库来定义UDF。
浏览 2
提问于2021-03-15
得票数 0
回答已采纳
2
回答
org.apache.
flink
.connector.kafka.source.KafkaSource java.lang.ClassNotFoundException:
Flink
、
、
我使用Kafka作为
Flink
job的数据源。当我将作业部署到
flink
集群作业管理器时,我收到一个错误ClassNotFoundException:Caused by: java.lang.ClassNotFoundException: org.apache.
flink
.connector.kafka.source.KafkaSource</groupId> <artifactId>
flink
-connector-kafka_2.12</arti
浏览 489
提问于2021-08-28
得票数 0
回答已采纳
1
回答
Apache SBT依赖失败
、
、
、
我正在尝试使用带有RabbitMq流连接器的
Flink
。尝试了所有可能的版本组合,但仍然失败。json4sNative = "org.json4s" %% "json4s-native" % "3.3.0" "org.apache.
flink
" %% "
flink
-scala" % flinkVersion % "provided", "org.
浏览 0
提问于2016-03-08
得票数 2
1
回答
Flink
文件系统支持
博士说“一个不完整的列表”。我在哪里可以找到一个完整的?
浏览 5
提问于2018-08-08
得票数 0
1
回答
如何在sbt/apache
项目
中从资源文件夹中打开文件
、
、
、
、
我正在使用apache开发一个基于scala的
项目
,到目前为止,我只在IntelliJ中运行我的
项目
,它没有出现任何问题。这在IntelliJ中有效,但在
flink
运行时不起作用。currentPath = Paths.get(filePath)所有三个变体都在IntelliJ中工作,而不是
flink
请注意,以下将在IntelliJ和
flink
运行时中同时工作: val source = Source.fro
浏览 2
提问于2018-12-12
得票数 4
1
回答
eclipse导入的maven
项目
无法解析其他导入的maven
项目
中的符号
、
、
、
、
我从它的git克隆导入了"
flink
“
项目
,并配置了相关设置。我可以用"mvn“在命令行中成功编译/打包它。 有几个
项目
报告了无法解析符号的错误。例如:“无法解决/
flink
-streaming-java_2.10/src/main/java/org/apache/
flink
/streaming/runtime/operators/windowing"Mat
浏览 5
提问于2016-04-24
得票数 3
1
回答
原因: java.lang.ClassCastException: org.apache.hadoop.fs.s3a.S3AFileSystem无法转换为org.apache.hadoop.fs.FileSystem
我可以从IntelliJ运行我的
Flink
作业没有问题,但是当我尝试在
flink
standalone上运行它时……./
flink
-1.4.0/bin/
flink
run ..<exclude>org.apache.
flink
:
flink<
浏览 3
提问于2018-01-24
得票数 0
2
回答
我甚至不能为Apache制作最基本的jar文件
急切的执行函数,在第145行,所以我尝试重新上传jar文件,这次删除了print(),我得到了一个不同的错误,它说: 2022-01-07 17:15:56,391 ERROR org.apache.
flink
.runtime.webmonitor.handlers.JarRunHandler
浏览 32
提问于2022-01-07
得票数 0
3
回答
使用maven依赖项触发版本不匹配
、
、
</groupId> <version>1.3.2</version><dependency> <artifactId>
flink
-clients_2.11&
浏览 19
提问于2017-11-28
得票数 0
回答已采纳
1
回答
用gradle代替maven的利弊
、
、
、
我正在做一个
项目
,在这个
项目
中我制作了一个
flink
数据流程序,并将代码的第一次运行转移到了另一个团队,以便他们可以查看它。他们都是大级别的用户,并问我是否有任何缺点或好处切换到使用gradle,而不是在未来的
flink
项目
使用maven。有两个git集线器repos,我发现乍一看,它们看起来像是在
flink
项目
上实现gradle,但仅此而已。( 1.)是否有“如果
flink
浏览 1
提问于2017-05-09
得票数 2
回答已采纳
2
回答
Flink
Scala缺失导入
、
、
在我的
Flink
项目
中,我找不到连接器的某些库(具体来说,我需要吃一次CSV,在批处理或流模式下读取几个块数据的TBs )。>
flink
-connector-filesystem_${scala.binary.version}</artifactId>我是否需要一个与Java不同的Scala导入路径?我希望
Fli
浏览 26
提问于2022-11-14
得票数 0
2
回答
无法在由ClassNotFoundException引起的
Flink
仪表板版本1.3.2中执行CEP模式
、
、
我在仪表板和IntelliJ中都使用
Flink
1.3.2。ClassNotFoundException说,当我从源代码构建
Flink
时,我看到了很多警告消息,这使我相信迭代条件类没有包含在jar中,因为错误也是如此。下面是错误 Caused by: java.lang.NoClassDefFoundError: org/apache/
flink
/cep/pattern/conditions/IterativeConditionjava.lang.Class.getMethod0(
浏览 1
提问于2017-10-28
得票数 0
回答已采纳
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
回答
将
项目
的非稳定版本添加到另一个maven
项目
、
我有一个maven
项目
,我在其中添加了
flink
库的依赖项,如下所示: <repository> </repositories> <dependency> <groupId>org.apache.
flink
<&
浏览 0
提问于2016-12-05
得票数 1
1
回答
Flink
scala
项目
依赖于
flink
java
项目
,因此调用java映射而不是scala映射
、
我想创建一个用scala编写的
flink
项目
。当我导入时'
flink
-streaming-scala_2.11'我可以运行如下代码:但我看到每一个都是这样:
flink
-
浏览 6
提问于2017-07-23
得票数 0
回答已采纳
1
回答
org.apache.
flink
.api.java.io.jdbc.JDBCInputFormat不在
FLINK
罐子里
、
我已经在eclipse-jee-kepler-SR2-win32-x86_64中创建了一个新的Java
项目
。 为什么Eclipse找不到导入?因为在jar
flink
-java-0.8.1.jar中没有io/jdbc目录。我在
flink
-0.9.0-bin-hadoop27 27中尝试了同样的方
浏览 2
提问于2015-07-02
得票数 1
回答已采纳
2
回答
运行用maven构建的jar时的FlinkMLTools NoClassDef
、
、
、
、
java.lang.NoClassDefFoundError: org/apache/
flink
/ml/common/
flink
ml$ 事实上,我的全球
项目
包含其他
项目
(并且这个推荐者是子
项目
之一)。这样,我必须在正确
项目
浏览 1
提问于2015-07-15
得票数 4
回答已采纳
5
回答
Flink
Scala ClassNotFoundException:
Flink
、
、
、
、
我是
Flink
的新手,我一直在遵循SocketWindowWordCount的例子。: org.apache.
flink
.api.common.typeinfo.TypeInformationimport org.apache.
flink
.streaming.api.scala" %% "
flink
-scala" % flinkVersion, "org.apache.
flink
" %% "
flink
-st
浏览 7
提问于2017-10-27
得票数 4
1
回答
如何声明
Flink
sbt跨版本依赖项?
、
、
我想使用sbt交叉编译特性用Scala2.10和2.11编译一个
项目
。问题是这个
项目
包含一些
Flink
依赖项。但是
Flink
jars不遵循标准的二进制格式(用_2.10或_2.11修改名称):scala jars没有后缀,而有它。 "org.apache.
flink
" % &q
浏览 3
提问于2016-01-15
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券