Repository Analysis

opensearch-project/OpenSearch

🔎 Open source distributed and RESTful search engine.

3.8 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of opensearch-project/OpenSearch, a Java project with 13,432 GitHub stars. SynthScan v2.0 examined 3,186,268 lines of code across 16062 source files, recording 3005 pattern matches distributed across 15 syntactic categories. The overall adjusted score of 3.8 places this repository in the Likely human-written band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

3.8
Adjusted Score
3.8
Raw Score
100%
Time Factor
2026-07-31
Last Push
13.4K
Stars
Java
Language
3.2M
Lines of Code
16.1K
Files
3.0K
Pattern Hits
2026-08-02
Scan Date
0.04
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 647HIGH 7MEDIUM 1384LOW 967

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 3005 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Hallucination Indicators647 hits · 6938 pts
SeverityFileLineSnippetContext
CRITICAL…ensearch/indices/analysis/AnalysisFactoryTestCase.java317 org.apache.lucene.analysis.TokenizerFactory.availableTokenizers()CODE
CRITICAL…ensearch/indices/analysis/AnalysisFactoryTestCase.java329 org.apache.lucene.analysis.CharFilterFactory.availableCharFilters()CODE
CRITICAL…ensearch/indices/analysis/AnalysisFactoryTestCase.java341 org.apache.lucene.analysis.TokenFilterFactory.availableTokenFilters()CODE
CRITICAL…rk/src/main/java/org/opensearch/test/StreamsUtils.java52 return org.opensearch.common.io.Streams.copyToString(new InputStreamReader(is, StandardCharsets.UTF_8));CODE
CRITICAL…rk/src/main/java/org/opensearch/test/StreamsUtils.java60 return org.opensearch.common.io.Streams.copyToString(new InputStreamReader(is, StandardCharsets.UTF_8));CODE
CRITICAL…in/java/org/opensearch/test/AbstractQueryTestCase.java414 BytesReference bytes = org.opensearch.core.xcontent.XContentHelper.toXContent(builder, MediaTypeRegistry.JSON, fCODE
CRITICAL…in/java/org/opensearch/test/AbstractQueryTestCase.java648 BytesReference bytes = org.opensearch.core.xcontent.XContentHelper.toXContent(testQuery, mediaType, false);CODE
CRITICAL…opensearch/search/aggregations/AggregatorTestCase.java565 new org.opensearch.search.aggregations.metrics.CardinalityAggregationContext(false, Runtime.getRuntime().maxCODE
CRITICAL…discovery/azure/classic/AzureTwoStartedNodesTests.java45 final String hostType = randomFrom(org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.HostType.valuesCODE
CRITICAL…azure/classic/AzureDiscoveryClusterFormationTests.java146 org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.HostType.PUBLIC_IP.name()CODE
CRITICAL…azure/classic/AzureDiscoveryClusterFormationTests.java156 org.opensearch.discovery.azure.classic.AzureSeedHostsProvider.Deployment.PRODUCTION.name()CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java24 return org.apache.commons.lang3.StringUtils.join(collection, separator);CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java29 return org.apache.commons.lang3.StringUtils.join(iterator, separator);CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java34 return org.apache.commons.lang3.StringUtils.join(array, separator);CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java39 return org.apache.commons.lang3.StringUtils.join(iterable, separator);CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java43 return org.apache.commons.lang3.StringUtils.isBlank(s);CODE
CRITICAL…src/main/java/org/apache/commons/lang/StringUtils.java47 return org.apache.commons.lang3.StringUtils.isEmpty(s);CODE
CRITICAL…g/opensearch/arrow/allocator/ArrowNativeAllocator.java659 () -> new org.apache.logging.log4j.message.ParameterizedMessage(CODE
CRITICAL…p/reactor/netty4/ReactorNetty4HttpServerTransport.java373 io.netty.handler.codec.http3.Http3.supportedApplicationProtocols()CODE
CRITICAL…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java182 if (protocol.equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_0.toString())) {CODE
CRITICAL…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java184 } else if (protocol.equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_1.toString())) {CODE
CRITICAL…arch/http/reactor/netty4/ReactorNetty4HttpRequest.java218 io.netty.handler.codec.http.HttpVersion.valueOf(protocol),CODE
CRITICAL…earch/telemetry/tracing/OTelTracingTelemetryTests.java106 io.opentelemetry.api.common.Attributes otelAttributes = io.opentelemetry.api.common.Attributes.builder()CODE
CRITICAL…earch/telemetry/tracing/OTelTracingTelemetryTests.java120 AttributesBuilder attributesBuilder = io.opentelemetry.api.common.Attributes.builder();CODE
CRITICAL…earch/telemetry/tracing/OTelTracingTelemetryTests.java126 AttributesBuilder attributesBuilder = io.opentelemetry.api.common.Attributes.builder();CODE
CRITICAL…ch/telemetry/tracing/OTelTracingContextPropagator.java47 io.opentelemetry.api.trace.Span span = io.opentelemetry.api.trace.Span.fromContext(context);CODE
CRITICAL…ch/telemetry/tracing/OTelTracingContextPropagator.java66 return Context.current().with(io.opentelemetry.api.trace.Span.wrap(oTelSpan.getDelegateSpan().getSpanContext()))CODE
CRITICAL…ava/org/opensearch/repositories/s3/S3AsyncService.java361 software.amazon.awssdk.http.nio.netty.ProxyConfiguration.builder();CODE
CRITICAL…g/opensearch/plugin/hive/IngestFromHiveKerberosIT.java271 org.apache.hadoop.security.UserGroupInformation.setConfiguration(conf);CODE
CRITICAL…/java/org/opensearch/plugin/hive/IngestFromHiveIT.java626 org.opensearch.common.util.io.IOUtils.rm(dir.toPath());CODE
CRITICAL…g/opensearch/plugin/hive/metastore/GetTableResult.java106 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetTableResult.class, metaDataMap);CODE
CRITICAL…g/opensearch/plugin/hive/metastore/GetTableResult.java336 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…g/opensearch/plugin/hive/metastore/GetTableResult.java340 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…g/opensearch/plugin/hive/metastore/GetTableResult.java399 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…arch/plugin/hive/metastore/AlreadyExistsException.java106 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AlreadyExistsException.class, metaDataMap);CODE
CRITICAL…arch/plugin/hive/metastore/AlreadyExistsException.java329 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…arch/plugin/hive/metastore/AlreadyExistsException.java333 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…arch/plugin/hive/metastore/AlreadyExistsException.java401 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…n/java/org/opensearch/plugin/hive/metastore/Order.java120 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Order.class, metaDataMap);CODE
CRITICAL…n/java/org/opensearch/plugin/hive/metastore/Order.java410 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…n/java/org/opensearch/plugin/hive/metastore/Order.java418 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…n/java/org/opensearch/plugin/hive/metastore/Order.java422 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…n/java/org/opensearch/plugin/hive/metastore/Order.java503 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java144 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SerDeInfo.class, metaDataMap);CODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java527 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java535 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java556 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java560 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…va/org/opensearch/plugin/hive/metastore/SerDeInfo.java692 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…rg/opensearch/plugin/hive/metastore/MetaException.java106 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MetaException.class, metaDataMap);CODE
CRITICAL…rg/opensearch/plugin/hive/metastore/MetaException.java329 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…rg/opensearch/plugin/hive/metastore/MetaException.java333 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…rg/opensearch/plugin/hive/metastore/MetaException.java401 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java146 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(FieldSchema.class, metaDataMap);CODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java511 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java519 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java527 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java531 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);CODE
CRITICAL…/org/opensearch/plugin/hive/metastore/FieldSchema.java629 return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLCODE
CRITICAL…earch/plugin/hive/metastore/NoSuchObjectException.java106 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NoSuchObjectException.class, metaDataMap);CODE
587 more matches not shown…
Decorative Section Separators1354 hits · 3957 pts
SeverityFileLineSnippetContext
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java61 // ─── Over-commit admission (allocator-owned decision) ────────────────────────COMMENT
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java91 // ─── Over-commit admission API (called by pool-full paths across all pool types) ─────────────COMMENT
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java258 // ─── Public / SPI methods ───────────────────────────────────────────────────COMMENT
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java512 // ─── Package-private accessors (used by rebalancer and tests) ────────────────COMMENT
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java669 // ─── Private helpers ─────────────────────────────────────────────────────────COMMENT
MEDIUM…g/opensearch/arrow/allocator/ArrowNativeAllocator.java692 // ─── Inner classes ───────────────────────────────────────────────────────────COMMENT
MEDIUM…opensearch/arrow/allocator/NativeMemoryRebalancer.java196 // ─── Private helpers ─────────────────────────────────────────────────────────COMMENT
MEDIUM…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java62 // ─── Settings ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java210 // ─── Instance state ──────────────────────────────────────────────────────────COMMENT
MEDIUM…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java217 // ─── Plugin lifecycle ────────────────────────────────────────────────────────COMMENT
MEDIUM…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java292 // ─── Package-private (visible for tests) ─────────────────────────────────────COMMENT
MEDIUM…va/org/opensearch/arrow/allocator/ArrowBasePlugin.java382 // ─── Private helpers ─────────────────────────────────────────────────────────COMMENT
MEDIUM…h/repositories/s3/async/AsyncTransferManagerTests.java419 // ── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…row/flight/transport/FlightTransportResponseTests.java67 // ── close() / prefetch-race stream lifecycle ─────────────────────────────COMMENT
MEDIUM…h/action/admin/cluster/filecache/FileCacheStatsIT.java130 // ── helpers ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…java/org/opensearch/monitor/fs/WarmFsServiceTests.java545 // ── Helpers ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…/java/org/opensearch/plugins/BlockCacheStatsTests.java105 // ── Version-gated (BWC) wire serialization ───────────────────────────────COMMENT
MEDIUM…/stats/AnalyticsBackendTaskCancellationStatsTests.java26 // ─── Property Test: Serialization Round-Trip (Property 3) ───────────────────COMMENT
MEDIUM…/stats/AnalyticsBackendTaskCancellationStatsTests.java77 // ─── Unit Tests ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…rg/opensearch/storage/tiering/TieringServiceTests.java1554 // ── removeWriteBlockForCancelledDfaIndices tests ──────────────────────────COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java65 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java67 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java104 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java106 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java146 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java148 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java165 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java167 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java216 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java218 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java260 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java262 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java341 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java343 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java357 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java359 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java418 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…torage/indexinput/FormatSwitchableIndexInputTests.java420 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java63 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java65 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java113 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java115 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java141 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java143 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java168 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java170 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java199 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java201 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java209 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java211 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java240 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…indexinput/FormatSwitchableIndexInputWrapperTests.java242 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java206 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java208 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java245 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java247 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java273 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java275 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java337 // ═══════════════════════════════════════════════════════════════COMMENT
MEDIUM…e/directory/TieredSubdirectoryAwareDirectoryTests.java339 // ═══════════════════════════════════════════════════════════════COMMENT
1294 more matches not shown…
Over-Commented Block500 hits · 492 pts
SeverityFileLineSnippetContext
LOWplugins/analysis-ukrainian/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWplugins/analysis-phonetic/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWplugins/analysis-nori/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWplugins/analysis-kuromoji/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWplugins/analysis-smartcn/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOW…pensearch/repositories/s3/async/AsyncPartsHandler.java121 }COMMENT
LOWplugins/ingestion-hive/bin/generate-thrift.sh1#!/bin/bashCOMMENT
LOWplugins/ingestion-hive/licenses/libthrift-LICENSE.txt261//COMMENT
LOWplugins/analysis-stempel/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOW…search/example/painlessallowlist/example_allowlist.txt1#COMMENT
LOWplugins/analysis-icu/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWdistribution/docker/src/docker/bin/docker-entrypoint.sh21if [[ "$1" != "opensearchwrapper" ]]; thenCOMMENT
LOWdistribution/docker/src/docker/bin/docker-entrypoint.sh41# Allow environment variables to be set by creating a file with theCOMMENT
LOWdistribution/src/config/opensearch.yml1# ======================== OpenSearch Configuration =========================COMMENT
LOWdistribution/src/config/opensearch.yml21# Use a descriptive name for the node:COMMENT
LOWdistribution/src/config/opensearch.yml41# Lock the memory on startup:COMMENT
LOWdistribution/src/config/opensearch.yml61# For more information, consult the network module documentation.COMMENT
LOWdistribution/src/config/opensearch.yml81#COMMENT
LOWdistribution/src/config/opensearch.yml101# Gates the visibility of the experimental segment replication features until they are production ready.COMMENT
LOWdistribution/src/config/opensearch.yml121# Once there is no observed impact on performance, this feature flag can be removed.COMMENT
LOWserver/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOW…arch/search/aggregations/metrics/ScriptedMetricIT.java161 }));COMMENT
LOW…arch/search/aggregations/metrics/ScriptedMetricIT.java241 }COMMENT
LOW…rch/aggregations/bucket/TermsFixedDocCountErrorIT.java41 public static Collection<Object[]> parameters() {COMMENT
LOW…rch/aggregations/bucket/TermsFixedDocCountErrorIT.java241 );COMMENT
LOW…t/java/org/opensearch/index/store/CorruptedFileIT.java621 .put(MergePolicyProvider.INDEX_MERGE_ENABLED, false)COMMENT
LOW…t/java/org/opensearch/gateway/GatewayIndexStateIT.java601 internalCluster().startNode();COMMENT
LOW…/java/org/opensearch/search/fetch/FetchPhaseTests.java141 // both excludes and includes support simple-match wildcards.COMMENT
LOW…/opensearch/common/joda/JavaJodaTimeDuellingTests.java241 assertSameDate("2010 12 06 11:05:15", "yyyy dd MM HH:mm:ss");COMMENT
LOW…action/search/StreamQueryPhaseResultConsumerTests.java261 // Document count follows the same scaling pattern as max values:COMMENT
LOW…c/test/java/org/opensearch/index/VersionTypeTests.java61 assertTrue(VersionType.INTERNAL.isVersionConflictForWrites(9, 10, randomBoolean()));COMMENT
LOW…c/test/java/org/opensearch/index/VersionTypeTests.java181 assertThat(VersionType.EXTERNAL_GTE.updateVersion(10, 10), equalTo(10L));COMMENT
LOW…leformats/node/FixedLengthStarTreeNodeSearchTests.java341 //COMMENT
LOW…a/org/opensearch/index/mapper/HllFieldMapperTests.java761COMMENT
LOW…pensearch/index/engine/NRTReplicaTranslogOpsTests.java101 // asserting the returned type when no custom factory is configured. A mockedCOMMENT
LOW…ine/dataformat/merge/MergeSchedulerOnDrainedTests.java381 assertTrue("Merge should have started", mergeStarted.await(5, TimeUnit.SECONDS));COMMENT
LOW…ces/org/opensearch/bootstrap/jvm/deny-jvm-versions.txt1// Some version and version range examples are:COMMENT
LOW…/routing/allocation/allocator/LocalShardsBalancer.java261 // checks if the weight delta is above a certain threshold; if it is not above a certain threshold,COMMENT
LOW…ices/recovery/LocalStorePeerRecoverySourceHandler.java101 resources.add(wrappedSafeSnapshot);COMMENT
LOW…r/src/main/java/org/opensearch/bootstrap/Security.java441 // FsHealthService.monitorFSHealth and Node.assertCanWritePluginHealthPaths run asCOMMENT
LOW…/opensearch/persistent/PersistentTasksNodeService.java101 // STARTED NULL Create as STARTED, StartCOMMENT
LOW…rch/profile/query/ConcurrentQueryProfileBreakdown.java181COMMENT
LOW…ns/bucket/terms/SignificantTermsAggregatorFactory.java261 Aggregator parent,COMMENT
LOW…arch/aggregations/bucket/terms/heuristic/JLHScore.java81 // If we are using a background context that is not a strict superset, a foregroundCOMMENT
LOW…java/org/opensearch/common/util/PageCacheRecycler.java121COMMENT
LOW…store/transfer/stream/OffsetRangeIndexInputStream.java61 // 1. First check is a coarse-grained check outside reference check which allows us to fail fast if readCOMMENT
LOW…va/org/opensearch/common/geo/GeoPolygonDecomposer.java481 // is part of the polygon the hole belongs to.COMMENT
LOW…org/opensearch/common/geo/builders/PolygonBuilder.java521 // To find the new component the hole belongs to all intersections of theCOMMENT
LOW…org/opensearch/common/geo/builders/PolygonBuilder.java601 // If two segments are connected maybe a hole must be deletedCOMMENT
LOW…admin/indices/alias/get/TransportGetAliasesAction.java201 systemAliasesCOMMENT
LOW…n/java/org/opensearch/index/mapper/DocumentParser.java441 handleDisableObjectsMapping(parentMappers, newMapper, docMapper, mapping);COMMENT
LOW…g/opensearch/index/engine/IndexingStrategyPlanner.java161 public IndexingStrategy planOperationAsNonPrimary(Engine.Index index) throws IOException {COMMENT
LOW…org/opensearch/index/engine/DataFormatAwareEngine.java1161 if (waitIfOngoing == false) {COMMENT
LOW…c/main/java/org/opensearch/index/shard/IndexShard.java4461COMMENT
LOWlibs/core/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOWlibs/netty4/licenses/lucene-LICENSE.txt281# Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com>COMMENT
LOW…java/org/opensearch/common/TimeBasedUUIDGenerator.java101 // but not necessarily for lookup speed (by having the leading bytes identifyCOMMENT
LOW…in/java/org/opensearch/secure_sm/policy/Tokenizer.java21 * Don't convert words to lowercaseCOMMENT
LOW…java/org/opensearch/gradle/pluginzip/PublishTests.java141 // have it evaluated (API call) and then check if there are tasks that the plugin uses to hookup intoCOMMENT
LOW…java/org/opensearch/gradle/pluginzip/PublishTests.java441 * It covers the case when user calls the "publishToMavenLocal" task.COMMENT
440 more matches not shown…
Structural Annotation Overuse183 hits · 278 pts
SeverityFileLineSnippetContext
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java306 // Step 1: Check if it's time to query Metastore for new partitions.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java312 // Step 2: If there's nothing to read (no pending partitions, no open file), return empty.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java317 // Step 3: If no file is currently open, open the next one from pending work.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java324 // Step 4: Read rows from the current file, converting each to a JSON message.COMMENT
LOWplugins/examples/stream-transport-example/README.md5## Step 1: Create Action DefinitionCOMMENT
LOWplugins/examples/stream-transport-example/README.md18## Step 2: Create Request/Response ClassesCOMMENT
LOWplugins/examples/stream-transport-example/README.md42## Step 3: Create Transport ActionCOMMENT
LOWplugins/examples/stream-transport-example/README.md85## Step 4: Register in PluginCOMMENT
LOWplugins/examples/stream-transport-example/README.md98## Step 5: Client UsageCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java203 // Step 0: Enable WLM modeCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java206 // Step 1: Create workload groupCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java210 // Step 2: Create auto-tagging ruleCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java214 // Step 3: Index documentCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java218 // Step 4: Get pre-query completionsCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java221 // Step 5: Execute queryCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java226 // Step 6: Get post-query completionsCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java90 // Step 3: Stop current primary node and validate replica promotion.COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java96 // Step 4: Verify new primary node is able to index documentsCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java106 // Step 5: Add a new node and assign the replica shard. Verify node recovery works.COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java606 // Step 2: Register snapshot repositoryCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java615 // Step 3: Take snapshotCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java630 // Step 4: Delete IndexCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java639 // Step 5: Restore Index from SnapshotCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java648 // Step 6: Verify index is restored and resumes ingestion from the 3rd messageCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java661 // Step 1: Create 2 nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java666 // Step 2: Create index on nodeACOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java683 // Step 3: Write documents and verifyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java690 // Step 4: Relocate index to nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java699 // Step 5: Wait for relocation to completeCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java702 // Step 6: Ensure index is searchable on nodeB and can resume ingestionCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java712 // Step 1: Create 2 nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java717 // Step 2: Create indexCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java734 // Step 3: Write documents and verifyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java741 // Step 4: Stop kafka and relocate index to nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java751 // Step 5: Wait for relocation to completeCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java754 // Step 6: Ensure index is searchable on nodeB even though kafka is downCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java771 // Step 1: Publish 10 messagesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java776 // Step 2: Start nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java780 // Step 3: Create index with 1 replicaCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java797 // Step 4: Add second node and verify green statusCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java801 // Step 5: Verify nodeA has the primary shardCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java807 // Step 6: Wait for 10 messages to be searchable on both nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java810 // Step 7: Flush to persist dataCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java813 // Step 8: Bring down nodeA (primary) and wait for nodeB to become primaryCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java818 // Step 9: Publish 1 new messageCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java821 // Step 10: Wait for 11 messages to be visible on nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java824 // Step 11: Validate version conflict count is exactly 1COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java64 // 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.java77 // Step 2: Produce update messages and validate segment replicationCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java118 // Step 6: Produce new updates and verify segment replication works when primary and replica index are not emptyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java595 // Step 1: Setup index and dataCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java304 // Step 2: Update age field from 25 to 30 and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java314 // Step 3: Delete the document and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java322 // Step 4: Validate create operationCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java368 // Step 1: Produce messagesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java378 // Step 2: Produce an update message and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java731 // Step 1: Publish 10 messagesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java736 // Step 2: Start nodesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java740 // Step 3: Create all-active indexCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java757 // Step 4: Wait for 10 messages to be searchable on nodeACOMMENT
123 more matches not shown…
Verbosity Indicators162 hits · 243 pts
SeverityFileLineSnippetContext
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java306 // Step 1: Check if it's time to query Metastore for new partitions.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java312 // Step 2: If there's nothing to read (no pending partitions, no open file), return empty.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java317 // Step 3: If no file is currently open, open the next one from pending work.COMMENT
LOW…java/org/opensearch/plugin/hive/HiveShardConsumer.java324 // Step 4: Read rows from the current file, converting each to a JSON message.COMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java203 // Step 0: Enable WLM modeCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java206 // Step 1: Create workload groupCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java210 // Step 2: Create auto-tagging ruleCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java214 // Step 3: Index documentCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java218 // Step 4: Get pre-query completionsCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java221 // Step 5: Execute queryCOMMENT
LOW…t/java/org/opensearch/plugin/wlm/WlmAutoTaggingIT.java226 // Step 6: Get post-query completionsCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java90 // Step 3: Stop current primary node and validate replica promotion.COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java96 // Step 4: Verify new primary node is able to index documentsCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java106 // Step 5: Add a new node and assign the replica shard. Verify node recovery works.COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java606 // Step 2: Register snapshot repositoryCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java615 // Step 3: Take snapshotCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java630 // Step 4: Delete IndexCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java639 // Step 5: Restore Index from SnapshotCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java648 // Step 6: Verify index is restored and resumes ingestion from the 3rd messageCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java661 // Step 1: Create 2 nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java666 // Step 2: Create index on nodeACOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java683 // Step 3: Write documents and verifyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java690 // Step 4: Relocate index to nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java699 // Step 5: Wait for relocation to completeCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java702 // Step 6: Ensure index is searchable on nodeB and can resume ingestionCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java712 // Step 1: Create 2 nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java717 // Step 2: Create indexCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java734 // Step 3: Write documents and verifyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java741 // Step 4: Stop kafka and relocate index to nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java751 // Step 5: Wait for relocation to completeCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java754 // Step 6: Ensure index is searchable on nodeB even though kafka is downCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java771 // Step 1: Publish 10 messagesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java776 // Step 2: Start nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java780 // Step 3: Create index with 1 replicaCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java797 // Step 4: Add second node and verify green statusCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java801 // Step 5: Verify nodeA has the primary shardCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java807 // Step 6: Wait for 10 messages to be searchable on both nodesCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java810 // Step 7: Flush to persist dataCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java813 // Step 8: Bring down nodeA (primary) and wait for nodeB to become primaryCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java818 // Step 9: Publish 1 new messageCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java821 // Step 10: Wait for 11 messages to be visible on nodeBCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java824 // Step 11: Validate version conflict count is exactly 1COMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java64 // 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.java77 // Step 2: Produce update messages and validate segment replicationCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java118 // Step 6: Produce new updates and verify segment replication works when primary and replica index are not emptyCOMMENT
LOW…va/org/opensearch/plugin/kafka/RemoteStoreKafkaIT.java595 // Step 1: Setup index and dataCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java304 // Step 2: Update age field from 25 to 30 and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java314 // Step 3: Delete the document and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java322 // Step 4: Validate create operationCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java368 // Step 1: Produce messagesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java378 // Step 2: Produce an update message and validateCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java731 // Step 1: Publish 10 messagesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java736 // Step 2: Start nodesCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java740 // Step 3: Create all-active indexCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java757 // Step 4: Wait for 10 messages to be searchable on nodeACOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java760 // Step 5: Flush to persist dataCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java763 // Step 6: Add second nodeCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java766 // Step 7: Relocate shard from nodeA to nodeBCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java771 // Step 8: Publish 1 new messageCOMMENT
LOW…ava/org/opensearch/plugin/kafka/IngestFromKafkaIT.java774 // Step 9: Wait for 11 messages to be visible on nodeBCOMMENT
102 more matches not shown…
Hyper-Verbose Identifiers65 hits · 65 pts
SeverityFileLineSnippetContext
LOW…nsearch/transport/AbstractSimpleTransportTestCase.java1964 class TestRequestHandler implements TransportRequestHandler<TestRequest> {CODE
LOW…nsearch/transport/AbstractSimpleTransportTestCase.java2052 class TestResponseHandler implements TransportResponseHandler<TestResponse> {CODE
LOW…nsearch/arrow/transport/ArrowBatchResponseHandler.java22public abstract class ArrowBatchResponseHandler<T extends ArrowBatchResponse> implements StreamTransportResponseHandler<CODE
LOW…rg/opensearch/arrow/flight/NativeArrowTransportIT.java467 static class TestArrowResponseHandler extends ArrowBatchResponseHandler<TestArrowResponse> {CODE
LOW…w/flight/transport/MetricsTrackingResponseHandler.java26class MetricsTrackingResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {CODE
LOW…xample/stream/NativeArrowStreamTransportExampleIT.java138 static class NativeArrowResponseHandler extends ArrowBatchResponseHandler<NativeArrowStreamDataResponse> {CODE
LOW…rTest/java/org/opensearch/action/IndicesRequestIT.java827 private class InterceptingRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {CODE
LOW…pensearch/cluster/coordination/LeaderCheckerTests.java545 private class CapturingTransportResponseHandler implements TransportResponseHandler<Empty> {CODE
LOW…lm/WorkloadManagementTransportRequestHandlerTests.java81 private static class TestTransportRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {CODE
LOW…l/transport/AdmissionControlTransportHandlerTests.java78 private class InterceptingRequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {CODE
LOW…a/org/opensearch/cluster/coordination/Publication.java379 private class PublishResponseHandler implements ActionListener<PublishWithJoinResponse> {CODE
LOW…a/org/opensearch/cluster/coordination/Publication.java425 private class ApplyCommitResponseHandler implements ActionListener<TransportResponse.Empty> {CODE
LOW…java/org/opensearch/tasks/TaskCancellationService.java232 private class BanParentRequestHandler implements TransportRequestHandler<BanParentTaskRequest> {CODE
LOW…search/indices/recovery/PeerRecoverySourceService.java202 class StartRecoveryTransportRequestHandler implements TransportRequestHandler<StartRecoveryRequest> {CODE
LOW…search/indices/recovery/PeerRecoverySourceService.java209 class ReestablishRecoveryTransportRequestHandler implements TransportRequestHandler<ReestablishRecoveryRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java419 class PrepareForTranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryPrepareForTranslogOperatCODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java435 class FinalizeRecoveryRequestHandler implements TransportRequestHandler<RecoveryFinalizeRecoveryRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java451 class HandoffPrimaryContextRequestHandler implements TransportRequestHandler<RecoveryHandoffPrimaryContextRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java464 class TranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryTranslogOperationsRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java550 class FilesInfoRequestHandler implements TransportRequestHandler<RecoveryFilesInfoRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java573 class CleanFilesRequestHandler implements TransportRequestHandler<RecoveryCleanFilesRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java594 class FileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {CODE
LOW…search/indices/recovery/PeerRecoveryTargetService.java654 private class RecoveryResponseHandler implements TransportResponseHandler<RecoveryResponse> {CODE
LOW…dices/replication/SegmentReplicationTargetService.java604 private class FileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {CODE
LOW…dices/replication/SegmentReplicationTargetService.java623 private class ForceSyncTransportRequestHandler implements TransportRequestHandler<ForceSyncRequest> {CODE
LOW…dices/replication/SegmentReplicationTargetService.java806 private class MergedSegmentFileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> {CODE
LOW…dices/replication/SegmentReplicationSourceService.java126 private class CheckpointInfoRequestHandler implements TransportRequestHandler<CheckpointInfoRequest> {CODE
LOW…dices/replication/SegmentReplicationSourceService.java156 private class GetSegmentFilesRequestHandler implements TransportRequestHandler<GetSegmentFilesRequest> {CODE
LOW…dices/replication/SegmentReplicationSourceService.java163 private class UpdateVisibleCheckpointRequestHandler implements TransportRequestHandler<UpdateVisibleCheckpointRequesCODE
LOW…dices/replication/SegmentReplicationSourceService.java177 private class GetMergedSegmentFilesRequestHandler implements TransportRequestHandler<GetSegmentFilesRequest> {CODE
LOW…in/java/org/opensearch/indices/store/IndicesStore.java261 private class ShardActiveResponseHandler implements TransportResponseHandler<ShardActiveResponse> {CODE
LOW…in/java/org/opensearch/indices/store/IndicesStore.java357 private class ShardActiveRequestHandler implements TransportRequestHandler<ShardActiveRequest> {CODE
LOW…/org/opensearch/transport/SniffConnectionStrategy.java403 private class SniffClusterStateResponseHandler implements TransportResponseHandler<ClusterStateResponse> {CODE
LOW…java/org/opensearch/transport/TransportHandshaker.java137 private class HandshakeResponseHandler implements TransportResponseHandler<HandshakeResponse> {CODE
LOW…pensearch/transport/EmptyTransportResponseHandler.java44public class EmptyTransportResponseHandler implements TransportResponseHandler<TransportResponse.Empty> {CODE
LOW…in/java/org/opensearch/transport/TransportService.java1537 public static final class ContextRestoreResponseHandler<T extends TransportResponse> implements TransportResponseHanCODE
LOW…ava/org/opensearch/transport/NativeMessageHandler.java515 private static class RequestHandler<T extends TransportRequest> extends AbstractRunnable {CODE
LOW…ava/org/opensearch/transport/TransportActionProxy.java62 private static class ProxyRequestHandler<T extends ProxyRequest> implements TransportRequestHandler<T> {CODE
LOW…ava/org/opensearch/transport/TransportActionProxy.java96 private static class ProxyResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {CODE
LOW…search/wlm/WorkloadManagementTransportInterceptor.java44 public static class RequestHandler<T extends TransportRequest> implements TransportRequestHandler<T> {CODE
LOW…covery/BlockingClusterStatePublishResponseHandler.java49public class BlockingClusterStatePublishResponseHandler {CODE
LOW…pensearch/repositories/VerifyNodeRepositoryAction.java191 class VerifyNodeRepositoryRequestHandler implements TransportRequestHandler<VerifyNodeRepositoryRequest> {CODE
LOW…ensearch/extensions/UpdateSettingsResponseHandler.java26public class UpdateSettingsResponseHandler implements TransportResponseHandler<AcknowledgedResponse> {CODE
LOW…xtensions/AddSettingsUpdateConsumerRequestHandler.java28public class AddSettingsUpdateConsumerRequestHandler {CODE
LOW…/extensions/settings/CustomSettingsRequestHandler.java24public class CustomSettingsRequestHandler {CODE
LOW…nsearch/extensions/rest/RestActionsRequestHandler.java27public class RestActionsRequestHandler {CODE
LOW…g/opensearch/action/ActionListenerResponseHandler.java52public class ActionListenerResponseHandler<Response extends TransportResponse> implements TransportResponseHandler<RespoCODE
LOW…ava/org/opensearch/action/bulk/BulkRequestHandler.java50public final class BulkRequestHandler {CODE
LOW…ort/broadcast/node/TransportBroadcastByNodeAction.java520 class BroadcastByNodeTransportRequestHandler implements TransportRequestHandler<NodeRequest> {CODE
LOW…tracing/handler/TraceableTransportResponseHandler.java27public class TraceableTransportResponseHandler<T extends TransportResponse> implements TransportResponseHandler<T> {CODE
LOW…rg/opensearch/gateway/LocalAllocateDangledIndices.java125 class AllocateDangledRequestHandler implements TransportRequestHandler<AllocateDangledRequest> {CODE
LOW…/java/org/opensearch/http/netty4/Netty4HttpClient.java451 private static class UpgradeRequestHandler extends ChannelInboundHandlerAdapter {CODE
LOW…g/opensearch/http/netty4/Netty4HttpRequestHandler.java45class Netty4HttpRequestHandler extends SimpleChannelInboundHandler<HttpPipelinedRequest> {CODE
LOW…in/resources/org/opensearch/painless/spi/java.util.txt152 def getOrDefault(def,def)CODE
LOW…ensearch/client/sniff/OpenSearchNodesSnifferTests.java171 private static class ResponseHandler implements HttpHandler {CODE
LOW…nal/httpclient/RestHttpClientGzipCompressionTests.java75 private static class GzipResponseHandler implements HttpHandler {CODE
LOW…/httpclient/RestHttpClientMultipleHostsIntegTests.java150 private static class ResponseHandler implements HttpHandler {CODE
LOW…nal/httpclient/RestHttpClientSingleHostIntegTests.java112 private static class ResponseHandler implements HttpHandler {CODE
LOW…lient/RestHttpClientSingleHostStreamingIntegTests.java69 private static class ResponseHandler implements HttpHandler {CODE
LOW…nternal/httpclient/RestHttpClientCompressionTests.java52 private static class GzipResponseHandler implements HttpHandler {CODE
5 more matches not shown…
Fake / Example Data50 hits · 54 pts
SeverityFileLineSnippetContext
LOW…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java290 stash.stashValue("placeholder", "elements");CODE
LOW…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java304 stash.stashValue("placeholder", "ele");CODE
LOW…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java310 stash.stashValue("placeholder", "le");CODE
LOW…ava/org/opensearch/test/rest/yaml/ObjectPathTests.java316 stash.stashValue("placeholder", "le");CODE
LOW…a/org/opensearch/repositories/s3/S3ClientSettings.java74 private static final String PLACEHOLDER_CLIENT = "placeholder";CODE
LOW…ces/rest-api-spec/test/custom-suggester/20_suggest.yml51 - match: { suggest.test.0.dummy: entry-dummy-value }CODE
LOW…ces/rest-api-spec/test/custom-suggester/20_suggest.yml53 - match: { suggest.test.0.options.0.dummy: option-dummy-value-1 }CODE
LOW…ces/rest-api-spec/test/custom-suggester/20_suggest.yml55 - match: { suggest.test.0.options.1.dummy: option-dummy-value-2 }CODE
LOW…pensearch/example/customsuggester/CustomSuggester.java69 CustomSuggestion.Entry.Option option12 = new CustomSuggestion.Entry.Option(new Text(firstOption), 0.9f, "option-CODE
LOW…pensearch/example/customsuggester/CustomSuggester.java80 CustomSuggestion.Entry.Option option123 = new CustomSuggestion.Entry.Option(new Text(secondOption), 0.8f, "optioCODE
LOW…pensearch/example/customsuggester/CustomSuggester.java89 CustomSuggestion response = new CustomSuggestion(name, suggestion.getSize(), "suggestion-dummy-value");CODE
LOW…pensearch/example/customsuggester/CustomSuggester.java90 CustomSuggestion.Entry entry = new CustomSuggestion.Entry(new Text(text), 0, text.length(), "entry-dummy-value")CODE
LOW…opensearch/search/fetch/subphase/MatchedQueriesIT.java370 client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();CODE
LOW…opensearch/search/fetch/subphase/MatchedQueriesIT.java370 client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();CODE
LOW…opensearch/search/fetch/subphase/MatchedQueriesIT.java408 client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();CODE
LOW…opensearch/search/fetch/subphase/MatchedQueriesIT.java408 client().prepareIndex("test").setId("1").setSource("content", "Lorem ipsum dolor sit amet").get();CODE
LOW…terTest/java/org/opensearch/nodestats/NodeStatsIT.java62 private static final String VALUE = "dummy_value";CODE
LOW…tion/ClusterBootstrapServiceDeprecatedMasterTests.java207 assertThat(vc.getNodeIds(), not(hasItem(containsString("placeholder"))));CODE
LOW…cluster/coordination/ClusterBootstrapServiceTests.java225 assertThat(vc.getNodeIds(), not(hasItem(containsString("placeholder"))));CODE
LOW…aggregations/pipeline/BucketScriptAggregatorTests.java91 FiltersAggregationBuilder filters = new FiltersAggregationBuilder("placeholder", new MatchAllQueryBuilder()).subCODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java71 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java166 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java297 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java329 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java412 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java479 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java591 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java657 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java825 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java919 .field("name", "John Doe")CODE
LOW…common/xcontent/support/AbstractFilteringTestCase.java1020 .field("name", "John Doe")CODE
LOW…a/org/opensearch/index/mapper/DocumentParserTests.java2729 b.field("name", "Jane Doe");CODE
LOW…a/org/opensearch/index/mapper/DocumentParserTests.java2849 b.field("user.name", "John Doe");CODE
LOW…a/org/opensearch/index/mapper/DocumentParserTests.java2855 assertEquals("John Doe", doc.rootDoc().getField("user.name").stringValue());CODE
LOW…a/org/opensearch/index/mapper/DynamicMappingTests.java368 b.field("author", "John Doe");CODE
LOW…a/org/opensearch/index/mapper/DynamicMappingTests.java378 assertThat(sourceMap.get("author"), equalTo("John Doe"));CODE
LOW…bs/dissect/src/test/resources/specification/tests.json258 "name": "Jane Doe",CODE
LOW…bs/dissect/src/test/resources/specification/tests.json272 "name": "Jane Doe",CODE
LOW…nalytics-backend-datafusion/rust/src/udf/rex_offset.rs213 let result = calculate_offsets(&r, "user@example.com").unwrap();CODE
LOW…alytics-backend-datafusion/rust/src/udf/rex_extract.rs239 assert_eq!(extract_group(&r, "user@example.com", "host"), Some("user"));CODE
LOW…alytics-backend-datafusion/rust/src/udf/rex_extract.rs241 extract_group(&r, "user@example.com", "domain"),CODE
LOW…s-backend-datafusion/rust/src/udaf/internal_pattern.rs618 "foo@bar.com".to_string(),CODE
LOW…x/plugins/block-cache-foyer/src/main/rust/src/tests.rs788 let fake_key = "data/file.parquet\x1F99999-100000".to_string();CODE
LOW…x/plugins/block-cache-foyer/src/main/rust/src/tests.rs793 .insert(fake_key.clone());CODE
LOW…ces/rest-api-spec/test/search/380_bitmap_filtering.yml22 - { "name": "Jane Doe", "student_id": 111 }CODE
LOW…ces/rest-api-spec/test/search/380_bitmap_filtering.yml26 - { "name": "John Doe", "student_id": 333 }CODE
LOW…rest-api-spec/test/index/111_false_allow_templates.yml105 author: "John Doe"CODE
LOW…rest-api-spec/test/index/111_false_allow_templates.yml124 author: "John Doe"CODE
LOW…search/index/reindex/AsyncBulkByScrollActionTests.java940 index.id() == null ? "dummy_id" : index.id(),CODE
LOW…java/org/opensearch/script/mustache/MustacheTests.java313 .field("name", "John Doe")CODE
Self-Referential Comments16 hits · 48 pts
SeverityFileLineSnippetContext
MEDIUM…c/test/repository_s3/60_repository_eks_credentials.yml65 # Create a first snapshotCOMMENT
MEDIUM…c/test/repository_s3/60_repository_eks_credentials.yml114 # Create a second snapshotCOMMENT
MEDIUM…c/test/repository_s3/40_repository_ec2_credentials.yml63 # Create a first snapshotCOMMENT
MEDIUM…c/test/repository_s3/40_repository_ec2_credentials.yml112 # Create a second snapshotCOMMENT
MEDIUM…/repository_s3/20_repository_permanent_credentials.yml154 # Create a first snapshotCOMMENT
MEDIUM…/repository_s3/20_repository_permanent_credentials.yml203 # Create a second snapshotCOMMENT
MEDIUM…c/test/repository_s3/50_repository_ecs_credentials.yml63 # Create a first snapshotCOMMENT
MEDIUM…c/test/repository_s3/50_repository_ecs_credentials.yml112 # Create a second snapshotCOMMENT
MEDIUM…/repository_s3/30_repository_temporary_credentials.yml63 # Create a first snapshotCOMMENT
MEDIUM…/repository_s3/30_repository_temporary_credentials.yml112 # Create a second snapshotCOMMENT
MEDIUM…es/rest-api-spec/test/repository_gcs/20_repository.yml68 # Create a first snapshotCOMMENT
MEDIUM…es/rest-api-spec/test/repository_gcs/20_repository.yml117 # Create a second snapshotCOMMENT
MEDIUM…/rest-api-spec/test/repository_azure/20_repository.yml68 # Create a first snapshotCOMMENT
MEDIUM…/rest-api-spec/test/repository_azure/20_repository.yml117 # Create a second snapshotCOMMENT
MEDIUM…sources/rest-api-spec/test/repository_url/10_basic.yml37 # Create a first snapshot using the FS repositoryCOMMENT
MEDIUM…sources/rest-api-spec/test/repository_url/10_basic.yml66 # Create a second snapshotCOMMENT
AI Slop Vocabulary11 hits · 33 pts
SeverityFileLineSnippetContext
MEDIUM…/org/opensearch/test/store/MockFSDirectoryFactory.java172 // TODO: make this test robust to virus scannerCOMMENT
MEDIUM…st/java/org/opensearch/remotestore/WritableWarmIT.java209 // TODO: Make these validation more robust, when SwitchableIndexInput is implemented.COMMENT
MEDIUM…ch/action/admin/cluster/node/stats/NodeStatsTests.java1634 // Build via the existing helper so the test is robust against future ctor argument churn.COMMENT
MEDIUM…in/java/org/opensearch/transport/TransportChannel.java66 * Do not use {@link #sendResponse} in conjunction with this method if you are sending a batch of responses.COMMENT
MEDIUM…search/transport/stream/StreamingTransportChannel.java34 * 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.java218 // Essentially we just request that a fragment is built from 0 to noMatchSize usingCOMMENT
MEDIUM…arch/search/profile/query/ConcurrentQueryProfiler.java53 // We utilize LinkedHashMap to preserve the insertion order of the profiled queriesCOMMENT
MEDIUM…ackend-datafusion/rust/src/scoped_page_index_reader.rs90/// the same `resolve_predicate_parquet_columns` the indexed path uses, robust toCOMMENT
MEDIUM…st/java/org/opensearch/composite/StatsLifecycleIT.java467 // Accepting -1 OR 0 makes the assertion robust to future shape changes (e.g., emittingCOMMENT
MEDIUM…ava/org/opensearch/be/datafusion/SortReverseQtfIT.java346 * over the seeded fixture. Mirrors {@link #categoryFor(long)} so the test is robust toCOMMENT
MEDIUM…rch/analytics/resilience/ReduceEarlyTerminationIT.java239 // check below is the robust, routing-independent signal.)COMMENT
Cross-File Repetition6 hits · 30 pts
SeverityFileLineSnippetContext
HIGH…lugin/wlm/action/UpdateWorkloadGroupResponseTests.java0{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfoSTRING
HIGH…lugin/wlm/action/CreateWorkloadGroupResponseTests.java0{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfoSTRING
HIGH…h/plugin/wlm/action/GetWorkloadGroupResponseTests.java0{ "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfoSTRING
HIGH…arch/analytics/planner/SortPushdownPlanShapeTests.java0opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[mocSTRING
HIGH…g/opensearch/analytics/planner/SortPlanShapeTests.java0opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[mocSTRING
HIGH…a/org/opensearch/analytics/planner/PlanShapeTests.java0opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[mocSTRING
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…opensearch/indices/recovery/RecoverySourceHandler.java617 // 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
SeverityFileLineSnippetContext
MEDIUM…arameterizedStaticSettingsOpenSearchIntegTestCase.java24 * {@link #hasSameParametersAs(ParameterizedOpenSearchIntegTestCase)} is being used by the test scaffolding to detect whCOMMENT
MEDIUM…nsearch/test/ParameterizedOpenSearchIntegTestCase.java25 * {@link #hasSameParametersAs(ParameterizedOpenSearchIntegTestCase)} is being used by the test scaffolding to detectCOMMENT
Slop Phrases3 hits · 6 pts
SeverityFileLineSnippetContext
LOWdistribution/src/config/opensearch.yml4# Before you set out to tweak and tune the configuration, make sure youCOMMENT
LOW…/search/fetch/subphase/highlight/HighlightBuilder.java542 * the named field. If you provide a list of fields here then don't forget to include name asCOMMENT
MEDIUM…earch/gradle/precommit/ValidateJsonNoKeywordsTask.java68 * The keywords are defined in a JSON file, although it's worth noting that what is and isn't aCOMMENT
TODO Padding4 hits · 6 pts
SeverityFileLineSnippetContext
LOW…arch/dsl/aggregation/bucket/TermsBucketTranslator.java51 // TODO: implement response conversionCOMMENT
LOW…h/dsl/aggregation/metric/AbstractMetricTranslator.java70 // TODO: implement response conversion per metric type (InternalAvg, InternalSum, etc.)COMMENT
LOW…arch/analytics/planner/dag/PickRandomNodeSelector.java35 // TODO: implement when shuffle aggregates/joins are added.COMMENT
LOW…lytics/planner/rel/OpenSearchDistributionTraitDef.java172 // TODO: implement HASH/RANGE shuffle exchange when joins and shuffle aggregates are added.COMMENT
Redundant / Tautological Comments1 hit · 2 pts
SeverityFileLineSnippetContext
LOWdistribution/src/config/opensearch.yml128# Set this to a directory on a dedicated filesystem to enable spill — the directoryCOMMENT