diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java index 81d8871b8e8e..d7294abc9d58 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java @@ -2733,6 +2733,10 @@ private boolean updatePartitionDataFromStream() log.debug("Found [%d] partitions for stream [%s]", partitionIdsFromSupplier.size(), ioConfig.getStream()); + final int configuredTaskCount = spec.getIoConfig().getTaskCount(); + if (configuredTaskCount > partitionIdsFromSupplier.size()) { + log.warn("Configured task count[%s] for supervisor[%s] is greater than the number of partitions[%d].", configuredTaskCount, supervisorId, partitionIdsFromSupplier.size()); + } Map storedMetadata = getOffsetsFromMetadataStorage(); Set storedPartitions = storedMetadata.keySet(); Set closedPartitions = storedMetadata