我有一个Flink流媒体应用程序，它在Kyro.copy上花费了大约20%的CPU时间。我可以通过打开对象重用模式来避免这一点，但我有一个小问题:我想将输入对象修改为我的运算符。对象重用模式的一般约定似乎是这样的:从map函数返回后，不要修改输入对象或记住输入对象。您可以在output之后修改对象并重新发射它们。(例如：)
现在
浏览 18提问于2020-03-04得票数 2
回答已采纳
我正在读取文档，它给出了重用对象的用例，如下所示： .apply(new WindowFunction<WikipediaEditEvent, Tuple2<String, Long它是否适用于所有操作符，在这些操作符中，我们可以通过collector.collect(...)调用变异并传递管道中的同一个对象？Tuple2.of(value.getCountry(), value.getEmployer()); }我想知道这种情况，我是否可以重复使用相同的元组，用不同的<
浏览 7提问于2021-06-20得票数 0
回答已采纳
1回答
对于Flink流/ Flink有状态函数，众所周知，对于小值(例如5ms)的setBufferTimeout将提供“最佳”延迟体验。其他推荐的配置值是什么，您必须注意(设置、重置、修改.)当优化Flink流或有状态函数中的延迟时，作业？
浏览 8提问于2020-09-18得票数 1
回答已采纳
在Flink中的迭代DataStream循环中如何处理时间戳？例如，下面是Flink中一个简单的迭代循环的例子，其中反馈循环与输入流的类型不同： }我的问题是Flink
浏览 1提问于2019-06-08得票数 0
回答已采纳
1回答
假设我有工作，
来源: kafka (byte[] data)，平面地图:解析byte[]到Google对象' foo '，创建一个Tuple2<>(foo.id，foo)，并返回这个tuple2密钥和进程:对于每个id，将第一个foo放入ValueState，如果有多个具有相同id的对象，更新ValueState。在这种情况下，打开“对象重用模式”可以吗？
浏览 1提问于2021-03-12得票数 0
回答已采纳
2回答
当要序列化时，我们需要静态地输入/声明变量的数据类型吗？在序列化时，它是否提高了性能？Flink默认使用kyro序列化程序
浏览 9提问于2020-05-07得票数 0
回答已采纳
如果两个运算符正在处理相同的上游，每个运算符是接收每个元素的副本还是处理相同的元素。例如，在以下代码中： DataStream<Data> stream=...; //init a stream of datastream.process(ProcessFunctionB); //stream was processed by function A 如果ProcessFunctionA更改了数据，ProcessFunctionB会看到更改
浏览 120提问于2021-04-24得票数 1
回答已采纳
4回答
如何装饰现有Java对象的方法？
、、、、
编辑:我在描述了我们的解决方案Prior Work
我考虑过通过JavaAssist创建代理。问题是ProxyFactory的create方法要求我提前知道构造函数输入类型。这意味着，每当直接引用构造函数设置的值时，生成的对象</e
浏览 11提问于2020-01-22得票数 0
回答已采纳
我有一个要添加到flink表中的对象列表。请分享如何创建表、注册以及如何将对象添加到flink表中。String firstName: List<Something> somethings = new ArrayList<Something>();
如何创建flink表，并将列表中对象的每个实例作为新记录添加到flink表中。
浏览 2提问于2020-06-04得票数 0
2回答
当我们在Laravel中收到一个请求对象时，有没有办法修改或添加数据呢？例如，我是否可以将一个参数(不是值，而是参数名称本身)重命名为其他名称？例如，输入可能名为fname，但我想将其更改为first_name。或者，我是否可以添加原始请求中没有的新输入和值？
我这样问的原因是，我有一个接受请求对象的方法，并且需要特定的输入名称。我希望能够重用该方法，但请求输入名称将有所不同。
浏览 0提问于2016-01-20得票数 1
1回答
我想知道从Flink子任务访问这个单例类的对象的最佳方式是什么，因为在多线程环境中存在一个潜在的单例对象初始化问题。最好是使用synchronized关键字锁定单例类的初始化，还是有更好的方法在Flink运行时实例化单例对象？
浏览 42提问于2018-02-02得票数 0
但是，我通常会解析大量输入字符串，是否可以修改代码以重用现有对象进行重复调用？如果是这样，有没有人有这样的例子？
浏览 4提问于2018-02-09得票数 1
回答已采纳
我正在使用Flink与RocksDB。从Flink的文档中，我承认在使用RocksDB后端时，Flink将异步地设置检查点。见其文档中的描述。要做到这一点，运算符必须能够生成一个状态对象，该对象应该以这样的方式存储，以便对运算符状态的进一步修改不会影响到该状态对象。例如，在RocksDB中使用的复制即写数据结构具有此行为.
浏览 10提问于2020-05-25得票数 3
据我所知，使用Flink的AVRO反序列化，您可以创建一个Avro对象流，这很好，但似乎存在一个问题，Flink的kafka使用者只创建单个对象的流：FlinkKafkaConsumerBase<T>而不是默认的在我的例子中，键和值都是独立的符合AVRO模式的对象，合并它们的模式可能是一场噩梦.
另外，使用Flink，我似乎无法检索ConsumerRecord信息？
浏览 3提问于2018-11-15得票数 0
回答已采纳
因此，它有一个函数channelRead(ChannelHandlerContext ctx, Object message)我对项目所做的修改使得我不能使用channelRead()函数获取对象。我的修改是这样的： ..现在，在我获得对象之后，我想重用现有的源代码。为了重用现有的源代码，我需要对象以及ChannelHandlerContext。但是，我不知道如何正确地构造DefaultChannelHa
浏览 1提问于2015-06-28得票数 0
2回答
我使用Flink (最新的通过git)从卡夫卡流到卡桑德拉。为了简化单元测试，我通过Dagger添加了依赖注入。ObjectGraph似乎正在正确地设置自己，但是Flink将“内部对象”标记为“不可串行化”。如果我直接包括这些对象，它们就能工作-那么有什么区别呢？是否有一种方法来构建这个，以便我可以使用后期绑定，还是Flink使这不可能？
依赖注入(通过匕首)和RichMapFunction不能共存。Dagger不允许在定义中包含任何扩展的对象。此外：
通过Dagger实例化的
浏览 4提问于2015-12-06得票数 11
回答已采纳
1回答
我正在使用flink siddhi并在处理大型对象时走出内存错误。在siddhi生成的输出流中，我有超过200个字段的对象，之后我有一些操作符来处理这个对象。flink版本1.7.2 at com.esotericsoftware.kryo.io.Input.readBytes(AbstractStreamOperator.java:250)
at org.apache.flink.s
浏览 12提问于2021-12-09得票数 0
相关问题：https://issues.apache.org/jira/browse/FLINK-14380 在使用类型提取器Flink判断一个类是否符合POJO时，Flink会检查该类是否实现了setter问题位于https://github.com/apache/flink/blob/master/flink-core/src/main/java
浏览 37提问于2019-10-12得票数 2
我们的想法是实现一个KeySelector，它将其输入对象映射到特定的分区键，但是这个键可以随着时间的推移而改变。例如，映射规则可以保存在数据库中，并且KeySelector将定期或按需更新它们。我不确定这是否会对Flink的状态或流分区机制造成问题。例如，如果一个输入Foo最初映射到分区键0，但后来更改为分区键1，并且键0不再使用，那么Flink会在某个时候简单地“忘记”键0吗？
浏览 18提问于2019-06-03得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
