Fix HiveSplitSource#bucketed parameter order
Like calling other static functions in HiveSplitSource, caller is
expecting maxInitialSplits comes before maxOutstandingSplits. Flipping
these two arguments effectively makes maxOutstandingSplits check
useless. This will lead to failures like HIVE_EXCEEDED_SPLIT_BUFFERING_LIMIT
if you are scanning a large bucketed table with multiple partitions
@@ -189,8 +189,8 @@ class HiveSplitSource
String databaseName,
String tableName,
CacheQuotaRequirement cacheQuotaRequirement,
- int estimatedOutstandingSplitsPerBucket,
int maxInitialSplits,
+ int estimatedOutstandingSplitsPerBucket,
DataSize maxOutstandingSplitsSize,
HiveSplitLoader splitLoader,
Executor executor,
