You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ji...@apache.org on 2019/11/22 05:32:30 UTC
[incubator-druid] branch master updated (dc6178d -> 934547a)
This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from dc6178d Upgrade Calcite to 1.21 (#8566)
add 934547a RetryingInputEntity to retry on transient errors (#8923)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/data/input/InputEntity.java | 14 ++--
.../druid/data/input/RetryingInputEntity.java | 76 ++++++++++++++++++++++
.../apache/druid/data/input/impl/ByteEntity.java | 8 ---
.../apache/druid/data/input/impl/FileEntity.java | 8 ---
.../apache/druid/data/input/impl/HttpEntity.java | 44 ++++++++++---
.../impl/{prefetch => }/RetryingInputStream.java | 8 ++-
.../data/input/impl/prefetch/FileFetcher.java | 1 +
.../PrefetchableTextFilesFirehoseFactory.java | 1 +
.../apache/druid/java/util/common/RetryUtils.java | 1 +
.../impl/prefetch/RetryingInputStreamTest.java | 1 +
.../input/google/GoogleCloudStorageEntity.java | 10 +--
.../google/GoogleCloudStorageInputSource.java | 5 +-
.../druid/inputsource/hdfs/HdfsInputEntity.java | 15 +++--
.../java/org/apache/druid/storage/s3/S3Utils.java | 3 +-
.../clients/OverlordResourceTestClient.java | 4 +-
.../utils/{RetryUtil.java => ITRetryUtil.java} | 4 +-
.../druid/testing/utils/ServerDiscoveryUtil.java | 2 +-
.../java/org/testng/DruidTestRunnerFactory.java | 4 +-
.../druid/tests/hadoop/ITHadoopIndexTest.java | 4 +-
.../tests/indexer/AbstractITBatchIndexTest.java | 6 +-
.../indexer/AbstractITRealtimeIndexTaskTest.java | 4 +-
.../druid/tests/indexer/AbstractIndexerTest.java | 6 +-
.../tests/indexer/AbstractKafkaIndexerTest.java | 6 +-
.../druid/tests/indexer/ITCompactionTaskTest.java | 10 +--
.../tests/indexer/ITNestedQueryPushDownTest.java | 4 +-
.../druid/tests/indexer/ITUnionQueryTest.java | 8 +--
.../druid/tests/query/ITSystemTableQueryTest.java | 6 +-
.../druid/tests/query/ITTwitterQueryTest.java | 4 +-
.../druid/tests/query/ITWikipediaQueryTest.java | 6 +-
.../security/ITBasicAuthConfigurationTest.java | 4 +-
.../realtime/firehose/HttpFirehoseFactory.java | 29 +--------
31 files changed, 192 insertions(+), 114 deletions(-)
create mode 100644 core/src/main/java/org/apache/druid/data/input/RetryingInputEntity.java
rename core/src/main/java/org/apache/druid/data/input/impl/{prefetch => }/RetryingInputStream.java (95%)
rename integration-tests/src/main/java/org/apache/druid/testing/utils/{RetryUtil.java => ITRetryUtil.java} (96%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org