You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fj...@apache.org on 2019/11/19 21:58:09 UTC
[incubator-druid] branch master updated (cf6643e -> c44452f)
This is an automated email from the ASF dual-hosted git repository.
fjy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from cf6643e add sequenceName and currentCheckPoint for backwards compatibility (#8864)
add c44452f Tidy up lifecycle, query, and ingestion logging. (#8889)
No new revisions were added by this update.
Summary of changes:
.../apache/druid/common/config/ConfigManager.java | 2 +-
.../druid/common/guava/ThreadRenamingCallable.java | 4 +-
.../main/java/org/apache/druid/guice/Jerseys.java | 6 +-
.../org/apache/druid/guice/JsonConfigurator.java | 2 +-
.../java/util/common/io/smoosh/FileSmoosher.java | 9 +-
.../java/util/common/lifecycle/Lifecycle.java | 4 +-
.../druid/java/util/common/logger/Logger.java | 54 +++++--
.../druid/java/util/emitter/EmittingLogger.java | 13 +-
.../druid/java/util/emitter/core/NoopEmitter.java | 6 +
.../java/util/http/client/pool/ResourcePool.java | 8 +-
.../org/apache/druid/segment/SegmentUtils.java | 15 ++
.../org/apache/druid/timeline/DataSegment.java | 11 +-
.../org/apache/druid/utils/CompressionUtils.java | 2 +-
.../druid/java/util/common/logger/LoggerTest.java | 12 +-
.../SegmentWithOvershadowedStatusTest.java | 2 +-
examples/conf/druid/cluster/_common/log4j2.xml | 49 +++++--
.../druid/single-server/large/_common/log4j2.xml | 49 +++++--
.../druid/single-server/medium/_common/log4j2.xml | 49 +++++--
.../micro-quickstart/_common/log4j2.xml | 49 +++++--
.../nano-quickstart/_common/log4j2.xml | 49 +++++--
.../druid/single-server/small/_common/log4j2.xml | 49 +++++--
.../druid/single-server/xlarge/_common/log4j2.xml | 49 +++++--
.../cloudfiles/CloudFilesDataSegmentPusher.java | 2 -
.../storage/google/GoogleDataSegmentPusher.java | 10 +-
.../druid/storage/hdfs/HdfsDataSegmentPusher.java | 7 +-
.../IncrementalPublishingKafkaIndexTaskRunner.java | 4 +-
.../druid/indexing/kafka/KafkaRecordSupplier.java | 8 +-
.../kafka/supervisor/KafkaSupervisorTest.java | 2 -
.../indexing/kinesis/KinesisIndexTaskRunner.java | 4 +-
.../druid/storage/s3/S3DataSegmentPusher.java | 6 +-
.../apache/druid/indexing/common/TaskToolbox.java | 12 +-
.../druid/indexing/common/TaskToolboxFactory.java | 9 +-
.../common/actions/RemoteTaskActionClient.java | 17 ++-
.../task/AppenderatorDriverRealtimeIndexTask.java | 4 +-
.../indexing/common/task/BatchAppenderators.java | 2 +-
.../common/task/CachingLocalSegmentAllocator.java | 2 +-
.../indexing/common/task/HadoopIndexTask.java | 8 +-
.../druid/indexing/common/task/IndexTask.java | 4 +-
.../indexing/common/task/InputSourceProcessor.java | 7 +-
.../indexing/common/task/RealtimeIndexTask.java | 2 +-
.../parallel/ParallelIndexSupervisorTask.java | 2 +-
.../batch/parallel/PartialSegmentMergeTask.java | 2 +-
.../overlord/BaseRestorableTaskRunner.java | 13 +-
.../druid/indexing/overlord/ForkingTaskRunner.java | 2 +-
.../druid/indexing/overlord/TaskRunnerUtils.java | 26 +---
.../indexing/overlord/ThreadingTaskRunner.java | 4 +-
.../seekablestream/SeekableStreamIndexTask.java | 4 +-
.../SeekableStreamIndexTaskRunner.java | 140 +++++++++++-------
.../indexing/seekablestream/SequenceMetadata.java | 2 +-
.../supervisor/SeekableStreamSupervisor.java | 6 +-
.../indexing/worker/IntermediaryDataManager.java | 17 ++-
.../druid/indexing/worker/WorkerTaskManager.java | 61 +++++---
.../druid/indexing/worker/WorkerTaskMonitor.java | 13 +-
.../druid/indexing/common/TaskToolboxTest.java | 2 +-
.../druid/indexing/common/task/IndexTaskTest.java | 6 +-
.../common/task/TestAppenderatorsManager.java | 2 +
.../results/auth_test_sys_schema_segments.json | 2 +-
.../org/apache/druid/guice/PropertiesModule.java | 6 +-
.../druid/query/ChainedExecutionQueryRunner.java | 4 +-
.../org/apache/druid/segment/CompressedPools.java | 10 +-
.../java/org/apache/druid/segment/IndexMerger.java | 8 +-
.../org/apache/druid/segment/IndexMergerV9.java | 22 +--
.../druid/segment/StringDimensionMergerV9.java | 13 +-
.../druid/segment/data/CompressionStrategy.java | 8 +-
.../druid/segment/transform/Transformer.java | 8 ++
.../org/apache/druid/client/BrokerServerView.java | 6 +-
.../org/apache/druid/curator/CuratorModule.java | 12 +-
.../druid/curator/announcement/Announcer.java | 8 +-
.../discovery/CuratorDruidNodeAnnouncer.java | 34 +++--
.../CuratorDruidNodeDiscoveryProvider.java | 60 ++++----
.../curator/inventory/CuratorInventoryManager.java | 10 +-
.../apache/druid/discovery/DruidLeaderClient.java | 4 +-
.../druid/initialization/Initialization.java | 18 ++-
.../query/lookup/LookupReferencesManager.java | 19 +--
.../segment/loading/LocalDataSegmentKiller.java | 4 +-
.../segment/loading/LocalDataSegmentPusher.java | 8 +-
.../apache/druid/segment/realtime/FireHydrant.java | 2 +-
.../realtime/appenderator/Appenderator.java | 9 +-
.../realtime/appenderator/AppenderatorImpl.java | 152 ++++++++++++++------
.../realtime/appenderator/Appenderators.java | 4 +
.../appenderator/BaseAppenderatorDriver.java | 158 ++++++++++++---------
.../DefaultOfflineAppenderatorFactory.java | 1 +
.../DefaultRealtimeAppenderatorFactory.java | 10 +-
.../appenderator/PeonAppenderatorsManager.java | 6 +-
.../appenderator/SegmentIdWithShardSpec.java | 15 --
.../appenderator/StreamAppenderatorDriver.java | 12 +-
.../UnifiedIndexerAppenderatorsManager.java | 2 +
.../realtime/firehose/LocalFirehoseFactory.java | 4 +-
.../ServiceAnnouncingChatHandlerProvider.java | 20 +--
.../java/org/apache/druid/server/DruidNode.java | 28 +++-
.../org/apache/druid/server/QueryLifecycle.java | 2 +-
.../org/apache/druid/server/QueryResource.java | 8 +-
.../druid/server/coordinator/DruidCoordinator.java | 16 ++-
.../server/coordinator/HttpLoadQueuePeon.java | 20 +--
.../helper/DruidCoordinatorSegmentInfoLoader.java | 2 +-
.../apache/druid/server/emitter/EmitterModule.java | 6 +-
.../initialization/jetty/JettyServerModule.java | 6 +-
.../apache/druid/server/metrics/MetricsModule.java | 13 +-
.../apache/druid/curator/CuratorModuleTest.java | 2 +-
.../realtime/appenderator/AppenderatorTester.java | 1 +
.../StreamAppenderatorDriverFailTest.java | 8 +-
.../ServiceAnnouncingChatHandlerProviderTest.java | 3 +-
.../coordination/SegmentChangeRequestDropTest.java | 2 +-
.../coordination/SegmentChangeRequestLoadTest.java | 2 +-
.../BatchDataSegmentAnnouncerTest.java | 2 +-
.../druid/server/http/ServersResourceTest.java | 4 +-
.../java/org/apache/druid/cli/CliCoordinator.java | 6 +-
.../java/org/apache/druid/cli/GuiceRunnable.java | 2 +-
.../druid/sql/calcite/schema/DruidSchema.java | 23 ++-
109 files changed, 1095 insertions(+), 625 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org