How to run a distributed query and get different sections of the result to each executor

Spark Connector
6

It seems that using the regular Bucket object on the executors hits the autoreleaseAfter limit for any query that doesn’t return almost instantly. Moving to the async API fixed the issue for me.

1 Like