解决Apache Ignite持久化层B+树损坏与WAL记录过大问题

[SEVERE][sys-stripe-4-#5][FailureProcessor] A critical problem with persistence data structures was detected.
[SEVERE][sys-stripe-4-#5][] JVM will be halted immediately due to the failure: [failureCtx=FailureContext [type=CRITICAL_ERROR, err=class o.a.i.i.processors.cache.persistence.tree.CorruptedTreeException: B+Tree is corrupted ...]]

Caused by: java.lang.IllegalArgumentException: Record is too long [capacity=134217728, size=134219738]
    at org.apache.ignite.internal.processors.cache.persistence.wal.SegmentedRingByteBuffer.offer0(SegmentedRingByteBuffer.java:214)
    at org.apache.ignite.internal.processors.cache.persistence.wal.SegmentedRingByteBuffer.offer(SegmentedRingByteBuffer.java:193)
    at org.apache.ignite.internal.processors.cache.persistence.wal.filehandle.FileWriteHandleImpl.addRecord(FileWriteHandleImpl.java:243)
    at org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager.log(FileWriteAheadLogManager.java:858)
    ...

import org.apache.ignite.Ignite;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;

public class IgniteWalConfigExample {
    public static void main(String[] args) {
        IgniteConfiguration cfg = new IgniteConfiguration();

        DataStorageConfiguration dataStorageCfg = new DataStorageConfiguration();

        // 方式一：直接增加 walBufferSize
        // 假设我们预期最大WAL记录可能达到150MB，我们可以将其设置为160MB
        dataStorageCfg.setWalBufferSize(160 * 1024 * 1024); // 160 MB

        // 方式二：增加 walSegmentSize (如果IGNITE_WAL_MMAP禁用，walBufferSize会按比例增加；如果启用，walBufferSize会接近walSegmentSize)
        // 假设我们将其设置为512MB，如果IGNITE_WAL_MMAP禁用，walBufferSize将变为 512MB / 4 = 128MB
        // 如果IGNITE_WAL_MMAP启用，walBufferSize将接近512MB
        // dataStorageCfg.setWalSegmentSize(512 * 1024 * 1024); // 512 MB

        // 组合使用：如果对walSegmentSize有特定要求，同时确保walBufferSize足够大
        dataStorageCfg.setWalSegmentSize(512 * 1024 * 1024); // 512 MB
        dataStorageCfg.setWalBufferSize(200 * 1024 * 1024); // 确保walBufferSize至少为200MB

        cfg.setDataStorageConfiguration(dataStorageCfg);

        // 启用或禁用 IGNITE_WAL_MMAP 可以在启动脚本中通过 -DIGNITE_WAL_MMAP=true/false 设置
        // 或者在代码中设置系统属性（在Ignite启动前）
        // System.setProperty("IGNITE_WAL_MMAP", "true");

        try (Ignite ignite = Ignition.start(cfg)) {
            // Your Ignite application logic
            System.out.println("Ignite cluster started with custom WAL configuration.");
        }
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util.xsd">

    <bean class="org.apache.ignite.configuration.IgniteConfiguration">
        <property name="dataStorageConfiguration">
            <bean class="org.apache.ignite.configuration.DataStorageConfiguration">
                <!-- 方式一：直接增加 walBufferSize -->
                <property name="walBufferSize" value="#{160 * 1024 * 1024}"/> <!-- 160 MB -->

                <!-- 方式二：增加 walSegmentSize -->
                <!-- <property name="walSegmentSize" value="#{512 * 1024 * 1024}"/> --> <!-- 512 MB -->

                <!-- 组合使用 -->
                <property name="walSegmentSize" value="#{512 * 1024 * 1024}"/> <!-- 512 MB -->
                <property name="walBufferSize" value="#{200 * 1024 * 1024}"/> <!-- 确保walBufferSize至少为200MB -->
            </bean>
        </property>
    </bean>
</beans>

java -DIGNITE_WAL_MMAP=true -jar ignite-core.jar ...