DistributedLogConfiguration extends CompositeConfiguration { public void loadStreamConf(Optional<DistributedLogConfiguration> streamConfiguration) { if (!streamConfiguration.isPresent()) { return; } ArrayList<Object> ignoredSettings = new ArrayList<Object>(); Iterator iterator = streamConfiguration.get().getKeys(); while (iterator.hasNext()) { Object setting = iterator.next(); if (setting instanceof String && streamSettings.contains(setting)) { String settingStr = (String) setting; setProperty(settingStr, streamConfiguration.get().getProperty(settingStr)); } else { ignoredSettings.add(setting); } } if (LOG.isWarnEnabled() && !ignoredSettings.isEmpty()) { LOG.warn("invalid stream configuration override(s): {}", StringUtils.join(ignoredSettings, ";")); } } DistributedLogConfiguration(); void loadConf(URL confURL); void loadConf(DistributedLogConfiguration baseConf); void loadConf(Configuration otherConf); void loadStreamConf(Optional<DistributedLogConfiguration> streamConfiguration); String getPropsAsString(); String getZkAclId(); DistributedLogConfiguration setZkAclId(String zkAclId); int getZKSessionTimeoutSeconds(); int getZKSessionTimeoutMilliseconds(); DistributedLogConfiguration setZKSessionTimeoutSeconds(int zkSessionTimeoutSeconds); double getZKRequestRateLimit(); DistributedLogConfiguration setZKRequestRateLimit(double requestRateLimit); int getZKNumRetries(); DistributedLogConfiguration setZKNumRetries(int zkNumRetries); int getZKRetryBackoffStartMillis(); DistributedLogConfiguration setZKRetryBackoffStartMillis(int zkRetryBackoffStartMillis); int getZKRetryBackoffMaxMillis(); DistributedLogConfiguration setZKRetryBackoffMaxMillis(int zkRetryBackoffMaxMillis); int getZKClientNumberRetryThreads(); DistributedLogConfiguration setZKClientNumberRetryThreads(int numThreads); int getBKClientZKSessionTimeoutMilliSeconds(); DistributedLogConfiguration setBKClientZKSessionTimeout(int sessionTimeout); double getBKClientZKRequestRateLimit(); DistributedLogConfiguration setBKClientZKRequestRateLimit(double rateLimit); int getBKClientZKNumRetries(); int getBKClientZKRetryBackoffStartMillis(); int getBKClientZKRetryBackoffMaxMillis(); int getEnsembleSize(); DistributedLogConfiguration setEnsembleSize(int ensembleSize); int getWriteQuorumSize(); DistributedLogConfiguration setWriteQuorumSize(int quorumSize); int getAckQuorumSize(); DistributedLogConfiguration setAckQuorumSize(int quorumSize); QuorumConfig getQuorumConfig(); boolean getRowAwareEnsemblePlacementEnabled(); DistributedLogConfiguration setRowAwareEnsemblePlacementEnabled(boolean enableRowAwareEnsemblePlacement); Class<? extends DNSToSwitchMapping> getEnsemblePlacementDnsResolverClass(); DistributedLogConfiguration setEnsemblePlacementDnsResolverClass(
            Class<? extends DNSToSwitchMapping> dnsResolverClass); String getBkDNSResolverOverrides(); DistributedLogConfiguration setBkDNSResolverOverrides(String overrides); DistributedLogConfiguration setBKDigestPW(String bkDigestPW); String getBKDigestPW(); int getBKClientNumberIOThreads(); DistributedLogConfiguration setBKClientNumberIOThreads(int numThreads); long getTimeoutTimerTickDurationMs(); DistributedLogConfiguration setTimeoutTimerTickDurationMs(long tickDuration); int getTimeoutTimerNumTicks(); DistributedLogConfiguration setTimeoutTimerNumTicks(int numTicks); int getBKClientReadTimeout(); DistributedLogConfiguration setBKClientReadTimeout(int readTimeout); int getBKClientWriteTimeout(); DistributedLogConfiguration setBKClientWriteTimeout(int writeTimeout); int getBKClientNumberWorkerThreads(); DistributedLogConfiguration setBKClientNumberWorkerThreads(int numThreads); int getNumWorkerThreads(); DistributedLogConfiguration setNumWorkerThreads(int numWorkerThreads); int getNumReadAheadWorkerThreads(); DistributedLogConfiguration setNumReadAheadWorkerThreads(int numWorkerThreads); int getNumLockStateThreads(); DistributedLogConfiguration setNumLockStateThreads(int numLockStateThreads); int getNumResourceReleaseThreads(); DistributedLogConfiguration setNumResourceReleaseThreads(int numResourceReleaseThreads); int getSchedulerShutdownTimeoutMs(); DistributedLogConfiguration setSchedulerShutdownTimeoutMs(int timeoutMs); boolean getUseDaemonThread(); DistributedLogConfiguration setUseDaemonThread(boolean daemon); int getDLLedgerMetadataLayoutVersion(); DistributedLogConfiguration setDLLedgerMetadataLayoutVersion(int layoutVersion); boolean getDLLedgerMetadataSkipMinVersionCheck(); DistributedLogConfiguration setDLLedgerMetadataSkipMinVersionCheck(boolean skipMinVersionCheck); long getFirstLogSegmentSequenceNumber(); DistributedLogConfiguration setFirstLogSegmentSequenceNumber(long firstLogSegmentSequenceNumber); boolean isLogSegmentSequenceNumberValidationEnabled(); DistributedLogConfiguration setLogSegmentSequenceNumberValidationEnabled(boolean enabled); boolean getEnableRecordCounts(); DistributedLogConfiguration setEnableRecordCounts(boolean enableRecordCounts); boolean getSanityCheckTxnID(); DistributedLogConfiguration setSanityCheckTxnID(boolean enabled); boolean getEncodeRegionIDInLogSegmentMetadata(); DistributedLogConfiguration setEncodeRegionIDInLogSegmentMetadata(boolean enabled); int getLogSegmentNameVersion(); DistributedLogConfiguration setLogSegmentNameVersion(int version); String getUnpartitionedStreamName(); DistributedLogConfiguration setUnpartitionedStreamName(String streamName); boolean getCreateStreamIfNotExists(); DistributedLogConfiguration setCreateStreamIfNotExists(boolean enabled); int getLogFlushTimeoutSeconds(); DistributedLogConfiguration setLogFlushTimeoutSeconds(int logFlushTimeoutSeconds); String getCompressionType(); DistributedLogConfiguration setCompressionType(String compressionType); boolean getFailFastOnStreamNotReady(); DistributedLogConfiguration setFailFastOnStreamNotReady(boolean failFastOnStreamNotReady); boolean getDisableRollingOnLogSegmentError(); DistributedLogConfiguration setDisableRollingOnLogSegmentError(boolean disableRollingOnLogSegmentError); boolean isDurableWriteEnabled(); DistributedLogConfiguration setDurableWriteEnabled(boolean enabled); int getOutputBufferSize(); DistributedLogConfiguration setOutputBufferSize(int opBufferSize); int getPeriodicFlushFrequencyMilliSeconds(); DistributedLogConfiguration setPeriodicFlushFrequencyMilliSeconds(int flushFrequencyMs); boolean getImmediateFlushEnabled(); DistributedLogConfiguration setImmediateFlushEnabled(boolean enabled); int getMinDelayBetweenImmediateFlushMs(); DistributedLogConfiguration setMinDelayBetweenImmediateFlushMs(int minDelayMs); int getRetentionPeriodHours(); DistributedLogConfiguration setRetentionPeriodHours(int retentionHours); boolean getExplicitTruncationByApplication(); DistributedLogConfiguration setExplicitTruncationByApplication(boolean enabled); int getLogSegmentRollingIntervalMinutes(); DistributedLogConfiguration setLogSegmentRollingIntervalMinutes(int rollingMinutes); long getMaxLogSegmentBytes(); DistributedLogConfiguration setMaxLogSegmentBytes(long maxBytes); int getLogSegmentRollingConcurrency(); DistributedLogConfiguration setLogSegmentRollingConcurrency(int concurrency); boolean isWriteLockEnabled(); DistributedLogConfiguration setWriteLockEnabled(boolean enabled); long getLockTimeoutMilliSeconds(); DistributedLogConfiguration setLockTimeout(long lockTimeout); long getLockReacquireTimeoutMilliSeconds(); DistributedLogConfiguration setLockReacquireTimeoutSeconds(long lockReacquireTimeout); long getLockOpTimeoutMilliSeconds(); DistributedLogConfiguration setLockOpTimeoutSeconds(long lockOpTimeout); boolean getEnableLedgerAllocatorPool(); DistributedLogConfiguration setEnableLedgerAllocatorPool(boolean enabled); String getLedgerAllocatorPoolPath(); DistributedLogConfiguration setLedgerAllocatorPoolPath(String path); String getLedgerAllocatorPoolName(); DistributedLogConfiguration setLedgerAllocatorPoolName(String name); int getLedgerAllocatorPoolCoreSize(); DistributedLogConfiguration setLedgerAllocatorPoolCoreSize(int poolSize); int getPerWriterOutstandingWriteLimit(); DistributedLogConfiguration setPerWriterOutstandingWriteLimit(int limit); int getGlobalOutstandingWriteLimit(); DistributedLogConfiguration setGlobalOutstandingWriteLimit(int limit); boolean getOutstandingWriteLimitDarkmode(); DistributedLogConfiguration setOutstandingWriteLimitDarkmode(boolean darkmoded); int getReadLACLongPollTimeout(); DistributedLogConfiguration setReadLACLongPollTimeout(int readAheadLongPollTimeout); boolean getDeserializeRecordSetOnReads(); DistributedLogConfiguration setDeserializeRecordSetOnReads(boolean enabled); int getReaderIdleWarnThresholdMillis(); DistributedLogConfiguration setReaderIdleWarnThresholdMillis(int warnThreshold); int getReaderIdleErrorThresholdMillis(); DistributedLogConfiguration setReaderIdleErrorThresholdMillis(int warnThreshold); boolean getIgnoreTruncationStatus(); DistributedLogConfiguration setIgnoreTruncationStatus(boolean ignoreTruncationStatus); boolean getAlertWhenPositioningOnTruncated(); DistributedLogConfiguration setAlertWhenPositioningOnTruncated(boolean alertWhenPositioningOnTruncated); boolean getPositionGapDetectionEnabled(); DistributedLogConfiguration setPositionGapDetectionEnabled(boolean enabled); DistributedLogConfiguration setEnableReadAhead(boolean enableReadAhead); boolean getEnableReadAhead(); DistributedLogConfiguration setEnableForceRead(boolean enableForceRead); boolean getEnableForceRead(); int getReadAheadMaxRecords(); DistributedLogConfiguration setReadAheadMaxRecords(int readAheadMaxEntries); int getReadAheadBatchSize(); DistributedLogConfiguration setReadAheadBatchSize(int readAheadBatchSize); int getReadAheadWaitTime(); DistributedLogConfiguration setReadAheadWaitTime(int readAheadWaitTime); int getReadAheadWaitTimeOnEndOfStream(); DistributedLogConfiguration setReadAheadWaitTimeOnEndOfStream(int waitTime); int getReadAheadNoSuchLedgerExceptionOnReadLACErrorThresholdMillis(); DistributedLogConfiguration setReadAheadNoSuchLedgerExceptionOnReadLACErrorThresholdMillis(long thresholdMillis); boolean getReadAheadSkipBrokenEntries(); DistributedLogConfiguration setReadAheadSkipBrokenEntries(boolean enabled); int getFirstNumEntriesPerReadLastRecordScan(); DistributedLogConfiguration setFirstNumEntriesPerReadLastRecordScan(int numEntries); int getMaxNumEntriesPerReadLastRecordScan(); DistributedLogConfiguration setMaxNumEntriesPerReadLastRecordScan(int numEntries); long getCheckLogExistenceBackoffStartMillis(); DistributedLogConfiguration setCheckLogExistenceBackoffStartMillis(long backoffMillis); long getCheckLogExistenceBackoffMaxMillis(); DistributedLogConfiguration setCheckLogExistenceBackoffMaxMillis(long backoffMillis); boolean getTraceReadAheadDeliveryLatency(); DistributedLogConfiguration setTraceReadAheadDeliveryLatency(boolean enabled); long getMetadataLatencyWarnThresholdMillis(); DistributedLogConfiguration setMetadataLatencyWarnThresholdMillis(long warnThresholdMillis); long getDataLatencyWarnThresholdMillis(); DistributedLogConfiguration setDataLatencyWarnThresholdMillis(long warnThresholdMillis); boolean getTraceReadAheadMetadataChanges(); DistributedLogConfiguration setTraceReadAheadMetadataChanges(boolean enabled); boolean getEnableTaskExecutionStats(); DistributedLogConfiguration setEnableTaskExecutionStats(boolean enabled); long getTaskExecutionWarnTimeMicros(); DistributedLogConfiguration setTaskExecutionWarnTimeMicros(long warnTimeMicros); boolean getEnablePerStreamStat(); DistributedLogConfiguration setEnablePerStreamStat(boolean enabled); Class<? extends FeatureProvider> getFeatureProviderClass(); DistributedLogConfiguration setFeatureProviderClass(Class<? extends FeatureProvider> providerClass); String getFileFeatureProviderBaseConfigPath(); DistributedLogConfiguration setFileFeatureProviderBaseConfigPath(String configPath); String getFileFeatureProviderOverlayConfigPath(); DistributedLogConfiguration setFileFeatureProviderOverlayConfigPath(String configPath); boolean isFederatedNamespaceEnabled(); DistributedLogConfiguration setFederatedNamespaceEnabled(boolean enabled); int getFederatedMaxLogsPerSubnamespace(); DistributedLogConfiguration setFederatedMaxLogsPerSubnamespace(int maxLogs); boolean getFederatedCheckExistenceWhenCacheMiss(); DistributedLogConfiguration setFederatedCheckExistenceWhenCacheMiss(boolean enabled); int getDynamicConfigReloadIntervalSec(); DistributedLogConfiguration setDynamicConfigReloadIntervalSec(int intervalSec); String getStreamConfigRouterClass(); DistributedLogConfiguration setStreamConfigRouterClass(String routerClass); int getBpsSoftWriteLimit(); int getBpsHardWriteLimit(); int getRpsSoftWriteLimit(); int getRpsHardWriteLimit(); int getMaxAcquiredPartitionsPerProxy(); DistributedLogConfiguration setMaxAcquiredPartitionsPerProxy(int numPartitions); int getMaxCachedPartitionsPerProxy(); DistributedLogConfiguration setMaxCachedPartitionsPerProxy(int numPartitions); boolean getEIInjectWriteDelay(); double getEIInjectedWriteDelayPercent(); DistributedLogConfiguration setEIInjectedWriteDelayPercent(double percent); int getEIInjectedWriteDelayMs(); DistributedLogConfiguration setEIInjectedWriteDelayMs(int delayMs); boolean getEIInjectReadAheadStall(); DistributedLogConfiguration setEIInjectReadAheadStall(boolean enabled); boolean getEIInjectReadAheadBrokenEntries(); DistributedLogConfiguration setEIInjectReadAheadBrokenEntries(boolean enabled); boolean getEIInjectReadAheadDelay(); DistributedLogConfiguration setEIInjectReadAheadDelay(boolean enabled); int getEIInjectMaxReadAheadDelayMs(); DistributedLogConfiguration setEIInjectMaxReadAheadDelayMs(int delayMs); int getEIInjectReadAheadDelayPercent(); DistributedLogConfiguration setEIInjectReadAheadDelayPercent(int percent); void validate(); static final String BKDL_ZK_ACL_ID; static final String BKDL_ZK_ACL_ID_DEFAULT; static final String BKDL_ZK_SESSION_TIMEOUT_SECONDS; static final int BKDL_ZK_SESSION_TIMEOUT_SECONDS_DEFAULT; static final String BKDL_ZK_REQUEST_RATE_LIMIT; static final double BKDL_ZK_REQUEST_RATE_LIMIT_DEFAULT; static final String BKDL_ZK_NUM_RETRIES; static final int BKDL_ZK_NUM_RETRIES_DEFAULT; static final String BKDL_ZK_RETRY_BACKOFF_START_MILLIS; static final int BKDL_ZK_RETRY_BACKOFF_START_MILLIS_DEFAULT; static final String BKDL_ZK_RETRY_BACKOFF_MAX_MILLIS; static final int BKDL_ZK_RETRY_BACKOFF_MAX_MILLIS_DEFAULT; static final String BKDL_ZKCLIENT_NUM_RETRY_THREADS; static final int BKDL_ZKCLIENT_NUM_RETRY_THREADS_DEFAULT; static final String BKDL_BKCLIENT_ZK_SESSION_TIMEOUT; static final int BKDL_BKCLIENT_ZK_SESSION_TIMEOUT_DEFAULT; static final String BKDL_BKCLIENT_ZK_REQUEST_RATE_LIMIT; static final double BKDL_BKCLIENT_ZK_REQUEST_RATE_LIMIT_DEFAULT; static final String BKDL_BKCLIENT_ZK_NUM_RETRIES; static final int BKDL_BKCLIENT_ZK_NUM_RETRIES_DEFAULT; static final String BKDL_BKCLIENT_ZK_RETRY_BACKOFF_START_MILLIS; static final int BKDL_BKCLIENT_ZK_RETRY_BACKOFF_START_MILLIS_DEFAULT; static final String BKDL_BKCLIENT_ZK_RETRY_BACKOFF_MAX_MILLIS; static final int BKDL_BKCLIENT_ZK_RETRY_BACKOFF_MAX_MILLIS_DEFAULT; static final String BKDL_BOOKKEEPER_ENSEMBLE_SIZE; static final String BKDL_BOOKKEEPER_ENSEMBLE_SIZE_OLD; static final int BKDL_BOOKKEEPER_ENSEMBLE_SIZE_DEFAULT; static final String BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE; static final String BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE_OLD; static final int BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE_DEFAULT; static final String BKDL_BOOKKEEPER_ACK_QUORUM_SIZE; static final String BKDL_BOOKKEEPER_ACK_QUORUM_SIZE_OLD; static final int BKDL_BOOKKEEPER_ACK_QUORUM_SIZE_DEFAULT; static final String BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT; static final String BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT_OLD; static final boolean BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT_DEFAULT; static final String BKDL_ENSEMBLE_PLACEMENT_DNS_RESOLVER_CLASS; static final String BKDL_ENSEMBLE_PLACEMENT_DNS_RESOLVER_CLASS_DEFAULT; static final String BKDL_BK_DNS_RESOLVER_OVERRIDES; static final String BKDL_BK_DNS_RESOLVER_OVERRIDES_DEFAULT; static final String BKDL_BOOKKEEPER_DIGEST_PW; static final String BKDL_BOOKKEEPER_DIGEST_PW_DEFAULT; static final String BKDL_BKCLIENT_NUM_IO_THREADS; static final String BKDL_TIMEOUT_TIMER_TICK_DURATION_MS; static final long BKDL_TIMEOUT_TIMER_TICK_DURATION_MS_DEFAULT; static final String BKDL_TIMEOUT_TIMER_NUM_TICKS; static final int BKDL_TIMEOUT_TIMER_NUM_TICKS_DEFAULT; static final String BKDL_BKCLIENT_READ_TIMEOUT; static final int BKDL_BKCLIENT_READ_TIMEOUT_DEFAULT; static final String BKDL_BKCLIENT_WRITE_TIMEOUT; static final int BKDL_BKCLIENT_WRITE_TIMEOUT_DEFAULT; static final String BKDL_BKCLIENT_NUM_WORKER_THREADS; static final int BKDL_BKCLEINT_NUM_WORKER_THREADS_DEFAULT; static final String BKDL_NUM_WORKER_THREADS; static final String BKDL_NUM_READAHEAD_WORKER_THREADS; static final String BKDL_NUM_LOCKSTATE_THREADS; static final String BKDL_NUM_RESOURCE_RELEASE_THREADS; static final String BKDL_SCHEDULER_SHUTDOWN_TIMEOUT_MS; static final int BKDL_SCHEDULER_SHUTDOWN_TIMEOUT_MS_DEFAULT; static final String BKDL_USE_DAEMON_THREAD; static final boolean BKDL_USE_DAEMON_THREAD_DEFAULT; static final String BKDL_LEDGER_METADATA_LAYOUT_VERSION; static final String BKDL_LEDGER_METADATA_LAYOUT_VERSION_OLD; static final int BKDL_LEDGER_METADATA_LAYOUT_VERSION_DEFAULT; static final String BKDL_LEDGER_METADATA_SKIP_MIN_VERSION_CHECK; static final boolean BKDL_LEDGER_METADATA_SKIP_MIN_VERSION_CHECK_DEFAULT; static final String BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER; static final String BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER_OLD; static final long BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER_DEFAULT; static final String BKDL_LOGSEGMENT_SEQUENCE_NUMBER_VALIDATION_ENABLED; static final boolean BKDL_LOGSEGMENT_SEQUENCE_NUMBER_VALIDATION_ENABLED_DEFAULT; static final String BKDL_ENABLE_RECORD_COUNTS; static final boolean BKDL_ENABLE_RECORD_COUNTS_DEFAULT; static final String BKDL_MAXID_SANITYCHECK; static final boolean BKDL_MAXID_SANITYCHECK_DEFAULT; static final String BKDL_ENCODE_REGION_ID_IN_VERSION; static final boolean BKDL_ENCODE_REGION_ID_IN_VERSION_DEFAULT; static final String BKDL_LOGSEGMENT_NAME_VERSION; static final int BKDL_LOGSEGMENT_NAME_VERSION_DEFAULT; static final String BKDL_UNPARTITIONED_STREAM_NAME; static final String BKDL_UNPARTITIONED_STREAM_NAME_DEFAULT; static final String BKDL_CREATE_STREAM_IF_NOT_EXISTS; static final boolean BKDL_CREATE_STREAM_IF_NOT_EXISTS_DEFAULT; static final String BKDL_LOG_FLUSH_TIMEOUT; static final int BKDL_LOG_FLUSH_TIMEOUT_DEFAULT; static final String BKDL_COMPRESSION_TYPE; static final String BKDL_COMPRESSION_TYPE_DEFAULT; static final String BKDL_FAILFAST_ON_STREAM_NOT_READY; static final boolean BKDL_FAILFAST_ON_STREAM_NOT_READY_DEFAULT; static final String BKDL_DISABLE_ROLLING_ON_LOG_SEGMENT_ERROR; static final boolean BKDL_DISABLE_ROLLING_ON_LOG_SEGMENT_ERROR_DEFAULT; static final String BKDL_IS_DURABLE_WRITE_ENABLED; static final boolean BKDL_IS_DURABLE_WRITE_ENABLED_DEFAULT; static final String BKDL_OUTPUT_BUFFER_SIZE; static final String BKDL_OUTPUT_BUFFER_SIZE_OLD; static final int BKDL_OUTPUT_BUFFER_SIZE_DEFAULT; static final String BKDL_PERIODIC_FLUSH_FREQUENCY_MILLISECONDS; static final int BKDL_PERIODIC_FLUSH_FREQUENCY_MILLISECONDS_DEFAULT; static final String BKDL_ENABLE_IMMEDIATE_FLUSH; static final boolean BKDL_ENABLE_IMMEDIATE_FLUSH_DEFAULT; static final String BKDL_MINIMUM_DELAY_BETWEEN_IMMEDIATE_FLUSH_MILLISECONDS; static final int BKDL_MINIMUM_DELAY_BETWEEN_IMMEDIATE_FLUSH_MILLISECONDS_DEFAULT; static final String BKDL_RETENTION_PERIOD_IN_HOURS; static final String BKDL_RETENTION_PERIOD_IN_HOURS_OLD; static final int BKDL_RETENTION_PERIOD_IN_HOURS_DEFAULT; static final String BKDL_EXPLICIT_TRUNCATION_BY_APPLICATION; static final boolean BKDL_EXPLICIT_TRUNCATION_BY_APPLICATION_DEFAULT; static final String BKDL_ROLLING_INTERVAL_IN_MINUTES; static final String BKDL_ROLLING_INTERVAL_IN_MINUTES_OLD; static final int BKDL_ROLLING_INTERVAL_IN_MINUTES_DEFAULT; static final String BKDL_MAX_LOGSEGMENT_BYTES; static final int BKDL_MAX_LOGSEGMENT_BYTES_DEFAULT; static final String BKDL_LOGSEGMENT_ROLLING_CONCURRENCY; static final int BKDL_LOGSEGMENT_ROLLING_CONCURRENCY_DEFAULT; static final String BKDL_WRITE_LOCK_ENABLED; static final boolean BKDL_WRITE_LOCK_ENABLED_DEFAULT; static final String BKDL_LOCK_TIMEOUT; static final long BKDL_LOCK_TIMEOUT_DEFAULT; static final String BKDL_LOCK_REACQUIRE_TIMEOUT; static final long BKDL_LOCK_REACQUIRE_TIMEOUT_DEFAULT; static final String BKDL_LOCK_OP_TIMEOUT; static final long BKDL_LOCK_OP_TIMEOUT_DEFAULT; static final String BKDL_ENABLE_LEDGER_ALLOCATOR_POOL; static final boolean BKDL_ENABLE_LEDGER_ALLOCATOR_POOL_DEFAULT; static final String BKDL_LEDGER_ALLOCATOR_POOL_PATH; static final String BKDL_LEDGER_ALLOCATOR_POOL_PATH_DEFAULT; static final String BKDL_LEDGER_ALLOCATOR_POOL_NAME; static final String BKDL_LEDGER_ALLOCATOR_POOL_NAME_DEFAULT; static final String BKDL_LEDGER_ALLOCATOR_POOL_CORE_SIZE; static final int BKDL_LEDGER_ALLOCATOR_POOL_CORE_SIZE_DEFAULT; static final String BKDL_PER_WRITER_OUTSTANDING_WRITE_LIMIT; static final int BKDL_PER_WRITER_OUTSTANDING_WRITE_LIMIT_DEFAULT; static final String BKDL_GLOBAL_OUTSTANDING_WRITE_LIMIT; static final int BKDL_GLOBAL_OUTSTANDING_WRITE_LIMIT_DEFAULT; static final String BKDL_OUTSTANDING_WRITE_LIMIT_DARKMODE; static final boolean BKDL_OUTSTANDING_WRITE_LIMIT_DARKMODE_DEFAULT; static final String BKDL_READLAC_OPTION; static final int BKDL_READLAC_OPTION_DEFAULT; static final String BKDL_READLACLONGPOLL_TIMEOUT; static final int BKDL_READLACLONGPOLL_TIMEOUT_DEFAULT; static final String BKDL_DESERIALIZE_RECORDSET_ON_READS; static final boolean BKDL_DESERIALIZE_RECORDSET_ON_READS_DEFAULT; static final String BKDL_READER_IDLE_WARN_THRESHOLD_MILLIS; static final int BKDL_READER_IDLE_WARN_THRESHOLD_MILLIS_DEFAULT; static final String BKDL_READER_IDLE_ERROR_THRESHOLD_MILLIS; static final int BKDL_READER_IDLE_ERROR_THRESHOLD_MILLIS_DEFAULT; static final String BKDL_READER_IGNORE_TRUNCATION_STATUS; static final boolean BKDL_READER_IGNORE_TRUNCATION_STATUS_DEFAULT; static final String BKDL_READER_ALERT_POSITION_ON_TRUNCATED; static final boolean BKDL_READER_ALERT_POSITION_ON_TRUNCATED_DEFAULT; static final String BKDL_READER_POSITION_GAP_DETECTION_ENABLED; static final boolean BKDL_READER_POSITION_GAP_DETECTION_ENABLED_DEFAULT; static final String BKDL_ENABLE_READAHEAD; static final boolean BKDL_ENABLE_READAHEAD_DEFAULT; static final String BKDL_ENABLE_FORCEREAD; static final boolean BKDL_ENABLE_FORCEREAD_DEFAULT; static final String BKDL_READAHEAD_MAX_RECORDS; static final String BKDL_READAHEAD_MAX_RECORDS_OLD; static final int BKDL_READAHEAD_MAX_RECORDS_DEFAULT; static final String BKDL_READAHEAD_BATCHSIZE; static final String BKDL_READAHEAD_BATCHSIZE_OLD; static final int BKDL_READAHEAD_BATCHSIZE_DEFAULT; static final String BKDL_READAHEAD_WAITTIME; static final String BKDL_READAHEAD_WAITTIME_OLD; static final int BKDL_READAHEAD_WAITTIME_DEFAULT; static final String BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM; static final String BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM_OLD; static final int BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM_DEFAULT; static final String BKDL_READAHEAD_NOSUCHLEDGER_EXCEPTION_ON_READLAC_ERROR_THRESHOLD_MILLIS; static final int BKDL_READAHEAD_NOSUCHLEDGER_EXCEPTION_ON_READLAC_ERROR_THRESHOLD_MILLIS_DEFAULT; static final String BKDL_READAHEAD_SKIP_BROKEN_ENTRIES; static final boolean BKDL_READAHEAD_SKIP_BROKEN_ENTRIES_DEFAULT; static final String BKDL_FIRST_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN; static final int BKDL_FIRST_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN_DEFAULT; static final String BKDL_MAX_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN; static final int BKDL_MAX_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN_DEFAULT; static final String BKDL_CHECK_LOG_EXISTENCE_BACKOFF_START_MS; static final int BKDL_CHECK_LOG_EXISTENCE_BACKOFF_START_MS_DEFAULT; static final String BKDL_CHECK_LOG_EXISTENCE_BACKOFF_MAX_MS; static final int BKDL_CHECK_LOG_EXISTENCE_BACKOFF_MAX_MS_DEFAULT; static final String BKDL_TRACE_READAHEAD_DELIVERY_LATENCY; static final boolean BKDL_TRACE_READAHEAD_DELIVERY_LATENCY_DEFAULT; static final String BKDL_METADATA_LATENCY_WARN_THRESHOLD_MS; static final long BKDL_METADATA_LATENCY_WARN_THRESHOLD_MS_DEFAULT; static final String BKDL_DATA_LATENCY_WARN_THRESHOLD_MS; static final long BKDL_DATA_LATENCY_WARN_THRESHOLD_MS_DEFAULT; static final String BKDL_TRACE_READAHEAD_METADATA_CHANGES; static final boolean BKDL_TRACE_READAHEAD_MEATDATA_CHANGES_DEFAULT; final static String BKDL_ENABLE_TASK_EXECUTION_STATS; final static boolean BKDL_ENABLE_TASK_EXECUTION_STATS_DEFAULT; final static String BKDL_TASK_EXECUTION_WARN_TIME_MICROS; final static long BKDL_TASK_EXECUTION_WARN_TIME_MICROS_DEFAULT; static final String BKDL_ENABLE_PERSTREAM_STAT; static final boolean BKDL_ENABLE_PERSTREAM_STAT_DEFAULT; static final String BKDL_FEATURE_PROVIDER_CLASS; static final String BKDL_FILE_FEATURE_PROVIDER_BASE_CONFIG_PATH; static final String BKDL_FILE_FEATURE_PROVIDER_BASE_CONFIG_PATH_DEFAULT; static final String BKDL_FILE_FEATURE_PROVIDER_OVERLAY_CONFIG_PATH; static final String BKDL_FILE_FEATURE_PROVIDER_OVERLAY_CONFIG_PATH_DEFAULT; static final String BKDL_FEDERATED_NAMESPACE_ENABLED; static final boolean BKDL_FEDERATED_NAMESPACE_ENABLED_DEFAULT; static final String BKDL_FEDERATED_MAX_LOGS_PER_SUBNAMESPACE; static final int BKDL_FEDERATED_MAX_LOGS_PER_SUBNAMESPACE_DEFAULT; static final String BKDL_FEDERATED_CHECK_EXISTENCE_WHEN_CACHE_MISS; static final boolean BKDL_FEDERATED_CHECK_EXISTENCE_WHEN_CACHE_MISS_DEFAULT; static final String BKDL_DYNAMIC_CONFIG_RELOAD_INTERVAL_SEC; static final int BKDL_DYNAMIC_CONFIG_RELOAD_INTERVAL_SEC_DEFAULT; static final String BKDL_STREAM_CONFIG_ROUTER_CLASS; static final String BKDL_STREAM_CONFIG_ROUTER_CLASS_DEFAULT; static final String BKDL_BPS_SOFT_WRITE_LIMIT; static final int BKDL_BPS_SOFT_WRITE_LIMIT_DEFAULT; static final String BKDL_BPS_HARD_WRITE_LIMIT; static final int BKDL_BPS_HARD_WRITE_LIMIT_DEFAULT; static final String BKDL_RPS_SOFT_WRITE_LIMIT; static final int BKDL_RPS_SOFT_WRITE_LIMIT_DEFAULT; static final String BKDL_RPS_HARD_WRITE_LIMIT; static final int BKDL_RPS_HARD_WRITE_LIMIT_DEFAULT; static final String BKDL_RPS_SOFT_SERVICE_LIMIT; static final int BKDL_RPS_SOFT_SERVICE_LIMIT_DEFAULT; static final String BKDL_RPS_HARD_SERVICE_LIMIT; static final int BKDL_RPS_HARD_SERVICE_LIMIT_DEFAULT; static final String BKDL_RPS_STREAM_ACQUIRE_SERVICE_LIMIT; static final int BKDL_RPS_STREAM_ACQUIRE_SERVICE_LIMIT_DEFAULT; static final String BKDL_BPS_SOFT_SERVICE_LIMIT; static final int BKDL_BPS_SOFT_SERVICE_LIMIT_DEFAULT; static final String BKDL_BPS_HARD_SERVICE_LIMIT; static final int BKDL_BPS_HARD_SERVICE_LIMIT_DEFAULT; static final String BKDL_BPS_STREAM_ACQUIRE_SERVICE_LIMIT; static final int BKDL_BPS_STREAM_ACQUIRE_SERVICE_LIMIT_DEFAULT; static final String BKDL_MAX_ACQUIRED_PARTITIONS_PER_PROXY; static final int BKDL_MAX_ACQUIRED_PARTITIONS_PER_PROXY_DEFAULT; static final String BKDL_MAX_CACHED_PARTITIONS_PER_PROXY; static final int BKDL_MAX_CACHED_PARTITIONS_PER_PROXY_DEFAULT; static final String BKDL_EI_INJECT_WRITE_DELAY; static final boolean BKDL_EI_INJECT_WRITE_DELAY_DEFAULT; static final String BKDL_EI_INJECTED_WRITE_DELAY_PERCENT; static final double BKDL_EI_INJECTED_WRITE_DELAY_PERCENT_DEFAULT; static final String BKDL_EI_INJECTED_WRITE_DELAY_MS; static final int BKDL_EI_INJECTED_WRITE_DELAY_MS_DEFAULT; static final String BKDL_EI_INJECT_READAHEAD_STALL; static final boolean BKDL_EI_INJECT_READAHEAD_STALL_DEFAULT; static final String BKDL_EI_INJECT_READAHEAD_DELAY; static final boolean BKDL_EI_INJECT_READAHEAD_DELAY_DEFAULT; static final String BKDL_EI_INJECT_MAX_READAHEAD_DELAY_MS; static final int BKDL_EI_INJECT_MAX_READAHEAD_DELAY_MS_DEFAULT; static final String BKDL_EI_INJECT_READAHEAD_DELAY_PERCENT; static final int BKDL_EI_INJECT_READAHEAD_DELAY_PERCENT_DEFAULT; static final String BKDL_EI_INJECT_READAHEAD_BROKEN_ENTRIES; static final boolean BKDL_EI_INJECT_READAHEAD_BROKEN_ENTRIES_DEFAULT; }
@Test(timeout = 20000) public void loadStreamConfNullOverrides() throws Exception { DistributedLogConfiguration conf = new DistributedLogConfiguration(); DistributedLogConfiguration confClone = (DistributedLogConfiguration)conf.clone(); Optional<DistributedLogConfiguration> streamConfiguration = Optional.absent(); conf.loadStreamConf(streamConfiguration); StrictConfigurationComparator comp = new StrictConfigurationComparator(); assertTrue(comp.compare(conf, confClone)); }