我尝试在Ignite缓存中接收一些事件。我的config.xml: <bean abstract="true" id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="workDirectory" value="/opt/apache-ignite-2.8.1-bin"/>
<!-- Set to true to enable distr
我们让Ignite在我们的JVM中以服务器模式运行。在下面的场景中,点燃将陷入死锁。我在这个问题的末尾添加了线程堆栈。
a.Create a cache with write through enabled
b.In CacheWriter.write() implementation
1.Wait for a second to for step c to be invoked
2.Try to read from another cache
c. While step b is executing Trigger a thread which will create a
我有一个缓存,它实际上将BinaryObject存储在集群(2个节点)中。点火版本为2.1.0。如果我不使用任何StreamReceiver(包括StreamTransformer),那么在使用以下代码添加大量BinaryObject数据时没有问题:
IgniteDataStreamer<Long,BinaryObject> ds = ignite.dataStreamer(CACHE_NAME);
SecureRandom random = new SecureRandom();
long i = 0;
long count = 1000000;
while(i++<cou
在字符串键上插入pojoClass对象时发生以下错误。我已经在Ignite配置中包含了所有事件类型。
我尝试过setStoreKeepBinary(true),也尝试过igniteConfiguration.setPeerClassLoadingEnabled(true),但是错误没有解决。
我正在使用Apache版本2.1。
错误日志:
[2017-09-06 16:22:08,043][ERROR][tcp-client-disco-msg-worker-#4%null%] [TcpDiscoverySpi] Failed to unmarshal discovery data f
我们已经构建了一个4节点的Apache集群,并且能够连接并执行基本操作,比如从Java程序创建一个缓存。
但是当我进行MySQL集成时,它无法连接到Ignite集群。
下面是错误消息。
Exception in thread "main" class org.apache.ignite.IgniteException: Resource field is not assignable from the resource: class org.springframework.jdbc.datasource.DriverManagerDataSource
at org.ap
我正在尝试使用PostgreSQL作为外部存储来设置Apache缓存存储。
public class MyCacheStore extends CacheStoreAdapter<String, MyCache> {
private static final String GET_QUERY= "SELECT * FROM ..";
private static final String UPDATE_QUERY = "UPDATE ...";
private static final String DELETE_QUE
我正在研究Apache流是如何工作的。我有两个节点集群设置(都在本地主机上),我启动了一个客户机节点,它使用StreamTransformer和EntryProcessor运行流代码。因此,在我的一个节点中,我不能反序列化异常。我的代码是Ignite文档中的简化WordCount示例:
public class StreamingExample {`
public static class StreamingExampleCacheEntryProcessor implements CacheEntryProcessor<String, Long, Object> {
@O
情况是这样的。
网络问题
Apache Ignite.NET集群有一个节点被分割。我可以在日志中看到这一点,问题中的节点记录NodeSegmented事件
在分段节点上,如果从ICacheLock对象获得ICache对象,然后尝试使用TryEnter()输入锁,则会得到返回值false。不是因为缓存密钥已经被锁定,而是奇怪的是,由于这种网络分段而出现的情况。
重新启动分段节点,然后重新加入集群并按预期工作。
下面是发生此事件时在日志中看到的堆栈跟踪:
Failed to send unlock request to node (will make best effort
我已经在Con图中将持久存储从H2更改为MYSQL,但是ignite实例没有启动。
<?xml version="1.0" encoding="UTF-8"?>
<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor
license agreements. See the NOTICE file distributed with this work for additional
information r
我正在使用ApacheIgnite2.10.0,我希望通过特性读取/写入数据,将数据从第三方持久性加载到缓存中,并将数据写入到第三方持久性中,为此,我实现了PersonStore,它扩展了CacheStoreAdapter类。我希望我的类(PersonStore、pojo和其他类)能够从客户机节点远程部署到Ignite服务器节点,为此,我在启动服务器时启用了peerClassLoading in CacheConfiguration。
java.lang.RuntimeException: Failed to create an instance of com.demoIgnite.adapt
当我试图将数据放入缓存时,Apache点燃器会抛出异常以下,
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to deserialize object with given class loader: [clsLdr=org.apache.ignite.internal.processors.cache.GridCacheDeploymentManager$CacheClassLoader@5d5b5fa7, err=Failed to deserialize object [typeName=java.ut
我有一个3节点的Apache Ignite集群,我已经创建了一个以Integer为键,'Subscriber‘POJO为值的缓存,当我从JAVA程序内部连接到集群并访问缓存时,我得到了上面提到的异常,我将'peerclassloading’属性设置为false,并且我已经在所有节点中部署了'Subscriber‘POJO二进制文件,请在下面找到完整的堆栈跟踪。这里我漏掉了什么?当我用Ignition.start()在我的JAVA程序中启动客户端时,为什么它在我的IGNITE_HOME中寻找一些文件?
class org.apache.ignite.IgniteCheck
我可以从intellji运行代码,但是当我想要转换成jar文件时,我会得到这样的错误(在mvn全新安装之后)(我知道ignite-hibernate是lgpl依赖项,并且这个依赖项在我本地的.m2 -> /.m2/repository/org/apache/ignite/ignite-hibernate_5.1 $中。)
Failed to collect dependencies at org.apache.ignite:ignite-hibernate_5.1:jar:2.5.0: Failed to read artifact descriptor for org.apache.i
是否有方法对Ignite中的持久数据进行数据加密?我正在使用节点。我试图执行,但遇到了以下错误:
org.apache.ignite.IgniteCheckedException: Using encryption is not allowed for not persistent cache [cacheName=student, groupName=null, cacheType=USER]
at org.apache.ignite.internal.processors.cache.ValidationOnNodeJoinUtils.validate(ValidationOnNo
我使用Ignite 2.5并部署了几个服务器,如下所示:
一台计算机充当启用持久性的DB服务器。
另外三台计算机是具有与DB服务器相同缓存但没有持久性的计算服务器。
我有这样的课:
public class Address implements Serializable
{
String streetName;
String houseNumber;
String cityName;
String countryName;
}
public class Person implements Serializable
{
@QuerySqlField
St