3.9

Adjusted Signal

3.9

Raw Pattern Score

100%

Time Factor

2026-10-31

Last Push

13.9K

Stars

Java

Language

3.3M

Lines of Code

16.6K

Files

3.3K

Pattern Hits

2026-10-31

Scan Date

0.04

HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 1.9/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 1038 finding(s).

Hallucinated Dependency & Supply Chain Risk 10.5/100 · LOW

Are imports declared and package/API names verified? 743 finding(s).

Agent Over-Engineering Ratio 6.4/100 · LOW

Are wrappers, guards, and repeated structures necessary? 1552 finding(s).

PR Review Velocity Impact 17.1/100 · LOW

Which changes need focused human review? 3268 finding(s).

What These Metrics Mean

Adjusted Signal: Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score: Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor: A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits: Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate: High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files: Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 693HIGH 11MEDIUM 1512LOW 1052

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 3268 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hallucination Indicators693 hits · 7408 pts

Severity	File	Line	Snippet	Context
CRITICAL	…ensearch/indices/analysis/AnalysisFactoryTestCase.java	325	org.apache.lucene.analysis.TokenizerFactory.availableTokenizers()	CODE
CRITICAL	…ensearch/indices/analysis/AnalysisFactoryTestCase.java	337	org.apache.lucene.analysis.CharFilterFactory.availableCharFilters()	CODE
CRITICAL	…ensearch/indices/analysis/AnalysisFactoryTestCase.java	349	org.apache.lucene.analysis.TokenFilterFactory.availableTokenFilters()	CODE
CRITICAL	…rk/src/main/java/org/opensearch/test/StreamsUtils.java	52	return org.opensearch.common.io.Streams.copyToString(new InputStreamReader(is, StandardCharsets.UTF_8));	CODE
CRITICAL	…rk/src/main/java/org/opensearch/test/StreamsUtils.java	60	return org.opensearch.common.io.Streams.copyToString(new InputStreamReader(is, StandardCharsets.UTF_8));	CODE
CRITICAL	…in/java/org/opensearch/test/AbstractQueryTestCase.java	414	BytesReference bytes = org.opensearch.core.xcontent.XContentHelper.toXContent(builder, MediaTypeRegistry.JSON, f	CODE
CRITICAL	…in/java/org/opensearch/test/AbstractQueryTestCase.java	648	BytesReference bytes = org.opensearch.core.xcontent.XContentHelper.toXContent(testQuery, mediaType, false);	CODE
CRITICAL	…opensearch/search/aggregations/AggregatorTestCase.java	589	new org.opensearch.search.aggregations.metrics.CardinalityAggregationContext(false, Runtime.getRuntime().max	CODE
CRITICAL	…discovery/azure/classic/AzureTwoStartedNodesTests.java	45	final String hostType = randomFrom(org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.HostType.values	CODE
CRITICAL	…azure/classic/AzureDiscoveryClusterFormationTests.java	146	org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.HostType.PUBLIC_IP.name()	CODE
CRITICAL	…azure/classic/AzureDiscoveryClusterFormationTests.java	156	org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.Deployment.PRODUCTION.name()	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	24	return org.apache.commons.lang3.StringUtils.join(collection, separator);	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	29	return org.apache.commons.lang3.StringUtils.join(iterator, separator);	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	34	return org.apache.commons.lang3.StringUtils.join(array, separator);	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	39	return org.apache.commons.lang3.StringUtils.join(iterable, separator);	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	43	return org.apache.commons.lang3.StringUtils.isBlank(s);	CODE
CRITICAL⚡	…src/main/java/org/apache/commons/lang/StringUtils.java	47	return org.apache.commons.lang3.StringUtils.isEmpty(s);	CODE
CRITICAL	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	659	() -> new org.apache.logging.log4j.message.ParameterizedMessage(	CODE
CRITICAL	…p/reactor/netty4/ReactorNetty4HttpServerTransport.java	373	io.netty.handler.codec.http3.Http3.supportedApplicationProtocols()	CODE
CRITICAL	…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java	182	if (protocol.equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_0.toString())) {	CODE
CRITICAL	…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java	184	} else if (protocol.equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_1.toString())) {	CODE
CRITICAL	…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java	218	io.netty.handler.codec.http.HttpVersion.valueOf(protocol),	CODE
CRITICAL	…earch/telemetry/tracing/OTelTracingTelemetryTests.java	106	io.opentelemetry.api.common.Attributes otelAttributes = io.opentelemetry.api.common.Attributes.builder()	CODE
CRITICAL	…earch/telemetry/tracing/OTelTracingTelemetryTests.java	120	AttributesBuilder attributesBuilder = io.opentelemetry.api.common.Attributes.builder();	CODE
CRITICAL	…earch/telemetry/tracing/OTelTracingTelemetryTests.java	126	AttributesBuilder attributesBuilder = io.opentelemetry.api.common.Attributes.builder();	CODE
CRITICAL	…ch/telemetry/tracing/OTelTracingContextPropagator.java	47	io.opentelemetry.api.trace.Span span = io.opentelemetry.api.trace.Span.fromContext(context);	CODE
CRITICAL	…ch/telemetry/tracing/OTelTracingContextPropagator.java	66	return Context.current().with(io.opentelemetry.api.trace.Span.wrap(oTelSpan.getDelegateSpan().getSpanContext()))	CODE
CRITICAL	…ava/org/opensearch/repositories/s3/S3AsyncService.java	361	software.amazon.awssdk.http.nio.netty.ProxyConfiguration.builder();	CODE
CRITICAL	…g/opensearch/plugin/hive/IngestFromHiveKerberosIT.java	271	org.apache.hadoop.security.UserGroupInformation.setConfiguration(conf);	CODE
CRITICAL	…/java/org/opensearch/plugin/hive/IngestFromHiveIT.java	626	org.opensearch.common.util.io.IOUtils.rm(dir.toPath());	CODE
CRITICAL	…g/opensearch/plugin/hive/metastore/GetTableResult.java	106	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetTableResult.class, metaDataMap);	CODE
CRITICAL	…g/opensearch/plugin/hive/metastore/GetTableResult.java	336	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…g/opensearch/plugin/hive/metastore/GetTableResult.java	340	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…g/opensearch/plugin/hive/metastore/GetTableResult.java	399	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…arch/plugin/hive/metastore/AlreadyExistsException.java	106	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AlreadyExistsException.class, metaDataMap);	CODE
CRITICAL	…arch/plugin/hive/metastore/AlreadyExistsException.java	329	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…arch/plugin/hive/metastore/AlreadyExistsException.java	333	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…arch/plugin/hive/metastore/AlreadyExistsException.java	401	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…n/java/org/opensearch/plugin/hive/metastore/Order.java	120	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Order.class, metaDataMap);	CODE
CRITICAL⚡	…n/java/org/opensearch/plugin/hive/metastore/Order.java	410	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL⚡	…n/java/org/opensearch/plugin/hive/metastore/Order.java	418	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL⚡	…n/java/org/opensearch/plugin/hive/metastore/Order.java	422	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…n/java/org/opensearch/plugin/hive/metastore/Order.java	503	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	144	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SerDeInfo.class, metaDataMap);	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	527	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	535	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	556	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	560	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java	692	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…rg/opensearch/plugin/hive/metastore/MetaException.java	106	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MetaException.class, metaDataMap);	CODE
CRITICAL	…rg/opensearch/plugin/hive/metastore/MetaException.java	329	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…rg/opensearch/plugin/hive/metastore/MetaException.java	333	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…rg/opensearch/plugin/hive/metastore/MetaException.java	401	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	146	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(FieldSchema.class, metaDataMap);	CODE
CRITICAL⚡	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	511	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL⚡	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	519	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL⚡	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	527	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL⚡	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	531	org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);	CODE
CRITICAL	…/org/opensearch/plugin/hive/metastore/FieldSchema.java	629	return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPL	CODE
CRITICAL	…earch/plugin/hive/metastore/NoSuchObjectException.java	106	org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NoSuchObjectException.class, metaDataMap);	CODE
633 more matches not shown…

Decorative Section Separators1477 hits · 4327 pts

Severity	File	Line	Snippet	Context
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	61	// ─── Over-commit admission (allocator-owned decision) ────────────────────────	COMMENT
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	91	// ─── Over-commit admission API (called by pool-full paths across all pool types) ─────────────	COMMENT
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	258	// ─── Public / SPI methods ───────────────────────────────────────────────────	COMMENT
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	512	// ─── Package-private accessors (used by rebalancer and tests) ────────────────	COMMENT
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	669	// ─── Private helpers ─────────────────────────────────────────────────────────	COMMENT
MEDIUM	…g/opensearch/arrow/allocator/ArrowNativeAllocator.java	692	// ─── Inner classes ───────────────────────────────────────────────────────────	COMMENT
MEDIUM	…opensearch/arrow/allocator/NativeMemoryRebalancer.java	196	// ─── Private helpers ─────────────────────────────────────────────────────────	COMMENT
MEDIUM	…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java	64	// ─── Settings ────────────────────────────────────────────────────────────────	COMMENT
MEDIUM	…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java	212	// ─── Instance state ──────────────────────────────────────────────────────────	COMMENT
MEDIUM	…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java	219	// ─── Plugin lifecycle ────────────────────────────────────────────────────────	COMMENT
MEDIUM	…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java	294	// ─── Package-private (visible for tests) ─────────────────────────────────────	COMMENT
MEDIUM	…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java	384	// ─── Private helpers ─────────────────────────────────────────────────────────	COMMENT
MEDIUM	…h/repositories/s3/async/AsyncTransferManagerTests.java	419	// ── Helpers ────────────────────────────────────────────────────────────────	COMMENT
MEDIUM	…row/flight/transport/FlightTransportResponseTests.java	70	// ── close() / prefetch-race stream lifecycle ─────────────────────────────	COMMENT
MEDIUM	…row/flight/transport/FlightTransportResponseTests.java	224	// ── cancelStreamOnly() / onClosed notification (channel-close support) ──────	COMMENT
MEDIUM	…h/arrow/flight/transport/FlightClientChannelTests.java	260	// ── channel close vs. active streams ───────────────────────────────────────	COMMENT
MEDIUM	…h/arrow/flight/transport/FlightClientChannelTests.java	380	// ── stream failure reporting ───────────────────────────────────────────────	COMMENT
MEDIUM	…h/action/admin/cluster/filecache/FileCacheStatsIT.java	130	// ── helpers ──────────────────────────────────────────────────────────────	COMMENT
MEDIUM	…java/org/opensearch/monitor/fs/WarmFsServiceTests.java	545	// ── Helpers ───────────────────────────────────────────────────────────────	COMMENT
MEDIUM	…/java/org/opensearch/plugins/BlockCacheStatsTests.java	105	// ── Version-gated (BWC) wire serialization ───────────────────────────────	COMMENT
MEDIUM	…/stats/AnalyticsBackendTaskCancellationStatsTests.java	26	// ─── Property Test: Serialization Round-Trip (Property 3) ───────────────────	COMMENT
MEDIUM	…/stats/AnalyticsBackendTaskCancellationStatsTests.java	77	// ─── Unit Tests ─────────────────────────────────────────────────────────────	COMMENT
MEDIUM	…rg/opensearch/storage/tiering/TieringServiceTests.java	1554	// ── removeWriteBlockForCancelledDfaIndices tests ──────────────────────────	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	65	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	67	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	104	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	106	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	146	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	148	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	165	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	167	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	216	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	218	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	260	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	262	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	341	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	343	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	357	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	359	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	418	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…torage/indexinput/FormatSwitchableIndexInputTests.java	420	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	63	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	65	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	113	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	115	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	141	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	143	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	168	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	170	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM⚡	…indexinput/FormatSwitchableIndexInputWrapperTests.java	199	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM⚡	…indexinput/FormatSwitchableIndexInputWrapperTests.java	201	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM⚡	…indexinput/FormatSwitchableIndexInputWrapperTests.java	209	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM⚡	…indexinput/FormatSwitchableIndexInputWrapperTests.java	211	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	240	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…indexinput/FormatSwitchableIndexInputWrapperTests.java	242	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…e/directory/TieredSubdirectoryAwareDirectoryTests.java	206	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…e/directory/TieredSubdirectoryAwareDirectoryTests.java	208	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…e/directory/TieredSubdirectoryAwareDirectoryTests.java	245	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…e/directory/TieredSubdirectoryAwareDirectoryTests.java	247	// ═══════════════════════════════════════════════════════════════	COMMENT
MEDIUM	…e/directory/TieredSubdirectoryAwareDirectoryTests.java	273	// ═══════════════════════════════════════════════════════════════	COMMENT
1417 more matches not shown…

Over-Commented Block582 hits · 567 pts

Severity	File	Line	Snippet	Context
LOW	plugins/analysis-ukrainian/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	plugins/analysis-phonetic/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	plugins/analysis-nori/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	plugins/analysis-kuromoji/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	plugins/analysis-smartcn/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	…pensearch/repositories/s3/async/AsyncPartsHandler.java	121	}	COMMENT
LOW	plugins/ingestion-hive/bin/generate-thrift.sh	1	#!/bin/bash	COMMENT
LOW	plugins/ingestion-hive/licenses/libthrift-LICENSE.txt	261	//	COMMENT
LOW	plugins/analysis-stempel/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	…ch/arrow/flight/transport/FlightTransportResponse.java	121	flightStream = flightClient.getStream(ticket, new HeaderCallOption(callHeaders));	COMMENT
LOW	…search/example/painlessallowlist/example_allowlist.txt	1	#	COMMENT
LOW	plugins/analysis-icu/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	distribution/docker/src/docker/bin/docker-entrypoint.sh	21	if [[ "$1" != "opensearchwrapper" ]]; then	COMMENT
LOW	distribution/docker/src/docker/bin/docker-entrypoint.sh	41	# Allow environment variables to be set by creating a file with the	COMMENT
LOW	distribution/src/config/opensearch.yml	1	# ======================== OpenSearch Configuration =========================	COMMENT
LOW	distribution/src/config/opensearch.yml	21	# Use a descriptive name for the node:	COMMENT
LOW	distribution/src/config/opensearch.yml	41	# Lock the memory on startup:	COMMENT
LOW	distribution/src/config/opensearch.yml	61	# For more information, consult the network module documentation.	COMMENT
LOW	distribution/src/config/opensearch.yml	81	#	COMMENT
LOW	distribution/src/config/opensearch.yml	101	# Gates the visibility of the experimental segment replication features until they are production ready.	COMMENT
LOW	distribution/src/config/opensearch.yml	121	# Once there is no observed impact on performance, this feature flag can be removed.	COMMENT
LOW	server/licenses/lucene-LICENSE.txt	281	# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>	COMMENT
LOW	…arch/search/aggregations/metrics/ScriptedMetricIT.java	161	}));	COMMENT
LOW	…arch/search/aggregations/metrics/ScriptedMetricIT.java	241	}	COMMENT
LOW	…rch/aggregations/bucket/TermsFixedDocCountErrorIT.java	41	public static Collection<Object[]> parameters() {	COMMENT
LOW	…rch/aggregations/bucket/TermsFixedDocCountErrorIT.java	241	);	COMMENT
LOW	…t/java/org/opensearch/index/store/CorruptedFileIT.java	621	.put(MergePolicyProvider.INDEX_MERGE_ENABLED, false)	COMMENT
LOW	…t/java/org/opensearch/gateway/GatewayIndexStateIT.java	601	internalCluster().startNode();	COMMENT
LOW	…/java/org/opensearch/search/fetch/FetchPhaseTests.java	141	// both excludes and includes support simple-match wildcards.	COMMENT
LOW	…/opensearch/common/joda/JavaJodaTimeDuellingTests.java	241	assertSameDate("2010 12 06 11:05:15", "yyyy dd MM HH:mm:ss");	COMMENT
LOW	…action/search/StreamQueryPhaseResultConsumerTests.java	261	// Document count follows the same scaling pattern as max values:	COMMENT
LOW	…c/test/java/org/opensearch/index/VersionTypeTests.java	61	assertTrue(VersionType.INTERNAL.isVersionConflictForWrites(9, 10, randomBoolean()));	COMMENT
LOW	…c/test/java/org/opensearch/index/VersionTypeTests.java	181	assertThat(VersionType.EXTERNAL_GTE.updateVersion(10, 10), equalTo(10L));	COMMENT
LOW	…leformats/node/FixedLengthStarTreeNodeSearchTests.java	341	//	COMMENT
LOW	…a/org/opensearch/index/mapper/HllFieldMapperTests.java	761		COMMENT
LOW	…pensearch/index/engine/NRTReplicaTranslogOpsTests.java	101	// asserting the returned type when no custom factory is configured. A mocked	COMMENT
LOW	…ine/dataformat/merge/MergeSchedulerOnDrainedTests.java	381	assertTrue("Merge should have started", mergeStarted.await(5, TimeUnit.SECONDS));	COMMENT
LOW	…ces/org/opensearch/bootstrap/jvm/deny-jvm-versions.txt	1	// Some version and version range examples are:	COMMENT
LOW	…/routing/allocation/allocator/LocalShardsBalancer.java	261	// checks if the weight delta is above a certain threshold; if it is not above a certain threshold,	COMMENT
LOW	…ices/recovery/LocalStorePeerRecoverySourceHandler.java	101	resources.add(wrappedSafeSnapshot);	COMMENT
LOW	…r/src/main/java/org/opensearch/bootstrap/Security.java	441	// FsHealthService.monitorFSHealth and Node.assertCanWritePluginHealthPaths run as	COMMENT
LOW	…/opensearch/persistent/PersistentTasksNodeService.java	101	// STARTED NULL Create as STARTED, Start	COMMENT
LOW	…opensearch/wlm/WorkloadGroupSharedThrottleService.java	101	// connection) keeps the handler registered; a grant later than this falls back to the coordinator purge or the TTL.	COMMENT
LOW	…rch/profile/query/ConcurrentQueryProfileBreakdown.java	181		COMMENT
LOW	…ns/bucket/terms/SignificantTermsAggregatorFactory.java	261	Aggregator parent,	COMMENT
LOW	…arch/aggregations/bucket/terms/heuristic/JLHScore.java	81	// If we are using a background context that is not a strict superset, a foreground	COMMENT
LOW	…java/org/opensearch/common/util/PageCacheRecycler.java	121		COMMENT
LOW	…store/transfer/stream/OffsetRangeIndexInputStream.java	61	// 1. First check is a coarse-grained check outside reference check which allows us to fail fast if read	COMMENT
LOW	…va/org/opensearch/common/geo/GeoPolygonDecomposer.java	481	// is part of the polygon the hole belongs to.	COMMENT
LOW	…org/opensearch/common/geo/builders/PolygonBuilder.java	521	// To find the new component the hole belongs to all intersections of the	COMMENT
LOW	…org/opensearch/common/geo/builders/PolygonBuilder.java	601	// If two segments are connected maybe a hole must be deleted	COMMENT
LOW	…admin/indices/alias/get/TransportGetAliasesAction.java	201	systemAliases	COMMENT
LOW	…n/java/org/opensearch/index/mapper/DocumentParser.java	1301	// Hand plugins a factory that produces a fresh parser over the buffered bytes rather than a	COMMENT
LOW	…h/index/translog/transfer/TranslogTransferManager.java	281	// concurrently instead, the CAS can win before the sweep while the metadata PUT is still in	COMMENT
LOW	…g/opensearch/index/engine/IndexingStrategyPlanner.java	161	public IndexingStrategy planOperationAsNonPrimary(Engine.Index index) throws IOException {	COMMENT
LOW	…org/opensearch/index/engine/DataFormatAwareEngine.java	321	}	COMMENT
LOW	…org/opensearch/index/engine/DataFormatAwareEngine.java	1521	try {	COMMENT
LOW	…c/main/java/org/opensearch/index/shard/IndexShard.java	4901	// all of the current methods here follow a pattern of:	COMMENT
LOW	…opensearch/index/shard/RemoteStoreRefreshListener.java	221	/*	COMMENT
LOW	…opensearch/index/shard/RemoteStoreRefreshListener.java	261	long bytesBeforeUpload = segmentTracker.getUploadBytesSucceeded(), startTimeInNS = System.nanoTime();	COMMENT
522 more matches not shown…

Structural Annotation Overuse186 hits · 283 pts

Severity	File	Line	Snippet	Context
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	306	// Step 1: Check if it's time to query Metastore for new partitions.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	312	// Step 2: If there's nothing to read (no pending partitions, no open file), return empty.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	317	// Step 3: If no file is currently open, open the next one from pending work.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	324	// Step 4: Read rows from the current file, converting each to a JSON message.	COMMENT
LOW	plugins/examples/stream-transport-example/README.md	5	## Step 1: Create Action Definition	COMMENT
LOW	plugins/examples/stream-transport-example/README.md	18	## Step 2: Create Request/Response Classes	COMMENT
LOW	plugins/examples/stream-transport-example/README.md	42	## Step 3: Create Transport Action	COMMENT
LOW	plugins/examples/stream-transport-example/README.md	85	## Step 4: Register in Plugin	COMMENT
LOW	plugins/examples/stream-transport-example/README.md	98	## Step 5: Client Usage	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	203	// Step 0: Enable WLM mode	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	206	// Step 1: Create workload group	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	210	// Step 2: Create auto-tagging rule	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	214	// Step 3: Index document	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	218	// Step 4: Get pre-query completions	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	221	// Step 5: Execute query	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	226	// Step 6: Get post-query completions	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	90	// Step 3: Stop current primary node and validate replica promotion.	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	96	// Step 4: Verify new primary node is able to index documents	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	106	// Step 5: Add a new node and assign the replica shard. Verify node recovery works.	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	606	// Step 2: Register snapshot repository	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	615	// Step 3: Take snapshot	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	630	// Step 4: Delete Index	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	639	// Step 5: Restore Index from Snapshot	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	648	// Step 6: Verify index is restored and resumes ingestion from the 3rd message	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	661	// Step 1: Create 2 nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	666	// Step 2: Create index on nodeA	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	683	// Step 3: Write documents and verify	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	690	// Step 4: Relocate index to nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	699	// Step 5: Wait for relocation to complete	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	702	// Step 6: Ensure index is searchable on nodeB and can resume ingestion	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	712	// Step 1: Create 2 nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	717	// Step 2: Create index	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	734	// Step 3: Write documents and verify	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	741	// Step 4: Stop kafka and relocate index to nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	751	// Step 5: Wait for relocation to complete	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	754	// Step 6: Ensure index is searchable on nodeB even though kafka is down	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	771	// Step 1: Publish 10 messages	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	776	// Step 2: Start nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	780	// Step 3: Create index with 1 replica	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	797	// Step 4: Add second node and verify green status	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	801	// Step 5: Verify nodeA has the primary shard	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	807	// Step 6: Wait for 10 messages to be searchable on both nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	810	// Step 7: Flush to persist data	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	813	// Step 8: Bring down nodeA (primary) and wait for nodeB to become primary	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	818	// Step 9: Publish 1 new message	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	821	// Step 10: Wait for 11 messages to be visible on nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	824	// Step 11: Validate version conflict count is exactly 1	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	64	// Step 1: Create primary and replica nodes. Create index with 1 replica and kafka as ingestion source.	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	77	// Step 2: Produce update messages and validate segment replication	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	118	// Step 6: Produce new updates and verify segment replication works when primary and replica index are not empty	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	595	// Step 1: Setup index and data	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	304	// Step 2: Update age field from 25 to 30 and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	314	// Step 3: Delete the document and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	322	// Step 4: Validate create operation	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	368	// Step 1: Produce messages	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	378	// Step 2: Produce an update message and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	731	// Step 1: Publish 10 messages	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	736	// Step 2: Start nodes	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	740	// Step 3: Create all-active index	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	757	// Step 4: Wait for 10 messages to be searchable on nodeA	COMMENT
126 more matches not shown…

Verbosity Indicators165 hits · 247 pts

Severity	File	Line	Snippet	Context
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	306	// Step 1: Check if it's time to query Metastore for new partitions.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	312	// Step 2: If there's nothing to read (no pending partitions, no open file), return empty.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	317	// Step 3: If no file is currently open, open the next one from pending work.	COMMENT
LOW⚡	…java/org/opensearch/plugin/hive/HiveShardConsumer.java	324	// Step 4: Read rows from the current file, converting each to a JSON message.	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	203	// Step 0: Enable WLM mode	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	206	// Step 1: Create workload group	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	210	// Step 2: Create auto-tagging rule	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	214	// Step 3: Index document	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	218	// Step 4: Get pre-query completions	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	221	// Step 5: Execute query	COMMENT
LOW⚡	…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java	226	// Step 6: Get post-query completions	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	90	// Step 3: Stop current primary node and validate replica promotion.	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	96	// Step 4: Verify new primary node is able to index documents	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	106	// Step 5: Add a new node and assign the replica shard. Verify node recovery works.	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	606	// Step 2: Register snapshot repository	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	615	// Step 3: Take snapshot	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	630	// Step 4: Delete Index	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	639	// Step 5: Restore Index from Snapshot	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	648	// Step 6: Verify index is restored and resumes ingestion from the 3rd message	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	661	// Step 1: Create 2 nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	666	// Step 2: Create index on nodeA	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	683	// Step 3: Write documents and verify	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	690	// Step 4: Relocate index to nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	699	// Step 5: Wait for relocation to complete	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	702	// Step 6: Ensure index is searchable on nodeB and can resume ingestion	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	712	// Step 1: Create 2 nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	717	// Step 2: Create index	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	734	// Step 3: Write documents and verify	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	741	// Step 4: Stop kafka and relocate index to nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	751	// Step 5: Wait for relocation to complete	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	754	// Step 6: Ensure index is searchable on nodeB even though kafka is down	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	771	// Step 1: Publish 10 messages	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	776	// Step 2: Start nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	780	// Step 3: Create index with 1 replica	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	797	// Step 4: Add second node and verify green status	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	801	// Step 5: Verify nodeA has the primary shard	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	807	// Step 6: Wait for 10 messages to be searchable on both nodes	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	810	// Step 7: Flush to persist data	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	813	// Step 8: Bring down nodeA (primary) and wait for nodeB to become primary	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	818	// Step 9: Publish 1 new message	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	821	// Step 10: Wait for 11 messages to be visible on nodeB	COMMENT
LOW⚡	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	824	// Step 11: Validate version conflict count is exactly 1	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	64	// Step 1: Create primary and replica nodes. Create index with 1 replica and kafka as ingestion source.	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	77	// Step 2: Produce update messages and validate segment replication	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	118	// Step 6: Produce new updates and verify segment replication works when primary and replica index are not empty	COMMENT
LOW	…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java	595	// Step 1: Setup index and data	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	304	// Step 2: Update age field from 25 to 30 and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	314	// Step 3: Delete the document and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	322	// Step 4: Validate create operation	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	368	// Step 1: Produce messages	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	378	// Step 2: Produce an update message and validate	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	731	// Step 1: Publish 10 messages	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	736	// Step 2: Start nodes	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	740	// Step 3: Create all-active index	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	757	// Step 4: Wait for 10 messages to be searchable on nodeA	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	760	// Step 5: Flush to persist data	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	763	// Step 6: Add second node	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	766	// Step 7: Relocate shard from nodeA to nodeB	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	771	// Step 8: Publish 1 new message	COMMENT
LOW⚡	…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java	774	// Step 9: Wait for 11 messages to be visible on nodeB	COMMENT
105 more matches not shown…

Hyper-Verbose Identifiers65 hits · 65 pts

Severity	File	Line	Snippet	Context
LOW	…nsearch/transport/AbstractSimpleTransportTestCase.java	1964	class TestRequestHandler implements TransportRequestHandler<TestRequest> {	CODE
LOW	…nsearch/transport/AbstractSimpleTransportTestCase.java	2052	class TestResponseHandler implements TransportResponseHandler<TestResponse> {	CODE
LOW	…nsearch/arrow/transport/ArrowBatchResponseHandler.java	22	public abstract class ArrowBatchResponseHandler<T extends ArrowBatchResponse> implements StreamTransportResponseHandler<	CODE
LOW	…rg/opensearch/arrow/flight/NativeArrowTransportIT.java	467	static class TestArrowResponseHandler extends ArrowBatchResponseHandler<TestArrowResponse> {	CODE
LOW	…w/flight/transport/MetricsTrackingResponseHandler.java	26	class MetricsTrackingResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {	CODE
LOW	…xample/stream/NativeArrowStreamTransportExampleIT.java	138	static class NativeArrowResponseHandler extends ArrowBatchResponseHandler<NativeArrowStreamDataResponse> {	CODE
LOW	…rTest/java/org/opensearch/action/IndicesRequestIT.java	827	private class InterceptingRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {	CODE
LOW	…pensearch/cluster/coordination/LeaderCheckerTests.java	545	private class CapturingTransportResponseHandler implements TransportResponseHandler<Empty> {	CODE
LOW	…lm/WorkloadManagementTransportRequestHandlerTests.java	81	private static class TestTransportRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {	CODE
LOW	…l/transport/AdmissionControlTransportHandlerTests.java	78	private class InterceptingRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {	CODE
LOW	…a/org/opensearch/cluster/coordination/Publication.java	379	private class PublishResponseHandler implements ActionListener<PublishWithJoinResponse> {	CODE
LOW	…a/org/opensearch/cluster/coordination/Publication.java	425	private class ApplyCommitResponseHandler implements ActionListener<TransportResponse.Empty> {	CODE
LOW	…java/org/opensearch/tasks/TaskCancellationService.java	232	private class BanParentRequestHandler implements TransportRequestHandler<BanParentTaskRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoverySourceService.java	202	class StartRecoveryTransportRequestHandler implements TransportRequestHandler<StartRecoveryRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoverySourceService.java	209	class ReestablishRecoveryTransportRequestHandler implements TransportRequestHandler<ReestablishRecoveryRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	420	class PrepareForTranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryPrepareForTranslogOperat	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	436	class FinalizeRecoveryRequestHandler implements TransportRequestHandler<RecoveryFinalizeRecoveryRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	452	class HandoffPrimaryContextRequestHandler implements TransportRequestHandler<RecoveryHandoffPrimaryContextRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	465	class TranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryTranslogOperationsRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	551	class FilesInfoRequestHandler implements TransportRequestHandler<RecoveryFilesInfoRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	574	class CleanFilesRequestHandler implements TransportRequestHandler<RecoveryCleanFilesRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	595	class FileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {	CODE
LOW	…search/indices/recovery/PeerRecoveryTargetService.java	655	private class RecoveryResponseHandler implements TransportResponseHandler<RecoveryResponse> {	CODE
LOW	…dices/replication/SegmentReplicationTargetService.java	604	private class FileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {	CODE
LOW	…dices/replication/SegmentReplicationTargetService.java	623	private class ForceSyncTransportRequestHandler implements TransportRequestHandler<ForceSyncRequest> {	CODE
LOW	…dices/replication/SegmentReplicationTargetService.java	806	private class MergedSegmentFileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {	CODE
LOW	…dices/replication/SegmentReplicationSourceService.java	126	private class CheckpointInfoRequestHandler implements TransportRequestHandler<CheckpointInfoRequest> {	CODE
LOW	…dices/replication/SegmentReplicationSourceService.java	156	private class GetSegmentFilesRequestHandler implements TransportRequestHandler<GetSegmentFilesRequest> {	CODE
LOW	…dices/replication/SegmentReplicationSourceService.java	163	private class UpdateVisibleCheckpointRequestHandler implements TransportRequestHandler<UpdateVisibleCheckpointReques	CODE
LOW	…dices/replication/SegmentReplicationSourceService.java	177	private class GetMergedSegmentFilesRequestHandler implements TransportRequestHandler<GetSegmentFilesRequest> {	CODE
LOW	…in/java/org/opensearch/indices/store/IndicesStore.java	261	private class ShardActiveResponseHandler implements TransportResponseHandler<ShardActiveResponse> {	CODE
LOW	…in/java/org/opensearch/indices/store/IndicesStore.java	357	private class ShardActiveRequestHandler implements TransportRequestHandler<ShardActiveRequest> {	CODE
LOW	…/org/opensearch/transport/SniffConnectionStrategy.java	403	private class SniffClusterStateResponseHandler implements TransportResponseHandler<ClusterStateResponse> {	CODE
LOW	…java/org/opensearch/transport/TransportHandshaker.java	137	private class HandshakeResponseHandler implements TransportResponseHandler<HandshakeResponse> {	CODE
LOW	…pensearch/transport/EmptyTransportResponseHandler.java	44	public class EmptyTransportResponseHandler implements TransportResponseHandler<TransportResponse.Empty> {	CODE
LOW	…in/java/org/opensearch/transport/TransportService.java	1537	public static final class ContextRestoreResponseHandler<T extends TransportResponse> implements TransportResponseHan	CODE
LOW	…ava/org/opensearch/transport/NativeMessageHandler.java	515	private static class RequestHandler<T extends TransportRequest> extends AbstractRunnable {	CODE
LOW	…ava/org/opensearch/transport/TransportActionProxy.java	62	private static class ProxyRequestHandler<T extends ProxyRequest> implements TransportRequestHandler<T> {	CODE
LOW	…ava/org/opensearch/transport/TransportActionProxy.java	96	private static class ProxyResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {	CODE
LOW	…search/wlm/WorkloadManagementTransportInterceptor.java	44	public static class RequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {	CODE
LOW	…covery/BlockingClusterStatePublishResponseHandler.java	49	public class BlockingClusterStatePublishResponseHandler {	CODE
LOW	…pensearch/repositories/VerifyNodeRepositoryAction.java	191	class VerifyNodeRepositoryRequestHandler implements TransportRequestHandler<VerifyNodeRepositoryRequest> {	CODE
LOW	…ensearch/extensions/UpdateSettingsResponseHandler.java	26	public class UpdateSettingsResponseHandler implements TransportResponseHandler<AcknowledgedResponse> {	CODE
LOW	…xtensions/AddSettingsUpdateConsumerRequestHandler.java	28	public class AddSettingsUpdateConsumerRequestHandler {	CODE
LOW	…/extensions/settings/CustomSettingsRequestHandler.java	24	public class CustomSettingsRequestHandler {	CODE
LOW	…nsearch/extensions/rest/RestActionsRequestHandler.java	27	public class RestActionsRequestHandler {	CODE
LOW	…g/opensearch/action/ActionListenerResponseHandler.java	52	public class ActionListenerResponseHandler<Response extends TransportResponse> implements TransportResponseHandler<Respo	CODE
LOW	…ava/org/opensearch/action/bulk/BulkRequestHandler.java	50	public final class BulkRequestHandler {	CODE
LOW	…ort/broadcast/node/TransportBroadcastByNodeAction.java	520	class BroadcastByNodeTransportRequestHandler implements TransportRequestHandler<NodeRequest> {	CODE
LOW	…tracing/handler/TraceableTransportResponseHandler.java	27	public class TraceableTransportResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {	CODE
LOW	…rg/opensearch/gateway/LocalAllocateDangledIndices.java	125	class AllocateDangledRequestHandler implements TransportRequestHandler<AllocateDangledRequest> {	CODE
LOW	…/java/org/opensearch/http/netty4/Netty4HttpClient.java	451	private static class UpgradeRequestHandler extends ChannelInboundHandlerAdapter {	CODE
LOW	…g/opensearch/http/netty4/Netty4HttpRequestHandler.java	45	class Netty4HttpRequestHandler extends SimpleChannelInboundHandler<HttpPipelinedRequest> {	CODE
LOW	…in/resources/org/opensearch/painless/spi/java.util.txt	152	def getOrDefault(def,def)	CODE
LOW	…ensearch/client/sniff/OpenSearchNodesSnifferTests.java	171	private static class ResponseHandler implements HttpHandler {	CODE
LOW	…nal/httpclient/RestHttpClientGzipCompressionTests.java	75	private static class GzipResponseHandler implements HttpHandler {	CODE
LOW	…/httpclient/RestHttpClientMultipleHostsIntegTests.java	150	private static class ResponseHandler implements HttpHandler {	CODE
LOW	…nal/httpclient/RestHttpClientSingleHostIntegTests.java	112	private static class ResponseHandler implements HttpHandler {	CODE
LOW	…lient/RestHttpClientSingleHostStreamingIntegTests.java	69	private static class ResponseHandler implements HttpHandler {	CODE
LOW	…nternal/httpclient/RestHttpClientCompressionTests.java	52	private static class GzipResponseHandler implements HttpHandler {	CODE
5 more matches not shown…

Fake / Example Data50 hits · 54 pts

Severity	File	Line	Snippet	Context
LOW	…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java	290	stash.stashValue("placeholder", "elements");	CODE
LOW⚡	…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java	304	stash.stashValue("placeholder", "ele");	CODE
LOW⚡	…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java	310	stash.stashValue("placeholder", "le");	CODE
LOW⚡	…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java	316	stash.stashValue("placeholder", "le");	CODE
LOW	…a/org/opensearch/repositories/s3/S3ClientSettings.java	74	private static final String PLACEHOLDER_CLIENT = "placeholder";	CODE
LOW⚡	…ces/rest-api-spec/test/custom-suggester/20_suggest.yml	51	- match: { suggest.test.0.dummy: entry-dummy-value }	CODE
LOW⚡	…ces/rest-api-spec/test/custom-suggester/20_suggest.yml	53	- match: { suggest.test.0.options.0.dummy: option-dummy-value-1 }	CODE
LOW⚡	…ces/rest-api-spec/test/custom-suggester/20_suggest.yml	55	- match: { suggest.test.0.options.1.dummy: option-dummy-value-2 }	CODE
LOW	…pensearch/example/customsuggester/CustomSuggester.java	69	CustomSuggestion.Entry.Option option12 = new CustomSuggestion.Entry.Option(new Text(firstOption), 0.9f, "option-	CODE
LOW⚡	…pensearch/example/customsuggester/CustomSuggester.java	80	CustomSuggestion.Entry.Option option123 = new CustomSuggestion.Entry.Option(new Text(secondOption), 0.8f, "optio	CODE
LOW⚡	…pensearch/example/customsuggester/CustomSuggester.java	89	CustomSuggestion response = new CustomSuggestion(name, suggestion.getSize(), "suggestion-dummy-value");	CODE
LOW⚡	…pensearch/example/customsuggester/CustomSuggester.java	90	CustomSuggestion.Entry entry = new CustomSuggestion.Entry(new Text(text), 0, text.length(), "entry-dummy-value")	CODE
LOW	…opensearch/search/fetch/subphase/MatchedQueriesIT.java	370	client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();	CODE
LOW	…opensearch/search/fetch/subphase/MatchedQueriesIT.java	370	client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();	CODE
LOW	…opensearch/search/fetch/subphase/MatchedQueriesIT.java	408	client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();	CODE
LOW	…opensearch/search/fetch/subphase/MatchedQueriesIT.java	408	client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();	CODE
LOW	…terTest/java/org/opensearch/nodestats/NodeStatsIT.java	62	private static final String VALUE = "dummy_value";	CODE
LOW	…tion/ClusterBootstrapServiceDeprecatedMasterTests.java	207	assertThat(vc.getNodeIds(), not(hasItem(containsString("placeholder"))));	CODE
LOW	…cluster/coordination/ClusterBootstrapServiceTests.java	225	assertThat(vc.getNodeIds(), not(hasItem(containsString("placeholder"))));	CODE
LOW	…aggregations/pipeline/BucketScriptAggregatorTests.java	91	FiltersAggregationBuilder filters = new FiltersAggregationBuilder("placeholder", new MatchAllQueryBuilder()).sub	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	71	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	166	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	297	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	329	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	412	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	479	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	591	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	657	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	825	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	919	.field("name", "John Doe")	CODE
LOW	…common/xcontent/support/AbstractFilteringTestCase.java	1020	.field("name", "John Doe")	CODE
LOW	…a/org/opensearch/index/mapper/DocumentParserTests.java	2729	b.field("name", "Jane Doe");	CODE
LOW	…a/org/opensearch/index/mapper/DocumentParserTests.java	2849	b.field("user.name", "John Doe");	CODE
LOW	…a/org/opensearch/index/mapper/DocumentParserTests.java	2855	assertEquals("John Doe", doc.rootDoc().getField("user.name").stringValue());	CODE
LOW	…a/org/opensearch/index/mapper/DynamicMappingTests.java	368	b.field("author", "John Doe");	CODE
LOW	…a/org/opensearch/index/mapper/DynamicMappingTests.java	378	assertThat(sourceMap.get("author"), equalTo("John Doe"));	CODE
LOW	…bs/dissect/src/test/resources/specification/tests.json	258	"name": "Jane Doe",	CODE
LOW	…bs/dissect/src/test/resources/specification/tests.json	272	"name": "Jane Doe",	CODE
LOW	…nalytics-backend-datafusion/rust/src/udf/rex_offset.rs	213	let result = calculate_offsets(&r, "user@example.com").unwrap();	CODE
LOW	…alytics-backend-datafusion/rust/src/udf/rex_extract.rs	239	assert_eq!(extract_group(&r, "user@example.com", "host"), Some("user"));	CODE
LOW	…alytics-backend-datafusion/rust/src/udf/rex_extract.rs	241	extract_group(&r, "user@example.com", "domain"),	CODE
LOW	…s-backend-datafusion/rust/src/udaf/internal_pattern.rs	618	"foo@bar.com".to_string(),	CODE
LOW	…x/plugins/block-cache-foyer/src/main/rust/src/tests.rs	788	let fake_key = "data/file.parquet\x1F99999-100000".to_string();	CODE
LOW	…x/plugins/block-cache-foyer/src/main/rust/src/tests.rs	793	.insert(fake_key.clone());	CODE
LOW	…ces/rest-api-spec/test/search/380_bitmap_filtering.yml	22	- { "name": "Jane Doe", "student_id": 111 }	CODE
LOW	…ces/rest-api-spec/test/search/380_bitmap_filtering.yml	26	- { "name": "John Doe", "student_id": 333 }	CODE
LOW	…rest-api-spec/test/index/111_false_allow_templates.yml	105	author: "John Doe"	CODE
LOW	…rest-api-spec/test/index/111_false_allow_templates.yml	124	author: "John Doe"	CODE
LOW	…search/index/reindex/AsyncBulkByScrollActionTests.java	940	index.id() == null ? "dummy_id" : index.id(),	CODE
LOW	…java/org/opensearch/script/mustache/MustacheTests.java	313	.field("name", "John Doe")	CODE

Cross-File Repetition10 hits · 50 pts

Severity	File	Snippet	Context
HIGH	…lugin/wlm/action/UpdateWorkloadGroupResponseTests.java	{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo	STRING
HIGH	…lugin/wlm/action/CreateWorkloadGroupResponseTests.java	{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo	STRING
HIGH	…h/plugin/wlm/action/GetWorkloadGroupResponseTests.java	{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo	STRING
HIGH	…/opensearch/analytics/planner/UnionPlanShapeTests.java	opensearchexchangereducer(viablebackends=[[mock-parquet]], exchange=[exchangeinfo[distributiontype=singleton, partitionk	STRING
HIGH	…arch/analytics/planner/SortPushdownPlanShapeTests.java	opensearchexchangereducer(viablebackends=[[mock-parquet]], exchange=[exchangeinfo[distributiontype=singleton, partitionk	STRING
HIGH	…g/opensearch/analytics/planner/SortPlanShapeTests.java	opensearchexchangereducer(viablebackends=[[mock-parquet]], exchange=[exchangeinfo[distributiontype=singleton, partitionk	STRING
HIGH	…g/opensearch/analytics/planner/ScanPlanShapeTests.java	opensearchexchangereducer(viablebackends=[[mock-parquet]], exchange=[exchangeinfo[distributiontype=singleton, partitionk	STRING
HIGH	…arch/analytics/planner/SortPushdownPlanShapeTests.java	opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc	STRING
HIGH	…g/opensearch/analytics/planner/SortPlanShapeTests.java	opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc	STRING
HIGH	…a/org/opensearch/analytics/planner/PlanShapeTests.java	opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc	STRING

AI Slop Vocabulary16 hits · 48 pts

Severity	File	Line	Snippet	Context
MEDIUM	…/org/opensearch/test/store/MockFSDirectoryFactory.java	172	// TODO: make this test robust to virus scanner	COMMENT
MEDIUM	…st/java/org/opensearch/remotestore/WritableWarmIT.java	209	// TODO: Make these validation more robust, when SwitchableIndexInput is implemented.	COMMENT
MEDIUM	…ch/action/admin/cluster/node/stats/NodeStatsTests.java	1679	// Build via the existing helper so the test is robust against future ctor argument churn.	COMMENT
MEDIUM	…in/java/org/opensearch/transport/TransportChannel.java	66	* Do not use {@link #sendResponse} in conjunction with this method if you are sending a batch of responses.	COMMENT
MEDIUM	…search/transport/stream/StreamingTransportChannel.java	34	* Do not use {@link #sendResponse} in conjunction with this method if you are sending a batch of responses.	COMMENT
MEDIUM	…ch/fetch/subphase/highlight/FastVectorHighlighter.java	218	// Essentially we just request that a fragment is built from 0 to noMatchSize using	COMMENT
MEDIUM	…arch/search/profile/query/ConcurrentQueryProfiler.java	53	// We utilize LinkedHashMap to preserve the insertion order of the profiled queries	COMMENT
MEDIUM	…ch/analytics/planner/rules/SplitRuleContractTests.java	285	// makes the mock more robust if a future rule path needs it).	COMMENT
MEDIUM	…a/org/opensearch/analytics/planner/dag/DAGBuilder.java	363	// cutter robust to future plan shapes.	COMMENT
MEDIUM	…earch/analytics/exec/shuffle/ShuffleBufferManager.java	184	// expiry - now > 0 (not now < expiry) to be robust to nanoTime wraparound.	COMMENT
MEDIUM	…ackend-datafusion/rust/src/scoped_page_index_reader.rs	90	/// the same `resolve_predicate_parquet_columns` the indexed path uses, robust to	COMMENT
MEDIUM	…x/plugins/analytics-backend-datafusion/rust/src/api.rs	3638	// logic robust to upstream changes.)	COMMENT
MEDIUM	…rg/opensearch/parquet/writer/ParquetDocumentInput.java	47	// guard. Name keying makes accumulation robust to that.	COMMENT
MEDIUM	…st/java/org/opensearch/composite/StatsLifecycleIT.java	467	// Accepting -1 OR 0 makes the assertion robust to future shape changes (e.g., emitting	COMMENT
MEDIUM	…ava/org/opensearch/be/datafusion/SortReverseQtfIT.java	346	* over the seeded fixture. Mirrors {@link #categoryFor(long)} so the test is robust to	COMMENT
MEDIUM	…rch/analytics/resilience/ReduceEarlyTerminationIT.java	239	// check below is the robust, routing-independent signal.)	COMMENT

Self-Referential Comments16 hits · 48 pts

Severity	File	Line	Snippet	Context
MEDIUM	…c/test/repository_s3/60_repository_eks_credentials.yml	65	# Create a first snapshot	COMMENT
MEDIUM	…c/test/repository_s3/60_repository_eks_credentials.yml	114	# Create a second snapshot	COMMENT
MEDIUM	…c/test/repository_s3/40_repository_ec2_credentials.yml	63	# Create a first snapshot	COMMENT
MEDIUM	…c/test/repository_s3/40_repository_ec2_credentials.yml	112	# Create a second snapshot	COMMENT
MEDIUM	…/repository_s3/20_repository_permanent_credentials.yml	154	# Create a first snapshot	COMMENT
MEDIUM	…/repository_s3/20_repository_permanent_credentials.yml	203	# Create a second snapshot	COMMENT
MEDIUM	…c/test/repository_s3/50_repository_ecs_credentials.yml	63	# Create a first snapshot	COMMENT
MEDIUM	…c/test/repository_s3/50_repository_ecs_credentials.yml	112	# Create a second snapshot	COMMENT
MEDIUM	…/repository_s3/30_repository_temporary_credentials.yml	63	# Create a first snapshot	COMMENT
MEDIUM	…/repository_s3/30_repository_temporary_credentials.yml	112	# Create a second snapshot	COMMENT
MEDIUM	…es/rest-api-spec/test/repository_gcs/20_repository.yml	68	# Create a first snapshot	COMMENT
MEDIUM	…es/rest-api-spec/test/repository_gcs/20_repository.yml	117	# Create a second snapshot	COMMENT
MEDIUM	…/rest-api-spec/test/repository_azure/20_repository.yml	68	# Create a first snapshot	COMMENT
MEDIUM	…/rest-api-spec/test/repository_azure/20_repository.yml	117	# Create a second snapshot	COMMENT
MEDIUM	…sources/rest-api-spec/test/repository_url/10_basic.yml	37	# Create a first snapshot using the FS repository	COMMENT
MEDIUM	…sources/rest-api-spec/test/repository_url/10_basic.yml	66	# Create a second snapshot	COMMENT

Synthetic Comment Markers1 hit · 8 pts

Severity	File	Line	Snippet	Context
HIGH	…opensearch/indices/recovery/RecoverySourceHandler.java	617	// existing lease we (approximately) know that all our peers are also retaining history as requested by the	COMMENT

Modern AI Meta-Vocabulary2 hits · 6 pts

Severity	File	Line	Snippet	Context
MEDIUM	…arameterizedStaticSettingsOpenSearchIntegTestCase.java	24	* {@link #hasSameParametersAs(ParameterizedOpenSearchIntegTestCase)} is being used by the test scaffolding to detect wh	COMMENT
MEDIUM	…nsearch/test/ParameterizedOpenSearchIntegTestCase.java	25	* {@link #hasSameParametersAs(ParameterizedOpenSearchIntegTestCase)} is being used by the test scaffolding to detect	COMMENT

Slop Phrases3 hits · 6 pts

Severity	File	Line	Snippet	Context
LOW	distribution/src/config/opensearch.yml	4	# Before you set out to tweak and tune the configuration, make sure you	COMMENT
LOW	…/search/fetch/subphase/highlight/HighlightBuilder.java	542	* the named field. If you provide a list of fields here then don't forget to include name as	COMMENT
MEDIUM	…earch/gradle/precommit/ValidateJsonNoKeywordsTask.java	68	* The keywords are defined in a JSON file, although it's worth noting that what is and isn't a	COMMENT

Redundant / Tautological Comments1 hit · 2 pts

Severity	File	Line	Snippet	Context
LOW	distribution/src/config/opensearch.yml	128	# Set this to a directory on a dedicated filesystem to enable spill — the directory	COMMENT

TODO Padding1 hit · 2 pts

Severity	File	Line	Snippet	Context
LOW	…arch/analytics/planner/dag/PickRandomNodeSelector.java	35	// TODO: implement when shuffle aggregates/joins are added.	COMMENT

opensearch-project/OpenSearch

Open-Source Code Quality, Security and Technical Debt Review