in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/PipeConfig.java [394:568]
public void printAllConfigs() {
LOGGER.info(
"PipeNonForwardingEventsProgressReportInterval: {}",
getPipeNonForwardingEventsProgressReportInterval());
LOGGER.info("PipeHardlinkBaseDirName: {}", getPipeHardlinkBaseDirName());
LOGGER.info("PipeHardlinkTsFileDirName: {}", getPipeHardlinkTsFileDirName());
LOGGER.info("PipeHardlinkWALDirName: {}", getPipeHardlinkWALDirName());
LOGGER.info("PipeHardLinkWALEnabled: {}", getPipeHardLinkWALEnabled());
LOGGER.info("PipeFileReceiverFsyncEnabled: {}", getPipeFileReceiverFsyncEnabled());
LOGGER.info("PipeDataStructureTabletRowSize: {}", getPipeDataStructureTabletRowSize());
LOGGER.info("PipeDataStructureTabletSizeInBytes: {}", getPipeDataStructureTabletSizeInBytes());
LOGGER.info(
"PipeDataStructureTabletMemoryBlockAllocationRejectThreshold: {}",
getPipeDataStructureTabletMemoryBlockAllocationRejectThreshold());
LOGGER.info(
"PipeDataStructureTsFileMemoryBlockAllocationRejectThreshold: {}",
getPipeDataStructureTsFileMemoryBlockAllocationRejectThreshold());
LOGGER.info("PipeTotalFloatingMemoryProportion: {}", getPipeTotalFloatingMemoryProportion());
LOGGER.info(
"PipeRealTimeQueuePollTsFileThreshold: {}", getPipeRealTimeQueuePollTsFileThreshold());
LOGGER.info(
"PipeRealTimeQueuePollHistoricalTsFileThreshold: {}",
getPipeRealTimeQueuePollHistoricalTsFileThreshold());
LOGGER.info("PipeSubtaskExecutorMaxThreadNum: {}", getPipeSubtaskExecutorMaxThreadNum());
LOGGER.info(
"PipeSubtaskExecutorBasicCheckPointIntervalByConsumedEventCount: {}",
getPipeSubtaskExecutorBasicCheckPointIntervalByConsumedEventCount());
LOGGER.info(
"PipeSubtaskExecutorBasicCheckPointIntervalByTimeDuration: {}",
getPipeSubtaskExecutorBasicCheckPointIntervalByTimeDuration());
LOGGER.info(
"PipeSubtaskExecutorPendingQueueMaxBlockingTimeMs: {}",
getPipeSubtaskExecutorPendingQueueMaxBlockingTimeMs());
LOGGER.info(
"PipeSubtaskExecutorCronHeartbeatEventIntervalSeconds: {}",
getPipeSubtaskExecutorCronHeartbeatEventIntervalSeconds());
LOGGER.info(
"PipeSubtaskExecutorForcedRestartIntervalMs: {}",
getPipeSubtaskExecutorForcedRestartIntervalMs());
LOGGER.info(
"PipeExtractorAssignerDisruptorRingBufferSize: {}",
getPipeExtractorAssignerDisruptorRingBufferSize());
LOGGER.info(
"PipeExtractorAssignerDisruptorRingBufferEntrySizeInBytes: {}",
getPipeExtractorAssignerDisruptorRingBufferEntrySizeInBytes());
LOGGER.info("PipeExtractorMatcherCacheSize: {}", getPipeExtractorMatcherCacheSize());
LOGGER.info("PipeConnectorHandshakeTimeoutMs: {}", getPipeConnectorHandshakeTimeoutMs());
LOGGER.info("PipeConnectorTransferTimeoutMs: {}", getPipeConnectorTransferTimeoutMs());
LOGGER.info("PipeConnectorReadFileBufferSize: {}", getPipeConnectorReadFileBufferSize());
LOGGER.info(
"PipeConnectorReadFileBufferMemoryControlEnabled: {}",
isPipeConnectorReadFileBufferMemoryControlEnabled());
LOGGER.info("PipeConnectorRetryIntervalMs: {}", getPipeConnectorRetryIntervalMs());
LOGGER.info(
"PipeConnectorRPCThriftCompressionEnabled: {}",
isPipeConnectorRPCThriftCompressionEnabled());
LOGGER.info(
"PipeLeaderCacheMemoryUsagePercentage: {}", getPipeLeaderCacheMemoryUsagePercentage());
LOGGER.info("PipeMaxAlignedSeriesNumInOneBatch: {}", getPipeMaxAlignedSeriesNumInOneBatch());
LOGGER.info(
"PipeListeningQueueTransferSnapshotThreshold: {}",
getPipeListeningQueueTransferSnapshotThreshold());
LOGGER.info("PipeSnapshotExecutionMaxBatchSize: {}", getPipeSnapshotExecutionMaxBatchSize());
LOGGER.info(
"PipeRemainingTimeCommitAutoSwitchSeconds: {}",
getPipeRemainingTimeCommitAutoSwitchSeconds());
LOGGER.info(
"PipeRemainingTimeCommitRateAverageTime: {}", getPipeRemainingTimeCommitRateAverageTime());
LOGGER.info("PipeTsFileScanParsingThreshold(): {}", getPipeTsFileScanParsingThreshold());
LOGGER.info(
"PipeAsyncConnectorForcedRetryTsFileEventQueueSizeThreshold: {}",
getPipeAsyncConnectorForcedRetryTsFileEventQueueSizeThreshold());
LOGGER.info(
"PipeAsyncConnectorForcedRetryTabletEventQueueSizeThreshold: {}",
getPipeAsyncConnectorForcedRetryTabletEventQueueSizeThreshold());
LOGGER.info(
"PipeAsyncConnectorForcedRetryTotalEventQueueSizeThreshold: {}",
getPipeAsyncConnectorForcedRetryTotalEventQueueSizeThreshold());
LOGGER.info(
"PipeAsyncConnectorMaxRetryExecutionTimeMsPerCall: {}",
getPipeAsyncConnectorMaxRetryExecutionTimeMsPerCall());
LOGGER.info("PipeAsyncConnectorSelectorNumber: {}", getPipeAsyncConnectorSelectorNumber());
LOGGER.info("PipeAsyncConnectorMaxClientNumber: {}", getPipeAsyncConnectorMaxClientNumber());
LOGGER.info(
"PipeAllConnectorsRateLimitBytesPerSecond: {}",
getPipeAllConnectorsRateLimitBytesPerSecond());
LOGGER.info(
"RateLimiterHotReloadCheckIntervalMs: {}", getRateLimiterHotReloadCheckIntervalMs());
LOGGER.info(
"PipeConnectorRequestSliceThresholdBytes: {}",
getPipeConnectorRequestSliceThresholdBytes());
LOGGER.info("SeperatedPipeHeartbeatEnabled: {}", isSeperatedPipeHeartbeatEnabled());
LOGGER.info(
"PipeHeartbeatIntervalSecondsForCollectingPipeMeta: {}",
getPipeHeartbeatIntervalSecondsForCollectingPipeMeta());
LOGGER.info(
"PipeMetaSyncerInitialSyncDelayMinutes: {}", getPipeMetaSyncerInitialSyncDelayMinutes());
LOGGER.info("PipeMetaSyncerSyncIntervalMinutes: {}", getPipeMetaSyncerSyncIntervalMinutes());
LOGGER.info(
"PipeMetaSyncerAutoRestartPipeCheckIntervalRound: {}",
getPipeMetaSyncerAutoRestartPipeCheckIntervalRound());
LOGGER.info("PipeAutoRestartEnabled: {}", getPipeAutoRestartEnabled());
LOGGER.info("PipeAirGapReceiverEnabled: {}", getPipeAirGapReceiverEnabled());
LOGGER.info("PipeAirGapReceiverPort: {}", getPipeAirGapReceiverPort());
LOGGER.info(
"PipeReceiverLoginPeriodicVerificationIntervalMs: {}",
getPipeReceiverLoginPeriodicVerificationIntervalMs());
LOGGER.info(
"PipeReceiverActualToEstimatedMemoryRatio: {}",
getPipeReceiverActualToEstimatedMemoryRatio());
LOGGER.info(
"PipeMaxAllowedHistoricalTsFilePerDataRegion: {}",
getPipeMaxAllowedHistoricalTsFilePerDataRegion());
LOGGER.info(
"PipeMaxAllowedPendingTsFileEpochPerDataRegion: {}",
getPipeMaxAllowedPendingTsFileEpochPerDataRegion());
LOGGER.info("PipeMaxAllowedPinnedMemTableCount: {}", getPipeMaxAllowedPinnedMemTableCount());
LOGGER.info("PipeMaxAllowedLinkedTsFileCount: {}", getPipeMaxAllowedLinkedTsFileCount());
LOGGER.info(
"PipeMaxAllowedLinkedDeletedTsFileDiskUsagePercentage: {}",
getPipeMaxAllowedLinkedDeletedTsFileDiskUsagePercentage());
LOGGER.info("PipeStuckRestartIntervalSeconds: {}", getPipeStuckRestartIntervalSeconds());
LOGGER.info("PipeStuckRestartMinIntervalMs: {}", getPipeStuckRestartMinIntervalMs());
LOGGER.info(
"PipeEpochKeepTsFileAfterStuckRestartEnabled: {}",
isPipeEpochKeepTsFileAfterStuckRestartEnabled());
LOGGER.info(
"PipeStorageEngineFlushTimeIntervalMs: {}", getPipeStorageEngineFlushTimeIntervalMs());
LOGGER.info("PipeMetaReportMaxLogNumPerRound: {}", getPipeMetaReportMaxLogNumPerRound());
LOGGER.info("PipeMetaReportMaxLogIntervalRounds: {}", getPipeMetaReportMaxLogIntervalRounds());
LOGGER.info("PipeTsFilePinMaxLogNumPerRound: {}", getPipeTsFilePinMaxLogNumPerRound());
LOGGER.info("PipeTsFilePinMaxLogIntervalRounds: {}", getPipeTsFilePinMaxLogIntervalRounds());
LOGGER.info("PipeWalPinMaxLogNumPerRound: {}", getPipeWalPinMaxLogNumPerRound());
LOGGER.info("PipeWalPinMaxLogIntervalRounds: {}", getPipeWalPinMaxLogIntervalRounds());
LOGGER.info("PipeMemoryManagementEnabled: {}", getPipeMemoryManagementEnabled());
LOGGER.info("PipeMemoryAllocateMaxRetries: {}", getPipeMemoryAllocateMaxRetries());
LOGGER.info(
"PipeMemoryAllocateRetryIntervalInMs: {}", getPipeMemoryAllocateRetryIntervalInMs());
LOGGER.info("PipeMemoryAllocateMinSizeInBytes: {}", getPipeMemoryAllocateMinSizeInBytes());
LOGGER.info(
"PipeMemoryAllocateForTsFileSequenceReaderInBytes: {}",
getPipeMemoryAllocateForTsFileSequenceReaderInBytes());
LOGGER.info("PipeMemoryExpanderIntervalSeconds: {}", getPipeMemoryExpanderIntervalSeconds());
LOGGER.info("PipeCheckMemoryEnoughIntervalMs: {}", getPipeCheckMemoryEnoughIntervalMs());
LOGGER.info(
"TwoStageAggregateMaxCombinerLiveTimeInMs: {}",
getTwoStageAggregateMaxCombinerLiveTimeInMs());
LOGGER.info(
"TwoStageAggregateDataRegionInfoCacheTimeInMs: {}",
getTwoStageAggregateDataRegionInfoCacheTimeInMs());
LOGGER.info(
"TwoStageAggregateSenderEndPointsCacheInMs: {}",
getTwoStageAggregateSenderEndPointsCacheInMs());
LOGGER.info("PipeEventReferenceTrackingEnabled: {}", getPipeEventReferenceTrackingEnabled());
LOGGER.info(
"PipeEventReferenceEliminateIntervalSeconds: {}",
getPipeEventReferenceEliminateIntervalSeconds());
}