🔎 Open source distributed and RESTful search engine.
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).
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.
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.
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.
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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …ensearch/indices/analysis/AnalysisFactoryTestCase.java | 317 | org.apache.lucene.analysis.TokenizerFactory.availableTokenizers() | CODE |
| CRITICAL | …ensearch/indices/analysis/AnalysisFactoryTestCase.java | 329 | org.apache.lucene.analysis.CharFilterFactory.availableCharFilters() | CODE |
| CRITICAL | …ensearch/indices/analysis/AnalysisFactoryTestCase.java | 341 | 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 | 565 | 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 |
| 587 more matches not shown… | ||||
| 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 | 62 | // ─── Settings ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …va/org/opensearch/arrow/allocator/ArrowBasePlugin.java | 210 | // ─── Instance state ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …va/org/opensearch/arrow/allocator/ArrowBasePlugin.java | 217 | // ─── Plugin lifecycle ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …va/org/opensearch/arrow/allocator/ArrowBasePlugin.java | 292 | // ─── Package-private (visible for tests) ───────────────────────────────────── | COMMENT |
| MEDIUM | …va/org/opensearch/arrow/allocator/ArrowBasePlugin.java | 382 | // ─── Private helpers ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …h/repositories/s3/async/AsyncTransferManagerTests.java | 419 | // ── Helpers ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …row/flight/transport/FlightTransportResponseTests.java | 67 | // ── close() / prefetch-race stream lifecycle ───────────────────────────── | 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 |
| MEDIUM | …e/directory/TieredSubdirectoryAwareDirectoryTests.java | 275 | // ═══════════════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …e/directory/TieredSubdirectoryAwareDirectoryTests.java | 337 | // ═══════════════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …e/directory/TieredSubdirectoryAwareDirectoryTests.java | 339 | // ═══════════════════════════════════════════════════════════════ | COMMENT |
| 1294 more matches not shown… | ||||
| 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 | …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 | …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 | 441 | handleDisableObjectsMapping(parentMappers, newMapper, docMapper, mapping); | 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 | 1161 | if (waitIfOngoing == false) { | COMMENT |
| LOW | …c/main/java/org/opensearch/index/shard/IndexShard.java | 4461 | COMMENT | |
| LOW | libs/core/licenses/lucene-LICENSE.txt | 281 | # Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com> | COMMENT |
| LOW | libs/netty4/licenses/lucene-LICENSE.txt | 281 | # Copyright (c) 2010, Jean-Philippe Barrette-LaPierre, <jpb@rrette.com> | COMMENT |
| LOW | …java/org/opensearch/common/TimeBasedUUIDGenerator.java | 101 | // but not necessarily for lookup speed (by having the leading bytes identify | COMMENT |
| LOW | …in/java/org/opensearch/secure_sm/policy/Tokenizer.java | 21 | * Don't convert words to lowercase | COMMENT |
| LOW | …java/org/opensearch/gradle/pluginzip/PublishTests.java | 141 | // have it evaluated (API call) and then check if there are tasks that the plugin uses to hookup into | COMMENT |
| LOW | …java/org/opensearch/gradle/pluginzip/PublishTests.java | 441 | * It covers the case when user calls the "publishToMavenLocal" task. | COMMENT |
| 440 more matches not shown… | ||||
| 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 |
| 123 more matches not shown… | ||||
| 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 |
| 102 more matches not shown… | ||||
| 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 | 419 | class PrepareForTranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryPrepareForTranslogOperat | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 435 | class FinalizeRecoveryRequestHandler implements TransportRequestHandler<RecoveryFinalizeRecoveryRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 451 | class HandoffPrimaryContextRequestHandler implements TransportRequestHandler<RecoveryHandoffPrimaryContextRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 464 | class TranslogOperationsRequestHandler implements TransportRequestHandler<RecoveryTranslogOperationsRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 550 | class FilesInfoRequestHandler implements TransportRequestHandler<RecoveryFilesInfoRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 573 | class CleanFilesRequestHandler implements TransportRequestHandler<RecoveryCleanFilesRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 594 | class FileChunkTransportRequestHandler implements TransportRequestHandler<FileChunkRequest> { | CODE |
| LOW | …search/indices/recovery/PeerRecoveryTargetService.java | 654 | 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… | ||||
| 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 |
| 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 |
| 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 | 1634 | // 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 | …ackend-datafusion/rust/src/scoped_page_index_reader.rs | 90 | /// the same `resolve_predicate_parquet_columns` the indexed path uses, robust to | 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …lugin/wlm/action/UpdateWorkloadGroupResponseTests.java | 0 | { "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo | STRING |
| HIGH | …lugin/wlm/action/CreateWorkloadGroupResponseTests.java | 0 | { "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo | STRING |
| HIGH | …h/plugin/wlm/action/GetWorkloadGroupResponseTests.java | 0 | { "workload_groups" : [ { "_id" : "h6jvp6kb0zgtzmpomzj4uq==", "name" : "workload_group_three", "resiliency_mode" : "enfo | STRING |
| HIGH | …arch/analytics/planner/SortPushdownPlanShapeTests.java | 0 | opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc | STRING |
| HIGH | …g/opensearch/analytics/planner/SortPlanShapeTests.java | 0 | opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc | STRING |
| HIGH | …a/org/opensearch/analytics/planner/PlanShapeTests.java | 0 | opensearchsort(sort0=[$0], dir0=[asc], viablebackends=[[mock-parquet]]) opensearchunion(all=[true], viablebackends=[[moc | STRING |
| 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 |
| 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 |
| 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …arch/dsl/aggregation/bucket/TermsBucketTranslator.java | 51 | // TODO: implement response conversion | COMMENT |
| LOW | …h/dsl/aggregation/metric/AbstractMetricTranslator.java | 70 | // TODO: implement response conversion per metric type (InternalAvg, InternalSum, etc.) | COMMENT |
| LOW | …arch/analytics/planner/dag/PickRandomNodeSelector.java | 35 | // TODO: implement when shuffle aggregates/joins are added. | COMMENT |
| LOW | …lytics/planner/rel/OpenSearchDistributionTraitDef.java | 172 | // TODO: implement HASH/RANGE shuffle exchange when joins and shuffle aggregates are added. | COMMENT |
| 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 |