问题标签 [ignite]

What is wrong with this code?? I can not escape from Task Not Serializable

Here is the ST:

我有一个 Startup+Singleton EJB，我需要在其中注入一个对象。在这个 EJB 的 PostConstruct 方法中，我需要为 Ignite 网格注册一个远程缓存事件侦听器。此侦听器的“应用”方法应调用注入对象的方法。

在 EventListenerDelegate 类中，我进一步注入了其他东西，最终将对检索到的缓存事件做一些事情。我将 Ignite 对象也传递给此类的 respondToCacheEvent 方法的原因是因为我在此方法中发出了 cache.remove。因此，如果我传递 Ignite 对象本身，很容易快速获取缓存句柄。希望这不是问题。

这部署得很好。但是当我在缓存上放一些东西时，我在“apply”方法的“listenerDelegate.respondToCacheEvent”行上得到一个 NullPointerException。这显然意味着，当 Ignite 注册监听器时，CDI 注入到那时还没有发生。或者可能问题完全是另外一回事。

我在做什么正确吗？我还能如何确保所有注入都正确发生，然后注册 remoteListener？

几年前，这个 gridgain 问题在主（发送方）节点的 Gridgain 故障转移中提出并解决

快进到今天。我们运行 gridgain 6.2.1（开源版本）并试图强制我们的 gridgain master 的高可用性（以防硬件或 master 进程失败）。从高层次的角度来看，我们通过我们定义的连续映射管理器将（可分发的）作业提交到主节点。

根据先前对该问题的接受答案，这在 2011 年是不可能的。

1. 2015 年的现状是否发生了变化，或者在新版本的 gridgain 中是否有其他策略可用？
2. 可以通过“集群组”在 ignite 中实现此功能吗？请参阅http://apacheignite.gridgain.org/docs/cluster-groups

谢谢

我使用数据网格作为我的主要“数据库”。我注意到 Hazelcast 和 Ignite 查询性能之间存在巨大差异。我通过适当的自定义序列化和索引优化了我的数据网格使用，但 IMO 的差异仍然很明显。

由于没有人在这里问过，我将回答我自己的问题以供将来参考。这不是一个抽象的（学习）练习，而是一个真实的基准测试，它模拟了我在大型 SaaS 系统中的数据网格使用情况——主要用于显示排序和过滤的分页列表。我主要想知道与原始的无框架 Hazelcast 和 Ignite 使用相比，我的通用 JDBC-ish 数据网格访问层增加了多少开销。但由于我是在比较苹果和苹果，所以这里是基准。

当我尝试连接并向本地 Ignite 节点发送 REST 请求时，有人可以解释一下这个神秘的异常吗？

请求如下所示：http: //127.0.0.1 :8080/ignite?cmd=top

Ignite 没有响应，但我在日志中看到以下内容：

[GridTcpRestProtocol] 由于未处理的异常而关闭 NIO 会话 [cls=class oaiiutil.nio.GridNioException, msg=无法解析传入数据包（无效数据包开始）[ses=GridSelectorNioSessionImpl [selectorIdx=2, queueSize=0, writeBuf=null, readBuf =null, recovery=null, super=GridNioSessionImpl [locAddr=/127.0.0.1:8080, rmtAddr=/127.0.0.1:64501, createTime=1439344656124, closeTime=0, bytesSent=0, bytesRcvd=278, sndSchedTime=1439344656124, lastSndTime =1439344656124，lastRcvTime=1439344656124，readsPaused=false，filterChain=FilterChain[filters=[GridNioCodecFilter [parser=GridTcpRestParser [jdkMarshaller=JdkMarshaller []，routerClient=false]，directMode=false]]，接受=true]]，b=47 ]]

我无法弄清楚这里出了什么问题。在网上搜索这个问题，我没有取得太大的成功。请帮忙。提前致谢。

我有一个缓存，其中字符串作为键，TileKey（下面的类）作为值，我注意到当我执行查询（下面）时，性能几乎线性地受到缓存大小的影响，即使所有使用的字段在查询中被索引。

这是一个有代表性的基准测试——我对所有基准测试使用了相同的查询（如下）和相同的参数：查询在所有基准测试中返回（相同的）30 个条目

• 查询 5350 个条目缓存耗时 6-7ms
• 查询 10700 个条目缓存耗时 8-10 毫秒
• 查询 48150 个条目缓存耗时 30-42 毫秒
• 查询 96300 个条目缓存耗时 50-70 毫秒

我已经使用 8gb 单节点和 4gb 2 节点执行了基准测试，结果几乎相同（就查询速度与缓存大小而言）

我还尝试通过使用“时间”字段作为第一个组字段来使用 QuerySqlFieldGroup，它应该在所有基准测试中将结果集减少到只有 1000 个条目，我不确定这是 QuerySqlFieldGroup 的正确用法，因为我理解它应该主要用于缓存之间的连接查询。

我做错了什么还是这些是使用 Ignite 索引的预期查询性能？

代码 ：

缓存配置：

班级 ：

I encounter this exception using Ignite

And my code

whats wrong with my code

version

ver. 1.2.0-incubating#20150616-sha1:9fb960ff 2015 Copyright(C) Apache Software Foundation

Gridgain has failover spi mechanism for failure of jobs on nodes. However, we would like to configure a failure mechanism that throws exception even when once of the configured data nodes goes down.

How can we do this?

我正在使用 CacheStoreFactory 实现和 CacheStoreSessionListener 创建缓存。如果我使用这些字段设置 CacheConfiguration 然后调用 createCache 但在 INSTANCE 方法中我得到这个异常：

线程“主”javax.cache.CacheException 中的异常：类 org.apache.ignite.IgniteCheckedException：无法验证缓存配置（确保缓存配置中的所有对象都是可序列化的）：LongCache

在静态方法中，这不会发生。这可以通过修改示例中的 CacheJdbcStoreExample.java 轻松重现。这发生在 Ignite 1.30 下

当方法

在我的 CacheStoreAdapter 实现中执行，我从底层数据库加载的数据不会自动添加到 Ignite 内存缓存中。这是设计使然吗？我是否需要为我的 CacheStoreAdapter 提供对缓存的引用，以便它可以手动执行put()？