Flink作业失败，错误信息如下 2020-12-02 09:37:27
java.util.concurrent.CompletionException: java.lang.reflect.UndeclaredThrowableException: The rpc invocation size exceeds the maximum akka framesize.at org.apache.flink.runtime.rpc.akka.AkkaI
浏览 237提问于2020-12-02得票数 1
回答已采纳
1回答
我用Java编写了一个Flink流作业，它加载一个包含订阅者数据(4列)的csv文件，然后从套接字流中读取数据，同时与订阅者数据进行匹配。最初，我使用的是一个小型csv文件(8MB)，一切正常：
# flink run analytics-flink.jar 19001 /root/minisubs.csv /root/output.csvFlat Map -> Filter -> Map -> Stream Sink(1/1) switched to R
浏览 0提问于2015-11-02得票数 3
我有一个MapReduce作业，这是每天运行。但它失败了，出现以下异常:-
java.io.IOException:超过最大作业大小: 5437618限制: 5242880。我能知道这个问题的根本原因吗？作业的输入路径保持不变。
浏览 0提问于2014-06-11得票数 0
谢谢,
单元历史file=/tmp/hadoop/hive_job_log_hadoop_201310040052_1692176679.txt总MapReduce作业=2启动作业，在未指定的减少任务数量中占从输入数据大小估计: 10为了更改减速器的平均负载(以字节为单位)：设置hive.exec.reducers.bytes.per.reducer=以限制减速器的最大数量:设置hive.exec.reducers.max=以设置一个恒定的减速器数:设置mapred.reduce.tasks=
浏览 9提问于2013-10-04得票数 1
回答已采纳
我的工作经常伴随着这样的信息：如果有人能解释斯派克说出这条信息时在做什么，那就太好了。这个信息是什么意思？用户做错了什么会导致这种情况呢？应该调整哪些可配置性？至少早在1.0.0之前，这一直是星火的一个问题，而且星火1.5.0还在继续。
浏览 0提问于2014-09-01得票数 12
我有一个算法，它递归地工作得比较深入，这样最终就会出现超过异常的最大堆栈大小(而不是无休止的递归！)。
我的算法可以拆分自己，使用asap异步进行，但是每次这样做都会极大地减缓执行速度。我希望有一种(快速)方法来找出当前堆栈使用率，所以我的算法可以决定在低于90%的情况下同步继续，但当它超过90%时异步地继续。我知道这个值必须在内部，但是有什么方法可以访问它吗？另一方面，我可以想象捕获的最大堆栈大小超过错误，但我，这是不可能的(为什么不呢？抛出此异常将意味着返回到<em
浏览 6提问于2017-06-24得票数 2
回答已采纳
我们有一个Flink作业，从hive读取数据，并与来自kafka的流数据连接。它可以在Yarn上成功运行，但当我们在Kubernetes上使用完全相同的内存设置运行它时，它失败并出现错误 java.io.IOException: Insufficient number of network543)
\tat java.lang.Thread.run(Thread.java:748) 我按照指令增加了taskmanager.memory.network.fraction，但由于对象模型的原因，它失败
浏览 163提问于2021-03-16得票数 0
回答已采纳
2回答
01:03:11 INFO mapreduce.Job: Task Id : attempt_1415950730849_0001_m_000000_0, Status : FAILED
Error: java.io.IOException
浏览 4提问于2014-11-14得票数 3
回答已采纳
1回答
托管照相机服务的进程意外死亡。
、、、、
因此，问题必须出现在我的代码中： Log.performanceEnd{ }
}我总共挑选了三张照片，然后调用我的我试着评论所有的jni代码，它仍然在发生，所以我认为问题肯定在这里，在我的YUV方法中，或者在突发HDR调用中。最后，
浏览 2提问于2016-07-13得票数 4
回答已采纳
1回答
对于我的类，我们将实现一个带有输出重定向的shell。我让输出重定向正常工作，除了我的第一个命令总是损坏请参阅：H<@?4echo$ echo this does work但是之后的每一个命令看起来都很好。我应该使用什么技术来找出导致这个问题的bug呢？
我认为这与没有正确洗手有关。我把它分散在我的代码周围(这很愚蠢)，看看它在循环期间是否会有帮助，但它没有。我还尝试打印出我的OrderedIds列表，这只是一个命令列表，用于检查我是否可以在任
浏览 0提问于2013-03-02得票数 0
回答已采纳
我的内核调用失败，并显示“内存不足”。它大量使用了堆栈帧，我想知道这是否是它失败的原因。使用--ptxas-options=-v调用nvcc时，它会打印以下配置文件信息：我尝试了每个块1个线程，以及每个块32个线程。同样的“内存不足”。另一个问题:如果寄存器的总数不超过</em
浏览 2提问于2011-10-19得票数 7
回答已采纳
培训基本上是有效的，但是当谈到拯救模型时，我得到了一个org.apache.spark.SparkException，它说：
195:
19
浏览 2提问于2016-04-18得票数 1
1回答
我试图在AWSEMR中执行带有默认设置的星火作业，这意味着默认容器内存是1.4GB。对于某些表，它工作正常，当我们处理大容量表时，我们得到的错误低于错误。诊断:应用程序application_1527024725057_17128失败2次，原因是appattempt_1527024725057_17128_000002的AM容器与exitCode：-104当数据超过1.4GB时，资源经理将杀死该作业，并在失败状态下执行。以上问题我需要一些帮助。
改变ser-site.xml中的任何属性值
浏览 1提问于2018-07-12得票数 2
回答已采纳
3回答
我已经在我的application.conf中定义了一些akka远程设置： actor { } enabled-transports = ["akka.remote.netty.tcp但我需要忽略akka配置设置。因此，我在第二
浏览 3提问于2020-08-27得票数 0
我有一个玩具Flink作业，从三个卡夫卡主题，然后结合所有这三个流。仅此而已，没有额外的工作。如果在我的Flink作业中使用并行性1，一切似乎都很好，因为当我更改并行性>1时，它失败了： atat org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995)
at org.apache.f
浏览 0提问于2019-03-07得票数 1
回答已采纳
我需要上传数据到大小约500mb的桶。我目前能够向servlets发送5mb的数据块，但是我不能将这些分块的对象组合在一起来将原始数据上传到S3。有没有其他方法可以实现这一点？
浏览 0提问于2015-05-20得票数 0
1回答
我使用log4j2在我的java应用程序中登录，该应用程序被配置为将日志写入文件。当磁盘空间满时会发生什么？log4j2会缓冲日志直到磁盘被刷新吗？如果是，会不会导致OOM错误？
浏览 6提问于2019-10-22得票数 1
编辑:为了更具体，我想测试我的解决方案，列表大小从0到100，包含-10000到10000之间的整数。
浏览 3提问于2012-04-02得票数 18
回答已采纳
2回答
…如果无法扩展堆栈帧，则没有错误指示。
据我所知，alloca在堆栈上分配内存，而(s)brk在堆上分配内存。来自：
那么，为什么不能使用
浏览 4提问于2017-10-14得票数 4
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
