这个功能看起来是由ReactiveCqlTemplate类提供的,我已经在下面的Cassandra配置中将它传递给了ReactiveCassandraTemplate:@public class CassandraConfiguration extends AbstractReactiveCassandraConfiguration {
private final ReactiveCassandraTemplate
", CASSANDRA_HOST_IPS) at com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:113)
at com.datastax.spark.connector.cql.PreparedStatementCache
我试图按时间从cassandra查询大量数据,然后使用spark数据集一次处理较小的数据块,但是,如果出现无效的查询异常,应用程序就会失败: at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)