This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from e6a11707cb Adding query stack fault to MSQ to capture native query
errors. (#13926)
add 319f99db05 Always use file sizes when determining batch ingest splits
(#13955)
No new revisions were added by this update.
Summary of changes:
.../druid/data/input/aliyun/OssInputSource.java | 47 ++-
.../druid/storage/aliyun/OssDataSegmentPuller.java | 16 +-
.../org/apache/druid/storage/aliyun/OssUtils.java | 30 +-
.../data/input/aliyun/OssInputSourceTest.java | 27 +-
.../storage/aliyun/OssDataSegmentPullerTest.java | 52 ++-
extensions-core/azure-extensions/pom.xml | 10 +-
.../druid/data/input/azure/AzureInputSource.java | 90 +++--
...udBlobHolderToCloudObjectLocationConverter.java | 42 ---
.../apache/druid/storage/azure/AzureStorage.java | 11 +-
.../storage/azure/AzureStorageDruidModule.java | 1 -
.../input/azure/AzureInputSourceSerdeTest.java | 7 -
.../data/input/azure/AzureInputSourceTest.java | 26 +-
...obHolderToCloudObjectLocationConverterTest.java | 59 ----
.../storage/azure/AzureStorageDruidModuleTest.java | 13 +-
.../google/GoogleCloudStorageInputSource.java | 110 +++---
.../apache/druid/storage/google/GoogleStorage.java | 6 +
.../apache/druid/storage/google/GoogleUtils.java | 1 +
.../google/GoogleCloudStorageInputSourceTest.java | 43 ++-
.../apache/druid/msq/input/InputSpecSlicer.java | 6 +
.../org/apache/druid/msq/input/SlicerUtils.java | 69 +++-
.../input/external/ExternalInputSpecSlicer.java | 234 +++++++++----
.../input/stage/CollectedReadablePartitions.java | 2 +-
.../msq/input/stage/StripedReadablePartitions.java | 2 +-
.../msq/input/table/TableInputSpecSlicer.java | 62 +---
.../druid/msq/kernel/controller/WorkerInputs.java | 12 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 43 ++-
.../external/ExternalInputSpecSlicerTest.java | 131 ++++++-
.../msq/input/table/TableInputSpecSlicerTest.java | 10 +-
.../msq/kernel/controller/WorkerInputsTest.java | 382 +++++++++++++++++++++
.../org/apache/druid/msq/test/MSQTestBase.java | 1 -
.../apache/druid/data/input/s3/S3InputSource.java | 75 ++--
.../druid/storage/s3/S3DataSegmentPuller.java | 17 +-
.../java/org/apache/druid/storage/s3/S3Utils.java | 32 +-
.../druid/data/input/s3/S3InputSourceTest.java | 73 +++-
.../druid/storage/s3/S3DataSegmentPullerTest.java | 38 +-
.../druid/data/input/MaxSizeSplitHintSpec.java | 11 +-
.../org/apache/druid/data/input/SplitHintSpec.java | 4 +-
.../data/input/impl/CloudObjectInputSource.java | 186 +++++++---
.../data/input/impl/CloudObjectSplitWidget.java | 78 +++++
.../druid/data/input/MaxSizeSplitHintSpecTest.java | 23 --
.../input/impl/CloudObjectInputSourceTest.java | 20 ++
.../apache/druid/sql/calcite/CalciteQueryTest.java | 1 +
42 files changed, 1435 insertions(+), 668 deletions(-)
delete mode 100644
extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureCloudBlobHolderToCloudObjectLocationConverter.java
delete mode 100644
extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureCloudBlobHolderToCloudObjectLocationConverterTest.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/CloudObjectSplitWidget.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
