腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Apache
Flink
中
阅读
超过
22列
的
CSV
、
、
到目前为止,我一直在做
的
是按如下方式读取
CSV
: var transfer: Double,} 如中所指定
的
。但现在我正在尝试读取一个有53列
的
CSV
。有没有办法让这个过程自动化呢?我需要创建
浏览 2
提问于2018-08-30
得票数 1
1
回答
Apache
Flink
上
的
吞吐量和延迟
、
、
、
、
我为
Apache
编写了一个非常简单
的
java程序,现在我对统计数据感兴趣,比如吞吐量(每秒处理
的
元组数)和延迟(程序处理每个输入元组所需
的
时间)。StreamExecutionEnvironment.getExecutionEnvironment(); .map(new MyMapper().w
浏览 1
提问于2017-06-16
得票数 2
回答已采纳
1
回答
如何在sbt/
apache
项目中从资源文件夹
中
打开文件
、
、
、
、
我正在使用
apache
开发一个基于scala
的
项目,到目前为止,我只
在
IntelliJ
中
运行我
的
项目,它没有出现任何问题。现在我第一次创建一个JAR文件,然后由
apache
运行时执行,我遇到了打开资源文件
的
问题。root src
浏览 2
提问于2018-12-12
得票数 4
2
回答
Apache
:无法为指定
的
execution.target找到兼容
的
工厂(=local)
我决定尝试一下
apache
。我决定使用scala控制台(或者更准确地说是)从
csv
文件
中
读取一些内容,并在本地打印它.只是为了调试结束实验。import $ivy.`org.
apache
.
flink
::
flink
-scala:1.10.0` import org.
apache
.
flink</e
浏览 3
提问于2020-02-25
得票数 2
回答已采纳
1
回答
在
AWS EC2 Linux 2上运行java FileNotFoundException,但文件在那里
、
、
我
的
.jar文件(
Apache
Flink
集群
的
java输入)
中
的
某个方法调用中断,出现以下异常:正如标题所说,文件确实位于该路径,为了仔细检查,我
在
一个实际不存在
的
文件上运行了该方法,并注意到,虽然异常类型相同,但堆栈跟踪明显不同。org.
apache
.
flink
.runtime
浏览 5
提问于2021-01-15
得票数 0
1
回答
Flink
linearRegression:如何加载数据(Scala)
、
、
我开始
在
Flink
中
训练一个多元线性回归算法。我正在跟踪可怕
的
和。我正在使用齐柏林飞艇来开发这个代码。/quake.
csv
") res13: org.
apache
浏览 10
提问于2017-05-31
得票数 0
回答已采纳
2
回答
Apache
:无法将表对象转换为DataSet对象
、
我
在
Flink
1.4.0上使用表API。我有一些Table对象要转换为DataSet类型
的
Row。该项目使用Maven构建,并在IntelliJ上导入。
浏览 1
提问于2018-03-04
得票数 0
回答已采纳
1
回答
Flink
表API流S3接收器引发SerializedThrowable异常
、
、
、
我试图使用
flink
1.15.1编写一个简单
的
表API S3流接收器(
csv
格式),并面临以下例外:at org.
apache
.
flink
.formats.
csv
.CsvBulkWriter.finish(CsvBulkWriter.java:110) ~[
flink
-
浏览 20
提问于2022-07-11
得票数 0
回答已采纳
2
回答
Apache
1.3
中
的
Elasticsearch 5连接器
、
、
通过
阅读
文档,我了解到使用
Apache
1.3,我应该能够使用ElasticSearch5.x。但是,
在
我
的
pom.xml
中
: <groupId>org.
apache
.
flink
</groupId> <artifactId>
flink
-connector-elasticsearch5_2.10</artifactI
浏览 2
提问于2017-06-08
得票数 3
回答已采纳
1
回答
DataSets
在
ApacheFlink联盟
、
、
我试图将一个Seq[DataSet(Long,Long,Double)]与
Flink
中
的
单个DataSet[(Long,Long,Double)]结合起来: ).collect() 其中图是一个常规scala集合,但可以转换为DataSet;结果是一个DataSet[Vector],不应该收集,并且
在
邻居方法
中
是必需
的
我总是得到FlinkRuntime
的
浏览 1
提问于2015-07-24
得票数 4
回答已采纳
1
回答
org.
apache
.
flink
.api.java.io.jdbc.JDBCInputFormat不在
FLINK
罐子里
、
我已经
在
eclipse-jee-kepler-SR2-win32-x86_64
中
创建了一个新
的
Java项目。 所有的进口产品都运行得很好。我
在
flink
-0.9.0-bin
浏览 2
提问于2015-07-02
得票数 1
回答已采纳
1
回答
Flink
从Hadoop读取数据并发布到Kafka
、
、
因为它们是DataSet和DataStream API
的
一部分,所以可以
在
一个工作
中
完成我想要做
的
事情吗?
浏览 34
提问于2020-04-29
得票数 0
回答已采纳
0
回答
分析
Flink
中
的
CSV
时,引号字段内
的
转义引号
、
在
Flink
中
,使用readCsvFile解析
CSV
文件会在包含引号
的
字段
中
引发异常,如"Fazenda São José ""OB"" Airport":08:49:05,7
浏览 4
提问于2016-07-11
得票数 4
1
回答
远程群集上
的
RegisterInputOutput()错误,
Apache
Flink
在
Apache
Flink
的
本地版本
中
执行以下代码不会生成任何错误,但在远程集群上会生成以下错误!如有任何帮助,我们不胜感激!personRecords = env.readCsvFile("dataPath/dataset.
csv
") at org.
apache
.
flink
.
浏览 0
提问于2015-12-08
得票数 1
1
回答
使用本地系统
的
pyflink读取批处理模式
的
csv
文件
、
、
、
我试图在编写pyflink作业时读取一个已建立
的
csv
文件。我使用文件系统连接器来获取数据,但是
在
ddl上执行execute_sql()之后,然后对表执行查询,我得到了一个错误,这说明它无法获取下一个结果。我无法解决此错误。我已经检查了
csv
文件,它是完全正确
的
,并与熊猫一起工作,但在这里,我不知道为什么它不能获取下一行。如需参考,请查找所附代码。at org.
apache
.
flink
.formats.
csv
.CsvFileSystemFormatFa
浏览 22
提问于2021-03-11
得票数 0
2
回答
Apache
-
Flink
Quickstart -读取
CSV
文件错误:期货
在
[10000毫秒]之后超时
、
、
、
我想通过以下代码
在
本地使用
Flink
-API读取
CSV
文件:List<Tuple2<String, Double>>
csv
= env.readCsvFile:408)at org.
apache
.<em
浏览 22
提问于2017-01-11
得票数 0
1
回答
Flink
(1.11.2) -尽管设置了正确
的
插件,但无法找到S3
的
实现。使用JDK11和Scala 2.12.11
、
我正在使用Linux
中
的
Docker运行一个带有单个节点
的
Flink
独立集群。我已经
在
Flink
1.10.0和JDK8
的
生产环境
中
运行了一段时间
的
前一个版本,我能够让S3在那里正常运行。看起来S3方案没有被映射到适当
的
类。我确信
Flink
正在挑选合适
的
插件。%% "scalatest" % "3.2.0" % "test"
浏览 65
提问于2020-09-29
得票数 1
4
回答
CSV
支持
的
带标题
的
Flink
SQL表
、
、
我已经
在
谷歌上搜索了20分钟了。我已经浏览了
Apache
Flink
文档,特别是,但是还没有找到跳过第一个标题行
的
方法。,309 'format' = '
csv
' 我
在
sql-client.sh上看到
的
错误是: [
浏览 4
提问于2021-05-15
得票数 1
1
回答
将风暴拓扑转换为
flink
-“未指定入口类”?
、
、
我通过gradle将拓扑构建到一个.jar文件
中
,并通过
flink
web接口提交它,并得到以下消息:“没有指定
的
条目类”。通过cmd行提交作业给我显示了以下消息: org.
apache
.
flink
.client.program.ProgramInvocationException:文件
中
既没有“主类”,也没有“程序类
在</
浏览 2
提问于2015-10-25
得票数 3
回答已采纳
1
回答
Flink
-如何将JVM选项传递给CLI
、
、
我想在我
的
工作
中
添加一个JVM选项。因此,我
在
flink
- line . the
中
添加了以下一行:但在CLI日志
中
浏览 0
提问于2018-03-01
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Flink 1.10.0 重磅发布,年度最大规模版本升级
官宣:Apache Flink 1.14.0 发布
Flink创始团队二次创业再被收购,Kafka母公司与阿里“遭遇战”已经开始
Apache Flink本地安装及Example运行
什么是 Apache Flink?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
云直播
对象存储
活动推荐
运营活动
广告
关闭
领券