获取和异常NotSerializableException：com.hazelcast.map.impl.proxy.MaproxyImpl
IMap<String, Policy> policyMap =jet.getHazelcastInstance().getMap(POLICY_MAP_NAME);
Utility.populatePoliciesMap(policyMap);
StreamStage<TimestampedEntry<String, Long>> streamStage = pipeline.drawFrom(KafkaSources.kafka(brokerConsumerProperties(), projectionFn, getIngestTopic()))
.addTimestamps()
.flatMap(ingestData -> traverseArray(ingestData.getMapRequestParameterTree().toArray(new String[ingestData.getMapRequestParameterTree().size()])))
.filter(hash -> policyMap.get(hash)!=null)
.window(sliding(MINUTES.toMillis(1), SECONDS.toMillis(10)))
.groupingKey(wholeItem())
.aggregate(counting())
.map((TimestampedEntry<String, Long> e) -> entry(e.getKey(), createBlacklistObjectEvent(Utility.fetchPolicy(e.getKey()), e.getTimestamp(), e.getValue())));
timestampedEntryStreamStage.drainTo(Sinks.map(BL_MAP_NAME));
线程“main”java.lang.IllegalArgumentException：“FilterFn”必须在com.hazelcast.jet.impl.util.checkSerializable(util.java:301)在com.hazelcast.jet.impl.pipeline.computeStageImpbase.attachFilter（computeStageImplosbase.java:129)在com.hazelca.jet.impl.pipeline.streamStageImpl.filter（.hazelCastJetingetstResultHandler.run(HazelCastJetingetstResultHandler.java:84)在com.visa.rls.handler.hazelCastJetingetstResultHandler.main(HazelCastJetingetstResultHandler.java:58)由:java.io.objectOutputStream.writeObject0(ObjectOutputStream.java.io.objectOutputStream.writeObjeArray（位于java.io.objectOutputStrea的putstream.writeObject0(ObjectOutputStream.java:1174)M.DefaultWriteFields(ObjectOutputStream.java:1548)在java.io.objectOutputStream.writeserialData(ObjectOutputStream.java:1509)在java.io.objectOutputStream.writeOrdinaryObject(ObjectOutputStream.writeObjectOutputStream.java:1432)在
共有1个答案
.filterUsingContext(
ContextFactory.withCreateFn(jetInstance -> jetInstance.getMap(POLICY_MAP_NAME)),
(policyMap, hash) -> policyMap.get(hash) != null
)
-
问题内容： 我在应用程序上加载一堆图像时遇到错误，我不确定是什么原因引起的。 这是他得到的错误。线135在底部。 我认为他的手机内存不足。他使用的是2010年生产的Desire HD。此方法的作用是从服务器获取图像并将其保存在哈希图中。以及将其显示在屏幕上。关于如何防止OUTMEMORYERROR的任何想法？ 我当时正在考虑建立一个计数器，如果有超过20张图像，该计数器只会清除哈希图。 Logca
-
问题内容： 我正在执行spring的简单Dependency Injection程序并获取此异常。我已经包含了common-logging1.1.1.jar和spring.jar文件。你能帮忙吗？ 问题答案： 如果你正在使用maven来管理依赖项，请在中添加以下行：
-
我使用以下代码在 NTAG213 NFC 标签上设置 AUTH0（需要密码验证的第一页）： 然而，当我在AUTH0上写00h（作为起始地址）时，总是会出现异常：“收发器失败”。 你能告诉我这里可能会出什么问题吗？
-
嘿StackOverflow社区， 关于抛出异常。一般什么时候抛出和异常，什么时候抓取？ 假设我遇到了这样的情况，我不得不退出，因为发生了一些问题，我无法从它中恢复过来。我是投还是接？ 我现在就这么做： 这样做对吗？如果我只是抛出异常会更合适吗？对不起，我是例外的新手：）
-
问题内容： 我想以编程方式调用testng。不蚀插件。 我已经关联了“ testng-6.8.21.jar”并通过eclipse运行，我在以下代码下运行： 低于异常。我如何克服这个例外。 问题答案： 更改： 通过： 所有代码是 TestNG代码是： 控制台结果：
-
问题内容： 所以我的Android Gallery中有3个文件夹。我正在尝试将这些文件夹的文件读入File数组，然后从那里将图像源转换为real 。 我的问题是引用文件数组时遇到问题。这是一些代码： 使用这些图像文件数组… 我的CreateList方法。错误是当我引用list.length时。 就像我说的那样，错误是当我使用list.length引用一个File数组时，例如我在第一个代码段中创建的