以下是stackTrace： at org.apache.flink.streaming.api.o
浏览 8提问于2018-01-16得票数 4
当我试图用flatMap操作符写出集合时，我得到了非法的状态异常(仅在高负载下)：缓冲池被破坏了，我在这里做错了什么？当flink抛出缓冲池错误时？java.lang.RuntimeException: Buffer pool is destroyed.at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriter
浏览 1提问于2019-04-02得票数 3
回答已采纳
我正在apache flink中做一个项目，我需要调用多个API来实现我的目标。每个API的结果是下一个API工作所必需的。------API1---API2----当我执行所有这些操作时，在作业运行了一段时间后，我得到了一个异常，显示“缓冲池已销毁
浏览 0提问于2019-05-02得票数 1
当我使用“java.lang.IllegalStateException”时，Flink抛出“SlidingEventTimeWindows:缓冲池被破坏”，但是当我更改为"SlidingProcessingTimeWindows堆栈跟踪如下：18:37:53,728 WARN org.apache.flink.streaming.api.operators.AbstractStreamOperator - Errorwhile emitting latency ma
浏览 2提问于2018-11-15得票数 3
回答已采纳
现在我要发送一条消息，假设它的大小是10‘s，所以我可以使用5个预先分配的缓冲区来存储该消息并调用Socket.BeginSend(IList<ArraySegment>>...)。
浏览 1提问于2011-07-04得票数 6
1回答
glfwPollEvents(); glfwTerminate();}VertexBuffer::VertexBuffer(float data[], unsigned int size) GL_CALL(glGenBuffers(1, &m_IDGL_ARRAY_BUFFER, m_ID));
void VertexBuffer::Unbind(
浏览 5提问于2021-03-09得票数 0
回答已采纳
1回答
如何在Flink中传递配置？我尝试过在flink-conf.yaml中添加这个配置，但是它没有工作。我们需要在哪里设置这个配置？为了测试该属性是否被传递给Flink，我尝试将BufferTimeout属性设置为-2在flink-conf.yaml中，但它没有抛出任何异常。当我在代码中将它设置为-2时，我有异常。这使我感到财产没有被传递给Flink。而且，我的延迟数有一个固定的模
浏览 4提问于2021-04-14得票数 0
DirectX媒体对象(DMO) 建议，为了提高效率，保存媒体示例(支持IMediaBuffer接口)的缓冲区应该集合起来，而不是不断地创建/销毁：
最简单的解决方案是为每个示例分配一个新的缓冲区，尽管这样做效率很低更好的解决方案是实现一个对象来管理缓冲区池。要做到这一点，请在IMediaBuffer实现的发布方法中编写代码，该方法在引用计数降到零时调用缓冲区管理器的方法(而不是删除自身)。然后，缓冲区管理器可以维护指向分配的缓冲区对象的指
浏览 6提问于2016-09-05得票数 4
回答已采纳
我看到这样描述这个错误的帖子。大多数原因是JavaScript是异步的，而mongoClient.close()是在回调之外调用的。这不是我的案子，但我不知道还能有什么原因。const url = "mongodb://localhost:27017/"; useNewUrlParser: true
module.exports = class Mongo
浏览 0提问于2019-02-04得票数 1
回答已采纳
我们的Flink流工作流发布消息给Kafka。KafkaProducer的“重试”机制在消息被添加到它的内部缓冲区之前不会启动。如果在此之前有异常，KafkaProducer将抛出该异常，似乎Flink没有处理该异常。在这种情况下，将出现数据丢失。在这种情况下，在将消息附加到缓冲区之前，KafkaProducer尝试获取元数据。如果KafkaProducer无法在配置的超时中获取元数据，则会引发异常。可能的解决办法(Kafka设置)：
元数据超时(metadata.fetch.tim
浏览 0提问于2017-02-02得票数 0
1回答
我们正在尝试使用RocksDB后端设置一个有状态的Flink作业。我们使用会话窗口，间隔30分钟。我们使用aggregateFunction，所以不使用任何闪烁状态变量。我们总共使用了10G内存和Flink 1.9,128个容器。512mb
taskmanager.network.memory.max: 2560mb 从我们对给定时间的监控来看，rocksdb内存大小小于10m，我们的堆使用量小于1G，但我们的直接内存使用量(网络缓冲区缓冲池/缓冲区使用指标都为1(满)。我们的
浏览 58提问于2020-10-13得票数 3
回答已采纳
(所讨论的代码不允许动态分配内存；允许它使用的所有内存都是由调用者作为单个缓冲区提供的。我不能说pthread可能会分配内存，但这并不意味着允许我的代码这样做。)在创建数据时，这很容易处理，因为该函数可以检查pthread_getspecific的结果:如果返回NULL，则可以在此处获取全局池的互斥锁，然后获取池条目，并使用pthread_setspecific当线程被销毁时，析构函数(根据pthread_key_create)会被调用，但是pthread手册对可能存在的任何限制都有些含糊。因此，我可以保
浏览 2提问于2010-11-17得票数 0
回答已采纳
为什么Apache的(有用的) org.apache.commons.pool.impl.commmons.pool.GenericObjectPool.addObject()被声明抛出异常，有什么很好的理由吗
浏览 5提问于2013-10-15得票数 2
4回答
；但是放弃第三方库资源就是抛出异常(但可以立即重新获取，这是很奇怪的！)。还有一个这种资源的池，比如一个Sample类的数组/容器。因此，有两种情况需要考虑:销毁动态分配的对象和销毁动态分配的对象数组。分配的内存会发生什么情况？这是不确定的行为吗？在数组的情况下会发生什么？是否调用数组中所有元素的dtor (至少不是内存)(例如，如果第一个元
浏览 2提问于2009-05-08得票数 2
回答已采纳
我有一个缓冲池实现，它基本上通过allocate()/release() API提供预先分配的release()对象。为了检测调用方忘记调用发布和ByteBuffer引用被泄露的情况，我使用了番石榴的FinalizableReferenceQueue和FinalizablePhantomReference. finalizeReferent此外，我需要有选择地销毁缓冲池，并将其替换为具有不同配置的更新缓冲池。为此，我将以前的SampleBuf
浏览 12提问于2022-05-11得票数 1
4回答
实现一个简单的线程池
、、、
当然，我理解线程池背后的基本思想，但对于我来说，一些实现细节仍然有些不清楚。这可能是因为我需要的线程池有点特别。让我来描述一下。我有一项任务在特定的(大型)缓冲区上执行了几十万次。我已经测量到，如果我使用线程来完成这个任务，那么性能会更好--缓冲区被分割成子缓冲区，每个线程在子缓冲区上执行其任务并返回结果。然后将所有线程的所有结果加在一起，给出最后的解决方案。所以我希望有一个线程池来执行这个任务，而不是每次创建一个新的线程集。我想要做到的是：
thre
浏览 5提问于2012-03-06得票数 2
回答已采纳
1回答
集群Infra:java.lang.RuntimeException因此，根据我的理解，Flink内部创建了一个为端提供哈希表的哈希表，即第一或第二部分数据被迭代到哈希表，反之亦然，而且由
浏览 3提问于2020-09-04得票数 1
回答已采纳
我有一个简单的客户端应用程序，它以低吞吐量从网络接收字节缓冲区。由于线程池(或IOCP线程池)以及吞吐量非常稳定，我本来希望线程被重用。
编辑：“低”吞吐量是每秒20条消息(大约200 KB/s)。
浏览 8提问于2014-08-12得票数 10
回答已采纳
我正在尝试写案例类序列化到AVRO到HDFS使用RollingSink在Flink。为了让avro文件可以被HDFS反序列化，我使用了包装FSDataOutputStream的DataFileWriter。当我试图在DataFileWriter和FSDataOutputStream之间同步以便关闭HDFS上的数据文件时，抛出异常，实际上我每隔一个文件就会得到数据。有没有办法在Flink writer实现中同步fs流和Avro编写器？
我尝试过使用DataFileWriter close()、flush()、sync()、f
浏览 1提问于2016-03-24得票数 0
1回答
下面是初始化任何ejb对象时遇到的异常。有谁能说出例外的原因是什么，我如何解决？提前谢谢..。等待回应..。ation of method "init" on bean "BeanId(RDxEAR#vs-tle-beans-server.jar#VLSContextHome, C5E6CB
浏览 0提问于2010-07-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
