Apache Ignite。使用CacheAtomicityMode.TRANSACTIONAL_SNAPSHOT初始化缓存
Apache Ignite是一个开源的内存计算平台，它提供了分布式缓存、计算网格和数据网格等功能。它可以将数据存储在内存中，以提供快速的数据访问和处理能力。
CacheAtomicityMode.TRANSACTIONAL_SNAPSHOT是Apache Ignite中的一个缓存原子性模式，它指定了缓存的事务一致性级别为"TRANSACTIONAL_SNAPSHOT"。在这个模式下，Ignite使用快照隔离级别来保证事务的一致性。当一个事务开始时，Ignite会创建一个数据快照，并在事务执行期间使用该快照来提供一致性视图。这意味着事务可以读取到其他事务提交之前的数据，并且不会受到其他事务的影响。
使用CacheAtomicityMode.TRANSACTIONAL_SNAPSHOT初始化缓存可以提供以下优势和应用场景：
- 优势：
- 事务一致性：保证事务的一致性，避免数据不一致的问题。
- 高性能：利用内存存储和快照隔离级别，提供快速的数据访问和处理能力。
- 并发控制：通过快照隔离级别，避免并发事务之间的冲突。
- 应用场景：
- 金融交易：在金融领域的交易处理中，保证事务的一致性非常重要，使用TRANSACTIONAL_SNAPSHOT模式可以提供可靠的事务处理能力。
- 实时分析：对于需要实时分析大量数据的场景，使用TRANSACTIONAL_SNAPSHOT模式可以提供高性能的数据访问和处理能力。
- 电子商务：在电子商务平台中，保证订单处理的一致性是关键，使用TRANSACTIONAL_SNAPSHOT模式可以确保订单数据的一致性。
推荐的腾讯云相关产品和产品介绍链接地址： 腾讯云提供了与Apache Ignite类似的产品，可以满足分布式缓存和计算的需求，例如腾讯云的分布式缓存产品"云数据库Redis"（https://cloud.tencent.com/product/redis）和分布式计算产品"云批量计算"（https://cloud.tencent.com/product/bc）等。这些产品可以与Apache Ignite结合使用，提供更全面的解决方案。
相关·内容
我创建了一个spring服务(Service )，它使用Ignite缓存。Ignite缓存使用CacheStoreAdapter从数据库预加载数据。缓存配置是：
final CacheConfiguration<String, StandardItem> cacheConfiguration = new CacheConfiguration<>(Identifiers.IGNITE_ITEM);
cacheConfiguration.setName(Identifiers.IGNITE_ITEM);
cacheConfiguration.setIndexedTypes
浏览 4提问于2017-12-01得票数 0
回答已采纳
这是我最后一次尝试配置ApacheIgnite2.0作为持久层和ODBC2.0作为查询层。
ODBC配置是可以的，我可以使用sql在缓存中放置和获取数据，但是当我插入Cassandra (通过docker映像插入3.9版本)作为持久层时，我得到如下信息：
java.lang.ClassNotFoundException: Unknown pair [platformId=0, typeId=1262449073]
我试着搜索这个异常，但没有得到任何有用的提示。
这是我的Ignite配置
boolean persistence = true;
IgniteCon
浏览 5提问于2017-06-27得票数 1
回答已采纳
我在我的远程Ignite集群上创建缓存K，V对时遇到了一些问题。我的Ignite节点构建在Java8中的Maven项目上，该项目通过多播配置进行集群，并带有分区缓存。这里面临的问题是，只有当集群中只有一个节点时，retrieve才能通过SqlFieldQuery或NoSQL成功地创建和检索缓存。当我将其缩放到超过1(在本例中为2)时，我将面临远程服务器引发的错误。
Caused by: org.apache.ignite.internal.cluster.ClusterTopologyServerNotFoundException: Failed to map keys for cache (
浏览 0提问于2018-08-20得票数 1
回答已采纳
我是Java (IgniteCLient)，用于连接到Ignite服务器并获取/设置要执行的服务器缓存操作。当我试图将自定义对象存储到缓存中时，异常下面的获取和缓存集正在失败。如果我尝试使用Ignite客户端节点存储相同的对象，它可以正常工作。java瘦客户端(我们可以存储的数据类型)是否有任何限制？
点燃服务器版本: 2.7.6
PFB异常跟踪：
class org.apache.ignite.binary.BinaryObjectException: Failed to serialize object [typeName=com.wyse.stratus.server.cache.Con
浏览 3提问于2020-03-05得票数 1
回答已采纳
2回答
我是Ignite.net技术的新手，正在尝试用数据持久化特性来实现它(使用EF core2.1作为我的缓存存储类)。我这样配置Ignite配置
var cfg = new IgniteConfiguration
{
JvmDllPath = @"C:\Program Files\Java\jdk-11.0.1\bin\server\jvm.dll",
IsActiveOnStart = true,
ClientMode = false,
IgniteI
浏览 55提问于2018-12-13得票数 0
回答已采纳
我正在尝试使用poc在我们的微服务中使用Apache来缓存DB事务。以下是Ignite Config代码：
IgniteConfiguration igniteConfiguration = new IgniteConfiguration();
igniteConfiguration.setIgniteInstanceName("igniteConfig");
ignite = Ignition.start(igniteConfiguration);
CacheConfiguration<Long, MyClass> myClassCacheConfig = n
浏览 1提问于2019-11-14得票数 0
我使用Apache作为分布式缓存，并且遇到了一些基本的健壮性问题。如果我们的Ignite服务器由于任何原因重新启动，这似乎会破坏我们所有的Ignite客户端，即使Ignite服务器重新上线。
这是客户端在与缓存交互时所看到的错误，在、服务器重新启动和客户端重新连接之后：
Caused by: org.apache.ignite.internal.processors.cache.CacheStoppedException: Failed to perform cache operation (cache is stopped): <redacted>
我的期望是Ignite客户端将
浏览 1提问于2020-10-22得票数 5
回答已采纳
我在Spring项目中使用Apache。我希望使用xml在我的应用程序上下文中创建一个org.apache.ignite.Ignite实例。创建Ignite对象的方法之一是使用org.apache.ignite.Ignition#start方法。我的问题是，如何使用bean xml配置从Ignition#start创建Ignite实例。
<!-- Implements Ignite interface -->
<bean class="org.apache.ignite.internal.IgniteKernal">
</bean>
&l
浏览 0提问于2016-07-18得票数 0
回答已采纳
我们让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
浏览 20提问于2022-11-28得票数 2
我已经创建了一个Ignite缓存"contact“，并在其中添加了"Person”对象。当我使用Ignite客户端模式时，我可以查询这个缓存。但是当我实现JDBC瘦客户机时，它说表Person不存在。我尝试了这样的查询：
Select * from Person
Select * from contact.Person
两者都不适用于瘦客户端。我正在使用Ignite 2.1。我感谢您的帮助，因为如何使用瘦客户端查询现有的缓存。谢谢。
默认情况下的缓存配置-config.xml
<bean id="ignite.cfg" class="or
浏览 3提问于2017-09-11得票数 1
我希望使用database作为内存数据库创建一个架构。因此，我做以下几点：
try (Statement statement = connection.createStatement()) {
statement.executeQuery("CREATE SCHEMA my_schema");
}
但我得到了错误：
Exception in thread "sql-connector-#38%null%" java.lang.AssertionError
at org.apache.ignite.internal.processors.query
浏览 0提问于2018-02-09得票数 0
回答已采纳
我有一个3节点的Apache Ignite集群，我已经创建了一个以Integer为键，'Subscriber‘POJO为值的缓存，当我从JAVA程序内部连接到集群并访问缓存时，我得到了上面提到的异常，我将'peerclassloading’属性设置为false，并且我已经在所有节点中部署了'Subscriber‘POJO二进制文件，请在下面找到完整的堆栈跟踪。这里我漏掉了什么？当我用Ignition.start()在我的JAVA程序中启动客户端时，为什么它在我的IGNITE_HOME中寻找一些文件？
class org.apache.ignite.IgniteCheck
浏览 2提问于2016-06-20得票数 1
看起来，尽管在配置中设置了过期时间，数据还是不会从Ignite缓存中被逐出。我注意到，当我使用SQL将数据插入缓存表时，会发生此问题。
emplCache.query(new SqlFieldsQuery(
"CREATE TABLE Employee (id LONG PRIMARY KEY, firstName VARCHAR, lastName VARCHAR,
salary DECIMAL, gender VARCHAR)")).getAll();
SqlFieldsQuery insertqry = new SqlFieldsQuery("
浏览 2提问于2017-08-14得票数 0
回答已采纳
我集成了最新的ignite用于缓存和web会话集群...while会话缓存，我得到了一个错误
- Failed to update web session: null
org.apache.jasper.JasperException: class org.apache.ignite.IgniteException: class org.apache.ignite.IgniteCheckedException: com.bizmatics.prognocis.view.MenuHistoryView
at org.apache.jasper.servlet.JspServletWrap
浏览 2提问于2019-12-27得票数 1
我使用 stable/ignite version 2.7.6在Kubernetes上设置了一个Ignite集群。
但很快我就会收到这样的错误：
JVM will be halted immediately due to the fail ure: [failureCtx=FailureContext [type=SYSTEM_WORKER_TERMINATION, err=java.lang.IllegalStateExce ption: Topology is not initialized: app-profiles]]
结果，Ignite Kubernetes pods一次又一次地重启
浏览 0提问于2020-05-22得票数 0
我有一个ignite服务器在复制模式下运行，许多客户端在同一个节点上启用了近乎缓存。现在，当我在使用近缓存和不使用近缓存的情况下运行客户端时，我没有发现显著的性能差异。
我对near cache的理解是，频繁使用的键和值将存储在客户端本身，因此不会对服务器进行实际的Get()调用。如果我错了，请纠正我。
是否有人可以共享工作的近缓存配置xml。
SERVER CONFIG:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2
浏览 3提问于2017-04-07得票数 1
1回答
当我尝试在Ignite缓存中存储HikariDataSource时，它不能被Ignite序列化。我喜欢Ignite用于缓存的特性，因此也希望将其重用以满足本地需求。
Caused by: org.apache.ignite.binary.BinaryInvalidTypeException: com.zaxxer.hikari.util.ConcurrentBag$$Lambda$2327/0x00000008010b9840
at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryCon
浏览 10提问于2022-05-11得票数 0
我正在尝试使用Apache Ignite进行设置。我有一个dotnet核心客户端应用程序，它正在尝试获取缓存(ignite.GetCache<int, CacheThing>("test-cache") )或创建缓存(ignite.CreateCache<int, CacheThing>)。
在这两种情况下，结果都是相同的错误(见下文)。
Apache Ignite服务器
我使用的是来自的docker容器，并使用了apache/ignite:2.6.0标签。
客户端代码(dotnetcore)
客户端正在尝试使用架构定义的自定义dotnet核心程序集创建
浏览 9提问于2018-09-03得票数 1
回答已采纳
1回答
我们在服务器和客户端模式下都使用Ignite 2.7.6 :两个服务器和六个客户端。 起初，每个装有client Ignite的应用程序节点都有2G堆。每个Ignite服务器节点有24G的外堆和2G的堆。 在最近的应用更新中，我们引入了新的功能，这需要大约2000个缓存，每个缓存有20个实体(用户组)。缓存条目的大小很小，最多包含10个整数。这些缓存是通过ignite.getOrCreateCache(name)方法创建的，因此它们具有默认的缓存配置(堆外、分区)。 但在更新后的一个小时内，我们在服务器节点上收到了OOM错误： [00:59:55,628][SEVERE][sys-#4475
浏览 28提问于2020-09-17得票数 2
回答已采纳
我一直在努力使用JDBC连接在Apache缓存上运行一个insert查询。我使用以下配置创建了我的缓存：
CacheConfiguration<Long, MyApplication> cacheCfg = new CacheConfiguration<>("SQL_PUBLIC_MYAPPLICATION");
cacheCfg.setCacheMode(CacheMode.REPLICATED);
cacheCfg.setIndexedTypes(Long.class, MyApplication.class);
cacheCfg.setSqlSch
浏览 4提问于2017-12-19得票数 1
回答已采纳
1回答
我有一个ApacheSpark作业，它的一个组件使用Ignite在Apache数据网格上激发查询，查询是一个SQLFieldsQuery。我正在遍历线程转储，在其中一个Executor日志中，我看到了以下内容：
org.h2.mvstore.db.TransactionStore.begin(TransactionStore.java:229)
org.h2.engine.Session.getTransaction(Session.java:1580)
org.h2.engine.Session.getStatementSavepoint(Session.java:1588)
org.
浏览 4提问于2017-05-08得票数 3
1回答
我们已经构建了一个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
浏览 4提问于2017-09-04得票数 0
1回答
我已经使用docker hub的docker镜像安装了Ignite。Ignite服务器节点正确启动。但是当我尝试更新缓存时，我得到了以下异常：
[SEVERE][rest-#35%null%][GridCacheCommandHandler] Failed to execute cache command: GridRestCacheRequest [cacheName=null, cacheFlags=0, ttl=null, super=GridRestRequest [destId=null, clientId=466b7ff5-c303-452e-8f2d-97d59c753de5,
浏览 2提问于2017-05-03得票数 0
1回答
我使用Ignite 2.13.x作为我的需求之一，我需要在Ignite集群中维护缓存，其中一些键值将同时更新，并且选择也是并行的。所以我现在面临的问题是，
java.sql.SQLException:未能更新某些键，因为它们已被并发修改[keys=[ROWKEY idHash=628930863，hash=1637498765，rowkey=6，( org.apache.ignite.internal.jdbc.thin.JdbcThinConnection.sendRequest(JdbcThinConnection.java:1009) at org.apache.ignite.inter
浏览 21提问于2022-06-21得票数 0
我有.Net Ignite客户端和服务器应用程序Ignite v2.9.1。我们有一个2节点的集群，最近我们升级了ignite 2.7.6到ignite 2.9.1，在使用这个版本后，我们经常遇到问题。 [2021-02-02T10:09:15,668][ERROR][client-connector-#227%ServerNode%][ClientListenerNioListener] Failed to process client request [req=o.a.i.i.processors.platform.client.cache.ClientCacheGetRequest@b
浏览 173提问于2021-02-03得票数 0
1回答
我有一个使用锁定的代码，当我使用客户端时，它工作得很好。在切换代码以使用粗客户端后，将得到以下异常：
Apache.Ignite.Core.Common.IgniteException:无法在锁或事务cacheNames=SQL_MYAPP_MODELS_COUNTERS中启动/停止缓存，operation=dynamicStartCache -> Apache.Ignite.Core.Common.JavaException:类org.apache.ignite.IgniteCheckedException:无法在锁或事务cacheNames=SQL_MYAPP_MODELS_COU
浏览 7提问于2022-01-18得票数 0
1回答
我创建了一个文件helloworld.txt。现在我正在读取文件，然后我希望将文件的内容加载到缓存中，每当缓存被更新时，它也应该写入该文件。
到目前为止，这是我的代码：
请告诉我如何加载缓存，然后从缓存写入文件，因为Apache文档中没有明确说明。
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import org.apache.ignite.Ignite;
import or
浏览 1提问于2016-03-29得票数 2
我想在生产环境(2.6版)中使用ignite集群。但我发现，当我运行这些代码时，会发生一些严重的故障，如下所示：
CacheConfiguration<Long, User> cacheCfg = new CacheConfiguration<>("QQ");
cacheCfg.setIndexedTypes(Long.class, String.class);
cacheCfg.setCacheMode(CacheMode.PARTITIONED);
cacheCfg.setSqlSchema("PUBLIC");
cacheCfg.s
浏览 2提问于2018-12-12得票数 0
在使用带有DataStreamer的StreamReceiver时，如何修复以下序列化错误？我猜它在反序列化RowStreamReceiver时找不到类。
错误：SEVERE: Failure in Java callback class org.apache.ignite.IgniteException: Platform error:Apache.Ignite.Core.Binary.BinaryObjectException: Unknown pair [platformId=1, typeId=113114]
我正在使用ApacheIgnite2.0，并且尝试使用在本测试中演示的相同类
浏览 2提问于2017-07-07得票数 2
回答已采纳
1回答
我正在研究Apache流是如何工作的。我有两个节点集群设置(都在本地主机上)，我启动了一个客户机节点，它使用StreamTransformer和EntryProcessor运行流代码。因此，在我的一个节点中，我不能反序列化异常。我的代码是Ignite文档中的简化WordCount示例：
public class StreamingExample {`
public static class StreamingExampleCacheEntryProcessor implements CacheEntryProcessor<String, Long, Object> {
@O
浏览 2提问于2016-09-16得票数 0
回答已采纳
1回答
我试图使用事务同步访问存储在Ignite中的对象，并发现一个事务的结果常常覆盖另一个事务的结果。为了便于测试，我编写了一个更简单的JUnit测试版本：
import junit.framework.TestCase;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.
浏览 1提问于2017-02-03得票数 0
回答已采纳
我们有一个用例如下
启动2作为数据节点点燃实例并将数据插入到缓存中。
(2)使用remoteListen创建队列并注册远程侦听器，如下所示
//Queue creation
CollectionConfiguration colCfg = new CollectionConfiguration();
colCfg.setCacheMode(PARTITIONED);
IgniteQueue<BinaryObject> queue = Ignition.ignite().queue(queueName, 0, colCfg);
//Remote Liste
浏览 3提问于2017-05-10得票数 3
回答已采纳
我在使用时遇到了一些错误。
现在，我通过将一个XML文件传递给bash ignite.sh来远程启动一个集群。然后，我用C#在本地并以编程方式启动另一个节点，该节点连接到底层的Oracle数据库，以便用数据加载缓存。
我的目标是能够查询缓存中的数据，其中键是对象ID，值是整个对象对象。我所做的唯一步骤是用Object.cs中的@QuerySqlField注释注释值类定义中的字段，并在Program.cs中用CacheConfiguration实例化QueryEntity。
通过XML文件启动远程集群
<?xml version="1.0" encoding="UT
浏览 5提问于2020-11-17得票数 1
回答已采纳
启动Apache Ignite客户端(Ignite版本2.3.0 )时，连接到(单个)群集节点一开始似乎可以正常工作。但是我得到了下面的异常
Jan 04, 2018 5:18:23 PM org.apache.ignite.logger.java.JavaLogger error
SEVERE: Failed to process custom exchange task: ClientCacheChangeDummyDiscoveryMessage [reqId=c1d6d9fd-a2be-4826-9459-05912ad1f5a5, cachesToClose=null, startC
浏览 19提问于2018-01-04得票数 0
我有一个缓存，它实际上将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
浏览 2提问于2017-09-05得票数 1
回答已采纳
是否有方法对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
浏览 6提问于2022-07-27得票数 0
我们已经在一个新的azure Kubernetes集群(版本1.20.9)中部署了ignite 2.8.1。有两个ignite实例，它们都工作得很好。但是当我们从一个旧的Kubernetes集群(版本1.18.10)复制一些dat文件和它对应的bin文件(这些基本上是持久性文件)到这个新集群时，问题就开始了。数据复制后，其中一个ignite实例开始持续失败，但其他实例正在启动并运行。在旧集群中，还部署了IGNET2.8.1&有2个ignite实例，一切都运行得很好。我得到了以下异常-
[IgniteKernal] Failed to start manager: GridManage
浏览 1提问于2021-12-01得票数 0
我正在尝试使用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
浏览 2提问于2021-04-08得票数 0
回答已采纳
我希望能够在Apache Ignite中监控缓存创建事件。
无论何时发生这样的事件-我希望能够在它们创建之后，但在任何人可以插入一些东西之前，能够对这些缓存做一些事情。
所以我使用了本地监听器。以下是所有代码：
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.eve
浏览 2提问于2018-11-10得票数 1
下面是使用的组件
负载平衡器.弹簧引导zuul带
服务器- tomcat7
Web应用程序- spring版本4.1
缓存模式分区
不是的。节点-2
网络聚类配置
我有一个web应用程序，它使用粘性会话，我希望使用apache点燃迁移到非粘性会话。我遵循apache点燃的"web会话集群“指南来实现更改。添加了一个负载均衡器，它将循环机制中的通信量路由到配置的节点列表。我在端口8080上运行节点1，在端口9090上运行节点2。两个节点都配置在带状负载均衡器中。
在本指南中提到的配置更改之后，我成功地运行了单个节点。我能够在管理程序中看到apache点燃缓
浏览 0提问于2018-09-17得票数 1
回答已采纳
如果有人能帮我的话真的很感谢。
我有一个用Java编写的ignite服务器，还有一个用C#编写的客户端，客户端可以连接到服务器，并可以正确地获取服务器的缓存。服务器重新启动后，客户端收到来自服务器的EVT_CLIENT_NODE_RECONNECTED事件。但是缓存不能再使用了。
服务器代码：
CacheConfiguration cacheConfiguration = new CacheConfiguration();
cacheConfiguration.setName("Sample");
cacheConfiguration.setCacheMode
浏览 8提问于2017-07-20得票数 2
我正在使用Apache Ignite，设置如下:2台服务器组成一个集群，在REPLICATED模式下配置了几个Ignite缓存。还有10个Java进程作为客户端连接到Apache Ignite集群，并从这些缓存中获取数据。 在使用VisualVM分析客户机JVM时，我发现客户机在阻塞状态下花费了几乎一半的时间 java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
at java.util.concurrent.locks.LockSupport.park(LockSup
浏览 19提问于2019-05-08得票数 0
回答已采纳
我已经使用SQL创建了一个分区的持久Ignite缓存。默认情况下，备份设置为"0"，现在我想为每个节点添加大小为"2“的备份(我们有3个节点)。在ignite服务器节点中，我编辑了配置xml文件，如下所示： <bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="cacheConfiguration">
&l
浏览 26提问于2020-10-29得票数 0
1回答
我有一个基本的Ignite持久性设置工作。现在，它是一个运行在服务器模式下的节点，我从其中连接两个客户端。当我从其中一个客户端(下面的“Client 1”)通过SQL插入数据时，我可以使用SQL再次选择它并获得结果。在下面的"Client 2“中，当我试图抓取本应用来表示此表的缓存时，它是空的。
服务器使用以下Dockerfile运行apacheignite映像：
服务器/Dockerfile：
FROM apacheignite/ignite
# for jdbc connection
EXPOSE 10800
EXPOSE 47100-47109
EXPOSE 47500-47
浏览 0提问于2019-04-17得票数 2
回答已采纳
1回答
我有两个节点，并且启用了持久性。我创建一个这样的缓存
// all the queues across the frontier instances
CacheConfiguration cacheCfg2 = new CacheConfiguration("queues");
cacheCfg2.setBackups(backups);
cacheCfg2.setCacheMode(CacheMode.PARTITIONED);
globalQueueCache = ignite.getOrCreateCache(cacheCfg2);
其
浏览 9提问于2022-04-13得票数 0
回答已采纳
我试图为JavaPairRDD中的每个元素检索缓存的值。我使用LOCAL缓存模式，因为我希望尽量减少缓存数据的数据洗牌。点火节点在火花作业中以嵌入式模式启动。如果我在单个节点上运行，下面的代码可以正常工作。但是，当我在一个由5台机器组成的集群上运行它时，我会得到zero结果。
我进行的第一次尝试是使用IgniteRDD sql方法：
dataRDD.sql("SELECT v.id,v.sub,v.obj FROM VPRow v JOIN table(id bigint = ?) i ON v.id = i.id",new Object[] {objKeyEntries.t
浏览 4提问于2017-06-03得票数 0
回答已采纳
在字符串键上插入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
浏览 2提问于2017-09-06得票数 4
回答已采纳
1回答
冲突枚举值java
、、、、
我在两个单独的文件中定义了两个枚举，如下所示：MyErrorCodes.java
@Getter
public enum MyErrorCodes implements ErrorCode {
ERROR1(90, 1, 01),
ERROR2(90, 1, 02),
ERROR3(90, 1, 03),
ERROR4(90, 1, 04),
ERROR5(90, 1, 05);
....
}
ErrorCategory.java
public class ErrorCategory {
@AllArgsConstructor
publi
浏览 3提问于2022-04-22得票数 1
回答已采纳
我使用的是点燃版本2.0.0
我正在尝试将大约4000万个数据从db加载到我的点燃实例(本例中为2)。我从上读到关于Ignite DataStreamers的文章。
由于loadCache()的数据加载速度非常低，所以我用IgniteDataStreamer.addData()更改了loadCache()。
在执行时，我在web控制台中注意到，堆上条目的指标正在递增(也就是说，它显示数据正在加载)。但是，当我查询点燃缓存时，结果为空。
我还注意到服务器日志显示了这个异常：
[01:46:19,541][ERROR][flusher-0-#66%RemoteIgniteCluster%][Gri
浏览 8提问于2017-07-11得票数 0
回答已采纳
我有一个服务器节点和一个客户端节点。在DataStorageConfiguration中，启用了persistent。我重新启动了服务器节点，并尝试在缓存上执行操作。我在异常情况下变得更糟了。这个例外是如果我使用DataStorageConfiguration的话。 原因:类org.apache.ignite.IgniteException:无法在锁或事务中启动/停止缓存。cacheName=org.apache.ignite.internal.processors.cache.GridCacheProcessor.checkEmptyTransactionsEx(GridCacheProc
浏览 28提问于2020-07-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
