腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
捕捉
从
flink
的
readFile
(
path
)
抛出
的
异常
?
我使用
flink
监控hdfs中
的
新文件(文件为gzip格式),并对其进行处理。env.
readFile
(filePath) 它可以在文件有效时工作, 但如果gzip文件无效,
flink
作业将被终止。有
异常
日志: java.io.IOException: Error opening the Input Split hdfs://mdw:8020/user/data/15_077_4.gz [0,-1at org.apache.
flink
.r
浏览 77
提问于2021-04-17
得票数 0
回答已采纳
1
回答
flink
检查点卡在坏文件上
、
我是新来
的
flink
(1.3.2),我有一个问题,想看看是否有人可以帮助这里。我正在做内部和外部检查指向,让我们假设有一个坏
的
文件来
的
路径和
flink</e
浏览 0
提问于2018-02-06
得票数 0
3
回答
Flink
获取RuntimeContext
、
、
在我
的
Flink
代码中,我使用了一个自定义
的
输入格式,它
抛出
了一个
异常
。看起来我需要一个RuntimeContext实例,但是我怎样才能得到一个呢?我
的
format类如下所示:@transientformat, inputFile.getAbsolutePath) // throws excep
浏览 1
提问于2018-03-21
得票数 2
3
回答
尝试并捕获块:无论是在类本身中还是在调用类外部
的
方法时。
你能帮我理解我应该在哪里
抛出
异常
并抓住它们吗?请看一下我
的
密码。我以为我在课堂上已经
抛出
并抓住了
异常
。但是当我在主类FirstThread.
readFile
("ParallelProgramming.txt");,中编写时,我遇到了一个运行时错误--未处理
的
异常
。所以,我不得不试着去抓。所以,我不明白为什么在Thd课程中,我
的
尝试和
捕捉
块不起作用。.*; public class Thrd ex
浏览 2
提问于2014-03-15
得票数 1
回答已采纳
3
回答
用Java在Eclipse中创建扫描仪时
的
FileNotFoundException
、
、
、
、
(
readFile
.java:9)-
readFile
- (default package) 在bin、
readF
浏览 4
提问于2012-05-04
得票数 4
回答已采纳
1
回答
Flink
on EMR -没有输出,无论是控制台还是文件
、
、
我试图在AWS EMR上部署我
的
flink
作业(版本5.15和
Flink
1.4.2)。然而,我无法
从
我
的
流中得到任何输出。我试着创造一个简单
的
工作: def main(args: Array[String]) { new org.apache.
浏览 2
提问于2018-07-19
得票数 0
回答已采纳
5
回答
何时
抛出
FileNotFoundException
我在main方法中调用了一个名为main
的
方法,
readFile
()
抛出
了FileNotFoundException,但是main没有,如下所示:
readFile
(); Scannerinput = new Scanner(new File("file.txt"))
浏览 6
提问于2015-12-28
得票数 5
回答已采纳
1
回答
如何
在
Flink
中跳过损坏
的
消息?
如何
在
Flink
中跳过损坏
的
消息 我有DAG: KafkaSrcConsumer > FlatMap > Window > SinkFunction 现在,如果我在操作符"KafkaSrcConsumer“中
从
Kafka获得corruptedMessage,我想
抛出
/跳过该消息,并且不想将损坏
的
消息转发给下一个操作符"FlatMap”。我们
如何
在Apache
Flink
中实现这一点? (注意:
从<
浏览 27
提问于2019-04-05
得票数 0
回答已采纳
1
回答
捕捉
“找不到文件”
、
我已经搜索了一段时间,但是在PowerShell中找不到会捕获“无法找到文件”错误
的
异常
。Try { $ips= GC $env:USERPROFILE\Desktop\$
readFile
.txtCatch { }
浏览 2
提问于2015-08-05
得票数 0
回答已采纳
2
回答
用DataStream读取
Flink
中
的
CSV文件
、
、
我是Apache
的
新手,版本为1.32,我正在尝试将CSV文件读取到Datastreamimport org.apache.
flink
.api.java.io.TextInputFormatimport org.apache.
flink
.api.scala.createTypeInformationimport= "src/main/resources/sales_ord
浏览 6
提问于2021-10-04
得票数 1
回答已采纳
1
回答
跟踪事件处理器-重试源自事件处理程序
的
支出
我正在尝试为一个ErrorHandler配置一个TrackingEventProcessor,以便重新尝试TrackingEventProcessor注释方法中
的
任何
异常
。目前正在使用AxonFramework4并研究
如何
实现这一目标。
浏览 5
提问于2020-07-01
得票数 0
1
回答
使用HttpWebRequest和StreamReader下载网页时未处理
的
异常
、
、
这是一个使用C# 4.0
的
.NET应用程序。我一直试图完善一个应用程序
的
一部分,
从
多个web服务器下载文件。一切都很好,除了偶尔
的
情况下,远程计算机关闭连接。但是,目前,应用程序导致一个
异常
,由AppDomain.CurrentDomain.UnhandledException
的
处理程序获取。try/catch,但是它们没有
捕捉
到这个特定
的
错误。为了避免这个问题,我添加了最里面的尝试/
捕捉
,但没有结果。我
浏览 2
提问于2010-08-25
得票数 1
回答已采纳
2
回答
flink
什么时候开始删除RocksDBKeyedStateBackend目录?
、
我
的
Flink
作业运行了几天,没有任何问题,但是过了几天,就会关闭tm并重新启动整个作业。在日志中我发现,org.apache.
flink
.contrib.streaming.state.RocksDBKeyedStateBackend -删除现有的实例基目录/tmp/
flink
-io-4b455efa-bcdeop_KeyedProcessOperator_a1c286a47e97622aa92a8f6cd4115854__1_4__uuid_4b53ff24-e240-48d6-b438-3ab2d
浏览 5
提问于2020-10-06
得票数 0
回答已采纳
5
回答
具有不同错误消息
的
相同
异常
类型
、
、
我有两个
抛出
相同
异常
throws IOException
的
方法public static void main(String[] args) { } ca
浏览 9
提问于2017-08-28
得票数 4
回答已采纳
1
回答
如何
在
Flink
中连续读取CSV文件并删除标头
、
、
、
我正在使用
Flink
流API,我希望继续
从
文件夹中读取CSV文件,忽略头文件并将CSV文件中
的
每一行转换为Java类(POJO)。在完成所有这些处理之后,我应该获得一个Java对象流(POJO)。
从
CSV文件中获取字符串流 String
path
= "/home/cosmin/Projects/
flink
_projects/
flink
-java-project/d
浏览 2
提问于2017-08-02
得票数 2
1
回答
单元测试中Jest未捕获
的
异常
、
我正在尝试测试一些使用Jest使用await和async
的
代码。我遇到
的
问题是
抛出
了一个
异常
,但Jest似乎没有抓住它。module.exports.loadConfigFilesession.url) throw new Error(&
浏览 1
提问于2017-11-24
得票数 0
回答已采纳
1
回答
在
flink
中使用NullpointException读取RowCsvInputFormat文件时
、
、
、
、
我是
Flink
流媒体
的
初学者。代码在下面。val readLocalCsvFile = new RowCsvInputFormat( Array(Types.STRING, Types.STRING, Types.STRING), &qu
浏览 23
提问于2022-01-06
得票数 0
1
回答
如何
处理
从
定义为to
的
函数引发
的
异常
?
、
、
据说,将函数定义为noexcept将使编译器能够进行一些优化来提升程序,如果函数需要
抛出
,编译器将抑制该优化。以下是我
的
简单片段: std::vector<int> vec{2, 4, 6, 8}; // vec is a vector of 4exception const& e){ }
浏览 1
提问于2021-03-08
得票数 1
1
回答
如何
在
flink
的
readFile
方法中提到FileInputFormat?
、
我使用
flink
从
文件中连续读取数据,该文件定期附加数据。我尝试在
flink
.But中使用
readFile
方法,不知道
如何
在此方法
的
参数中提及FileInputFormat。我
的
文件格式是json。
浏览 0
提问于2017-06-21
得票数 1
1
回答
无法读取亚马逊s3上
的
拼花文件并将其加载到FlinkSql中
、
、
、
、
I成功地将csv文件数据
从
s3加载到FlinkSql本地机器中。='s3://d11-data-lake-load/
flink
/events_data/test_
flink
/test-csv',); CREATE TABLE fs_table ( usern
浏览 7
提问于2021-05-12
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何使用python删除一个文件?
JS异步编程之callback
优雅 koa处理异常
Java出现异常怎么处理 如何学好Java编程基础
Java异常处理的11大误区及经验总结
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券