Apache Ignite调用loadCache从Oracle加载缓存时出现ORA-30485警告
我们的应用基于Apache Ignite 2.16.0开发,启动时执行ignite.cache("ChnlMstrCache").loadCache(null, new Object[0])从Oracle 19c数据库加载缓存,此时Ignite日志中出现警告:多线程模式下无法从数据库加载条目,将尝试单线程模式,错误根源为ORA-30485: missing ORDER BY expression in the window specification。
代码中未手动编写SQL语句,仅通过调用load()方法触发该问题,应用功能可正常运行,但无法明确该警告的触发原因。
错误堆栈
2024-08-29T20:34:05,391|WARN|mgmt-#111%ImportedCluster%|store.jdbc.CacheJdbcPojoStore||Failed to load entries from db in multithreaded mode, will try in single thread [cache=OurCache, keyType=java.lang.Integer] java.sql.SQLException: ORA-30485: missing ORDER BY expression in the window specification at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:629) ~[ojdbc8-21.7.0.0.jar!/:21.6.0.0.0] ... Caused by: oracle.jdbc.OracleDatabaseException: ORA-30485: missing ORDER BY expression in the window specification
Cache配置
<bean class="org.apache.ignite.configuration.CacheConfiguration"> <property name="name" value="ChnlMstrCache" /> <property name="cacheMode" value="REPLICATED" /> <property name="atomicityMode" value="ATOMIC" /> <property name="backups" value="1" /> <property name="cacheStoreFactory"> <bean class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory"> <property name="dataSourceBean" value="dataSourceRM" /> <property name="dialect"> <bean class="org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect"></bean> </property> ... </bean> </property> <property name="readThrough" value="true" /> <property name="writeThrough" value="true" /> <property name="writeBehindEnabled" value="true"/> <property name="writeBehindFlushFrequency" value="10000"/> <property name="queryEntities"> ... </property> </bean>
原因分析
Ignite的CacheJdbcPojoStore在多线程加载缓存时,会自动生成带窗口函数的SQL来分片查询数据,实现并行加载。但当前配置使用的BasicJdbcDialect是通用方言,对Oracle的窗口函数语法支持不完善,生成的SQL缺少窗口规范必需的ORDER BY子句,导致Oracle数据库抛出ORA-30485错误。
解决办法
使用Oracle专属方言
将CacheJdbcPojoStoreFactory中的dialect替换为OracleDialect,该方言针对Oracle数据库语法做了适配,能正确生成带ORDER BY的窗口函数SQL,彻底解决该问题。修改后的配置片段如下:<property name="dialect"> <bean class="org.apache.ignite.cache.store.jdbc.dialect.OracleDialect"></bean> </property>强制单线程加载(临时方案)
如果暂时无法替换方言,可以通过设置CacheJdbcPojoStoreFactory的parallelLoadBatchSize属性为0,强制Ignite使用单线程加载缓存。这样就不会生成分片的窗口函数SQL,避免警告,但会降低缓存加载效率,不推荐作为长期方案。
内容的提问来源于stack exchange,提问作者Karthik_Rajendiran

