An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs
OptimisticTransaction.readPredicates may be updated by multiple threads that call filesForScan. This commit turns it from an ArrayBuffer to a ConcurrentLinkedQueue to be thread safe.
Which Delta project/connector is this regarding?
Description
OptimisticTransaction.readPredicates
may be updated by multiple threads that callfilesForScan
. This commit turns it from anArrayBuffer
to aConcurrentLinkedQueue
to be thread safe.How was this patch tested?
Existing tests.
Does this PR introduce any user-facing changes?
No