Apache Pinot - A realtime distributed OLAP datastore
This report presents the forensic synthetic code analysis of apache/pinot, a Java project with 6,128 GitHub stars. SynthScan v2.0 examined 1,422,664 lines of code across 6952 source files, recording 2805 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 4.7 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 2805 distinct pattern matches across 19 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 | …pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java | 109 | com.google.common.collect.ImmutableList.copyOf(origAboveFilters), joinType); | CODE |
| CRITICAL | …sthandler/BaseSingleStageBrokerRequestHandlerTest.java | 744 | org.apache.pinot.spi.exception.QueryErrorCode.TOO_MANY_REQUESTS.getId(), | CODE |
| CRITICAL | …e/pinot/broker/requesthandler/QueryValidationTest.java | 137 | + "\"REALTIME\"] as String[]; org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2') FROM foo"; | CODE |
| CRITICAL⚡ | …adaptiveserverselector/AdaptiveServerSelectorTest.java | 76 | CommonConstants.Broker.AdaptiveServerSelector.Type.NO_OP.name()); | CODE |
| CRITICAL⚡ | …adaptiveserverselector/AdaptiveServerSelectorTest.java | 86 | CommonConstants.Broker.AdaptiveServerSelector.Type.NUM_INFLIGHT_REQ.name()); | CODE |
| CRITICAL⚡ | …adaptiveserverselector/AdaptiveServerSelectorTest.java | 94 | CommonConstants.Broker.AdaptiveServerSelector.Type.LATENCY.name()); | CODE |
| CRITICAL⚡ | …adaptiveserverselector/AdaptiveServerSelectorTest.java | 102 | CommonConstants.Broker.AdaptiveServerSelector.Type.HYBRID.name()); | CODE |
| CRITICAL | …pinot/core/accounting/QueryResourceAggregatorTest.java | 55 | long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize(); | CODE |
| CRITICAL | …pinot/core/accounting/QueryResourceAggregatorTest.java | 66 | long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize(); | CODE |
| CRITICAL | …pinot/core/accounting/QueryResourceAggregatorTest.java | 189 | long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize(); | CODE |
| CRITICAL | …che/pinot/core/util/SegmentProcessorAvroUtilsTest.java | 113 | org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL | …che/pinot/core/util/SegmentProcessorAvroUtilsTest.java | 303 | org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL | …che/pinot/core/util/SegmentProcessorAvroUtilsTest.java | 325 | org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL | …che/pinot/core/util/SegmentProcessorAvroUtilsTest.java | 348 | return new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL | …killing/strategy/ScanEntriesThresholdStrategyTest.java | 218 | org.apache.pinot.spi.env.PinotConfiguration pinotConfig = new org.apache.pinot.spi.env.PinotConfiguration(props); | CODE |
| CRITICAL | …killing/strategy/ScanEntriesThresholdStrategyTest.java | 220 | new org.apache.pinot.core.accounting.QueryMonitorConfig(pinotConfig, 1_000_000_000L); | CODE |
| CRITICAL | …killing/strategy/ScanEntriesThresholdStrategyTest.java | 233 | org.apache.pinot.spi.env.PinotConfiguration pinotConfig = new org.apache.pinot.spi.env.PinotConfiguration(props); | CODE |
| CRITICAL | …killing/strategy/ScanEntriesThresholdStrategyTest.java | 235 | new org.apache.pinot.core.accounting.QueryMonitorConfig(pinotConfig, 1_000_000_000L); | CODE |
| CRITICAL | …ot/core/data/function/GroovyFunctionEvaluatorTest.java | 81 | + "org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2})", | CODE |
| CRITICAL | …ot/core/data/function/GroovyFunctionEvaluatorTest.java | 194 | "Groovy({org.apache.commons.codec.digest.DigestUtils.sha256Hex(ssn)}, ssn)", Lists.newArrayList("ssn"), | CODE |
| CRITICAL | …ta/manager/BaseTableDataManagerAcquireSegmentTest.java | 102 | org.apache.commons.io.FileUtils.deleteQuietly(_tmpDir); | CODE |
| CRITICAL | …a/manager/realtime/RealtimeSegmentDataManagerTest.java | 1267 | new org.apache.pinot.spi.config.table.CompletionConfig("DOWNLOAD")); | CODE |
| CRITICAL | …r/filter/predicate/PredicateEvaluatorProviderTest.java | 190 | new org.apache.pinot.common.request.context.predicate.NotEqPredicate(ExpressionContext.forIdentifier("col"), | CODE |
| CRITICAL | …r/filter/predicate/PredicateEvaluatorProviderTest.java | 218 | FieldSpec fieldSpec = new org.apache.pinot.spi.data.DimensionFieldSpec(columnName, dataType, true); | CODE |
| CRITICAL | …ot/queries/JsonUnnestIngestionFromAvroQueriesTest.java | 79 | private static final org.apache.pinot.spi.data.Schema SCHEMA = new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL | …he/pinot/queries/JsonIngestionFromAvroQueriesTest.java | 82 | private static final org.apache.pinot.spi.data.Schema SCHEMA = new org.apache.pinot.spi.data.Schema.SchemaBuilder() | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 86 | return io.netty.util.internal.ReflectionUtil.trySetAccessible(CONSTRUCTOR, true) == null; | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 91 | return io.netty.util.internal.PlatformDependent.usedDirectMemory(); | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 96 | return io.netty.util.internal.PlatformDependent.maxDirectMemory(); | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 113 | return io.grpc.netty.shaded.io.netty.util.internal.ReflectionUtil.trySetAccessible(CONSTRUCTOR, true) == null; | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 118 | return io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.usedDirectMemory(); | CODE |
| CRITICAL⚡ | …ava/org/apache/pinot/core/transport/NettyInstance.java | 123 | return io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.maxDirectMemory(); | CODE |
| CRITICAL | …ava/org/apache/pinot/core/util/ListenerConfigUtil.java | 240 | // @see org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory.createHttpServer(java.net.URI, org | COMMENT |
| CRITICAL | …unction/DistinctCountCPCSketchAggregationFunction.java | 862 | return org.apache.datasketches.common.Util.exactLog2OfInt(_nominalEntries); | CODE |
| CRITICAL | …ier/src/main/java/org/apache/pinot/compat/TableOp.java | 163 | org.apache.pinot.spi.data.Schema.fromString(schemaJson); | CODE |
| CRITICAL | …pache/pinot/sql/ddl/compile/DdlCompileContextTest.java | 48 | org.assertj.core.api.Assertions.assertThat(ex.getMessage()) | CODE |
| CRITICAL | …ot/connector/spark/v3/datasource/PinotDataWriter.scala | 199 | val fs = org.apache.hadoop.fs.FileSystem.get(new java.net.URI(savePath), new org.apache.hadoop.conf.Configuration()) | CODE |
| CRITICAL | …ot/connector/spark/v3/datasource/PinotDataWriter.scala | 229 | case org.apache.spark.sql.types.ArrayType(elementType, _) => | CODE |
| CRITICAL | …rg/apache/pinot/connector/spark/common/HttpUtils.scala | 98 | val connectionManager = org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManagerBuilder.create() | CODE |
| CRITICAL | …r/spark/common/reader/PinotGrpcServerDataFetcher.scala | 44 | val (hostStr, portStr) = org.apache.pinot.connector.spark.common.NetUtils.parseHostPort(proxyUri, readOptions.useH | CODE |
| CRITICAL | …ector/spark/common/reader/PinotServerDataFetcher.scala | 170 | val (proxyHost, proxyPort) = org.apache.pinot.connector.spark.common.NetUtils.parseHostPort(proxyUri, dataSourceOp | CODE |
| CRITICAL | …not/server/predownload/PredownloadSegmentInfoTest.java | 112 | org.apache.commons.io.FileUtils.writeByteArrayToFile(new File(segDir, "columns.psf"), new byte[]{1, 2, 3}); | CODE |
| CRITICAL | …not/server/predownload/PredownloadSegmentInfoTest.java | 127 | org.apache.commons.io.FileUtils.deleteQuietly(tempDir); | CODE |
| CRITICAL | …pinot/server/predownload/PredownloadTableInfoTest.java | 92 | org.apache.commons.io.FileUtils.writeByteArrayToFile(new File(segDir, "columns.psf"), new byte[]{1, 2, 3}); | CODE |
| CRITICAL | …pinot/server/predownload/PredownloadTableInfoTest.java | 107 | org.apache.commons.io.FileUtils.deleteQuietly(tempDir); | CODE |
| CRITICAL | …/server/api/ServerAdminApiAccessControlFilterTest.java | 135 | .thenThrow(new NotAuthorizedException(javax.ws.rs.core.Response.status(Status.UNAUTHORIZED).build())); | CODE |
| CRITICAL | …ache/pinot/server/predownload/PredownloadZKClient.java | 169 | if (!CommonConstants.Helix.StateModel.SegmentStateModel.ONLINE.equals(entry.getValue())) { | CODE |
| CRITICAL | …/apache/pinot/server/api/resources/TablesResource.java | 598 | File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(tmpSegmentTarDir, | CODE |
| CRITICAL | …/apache/pinot/server/api/resources/TablesResource.java | 1068 | File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(segmentTarUploadDir, | CODE |
| CRITICAL | …s/src/test/resources/udf-test-results/uuidtobytes.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …on-tests/src/test/resources/udf-test-results/acos.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …src/test/resources/udf-test-results/all-functions.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …ests/src/test/resources/udf-test-results/arraymax.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …ion-tests/src/test/resources/udf-test-results/not.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …test/resources/udf-test-results/arrayelementatint.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …tests/src/test/resources/udf-test-results/adler32.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …tests/src/test/resources/udf-test-results/isfalse.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …tion-tests/src/test/resources/udf-test-results/or.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …-tests/src/test/resources/udf-test-results/isuuid.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …s/src/test/resources/udf-test-results/uuidversion.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| 254 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | .codecov.yml | 1 | # | COMMENT |
| LOW | …/java/org/apache/pinot/query/QueryCompilationTest.java | 201 | // CALCITE-7379: decorrelating a scalar correlated sub-query feeding an aggregate changes the nullability of the | COMMENT |
| LOW | …inot/query/planner/physical/v2/LookupJoinPlanTest.java | 181 | // PhysicalExchange(SINGLETON_EXCHANGE) ← root | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 61 | COMMENT | |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 241 | Preconditions.checkState(old == null, "Mailbox already exists for stageId: %s", stageId); | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 261 | /// tableScan("T1") | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 301 | COMMENT | |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 321 | /// readT1.newReceiver(), // here a new receiver is created | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 361 | /// Returns whether the spool is sealed or not. | COMMENT |
| LOW | …rg/apache/pinot/calcite/rel/hint/PinotHintOptions.java | 81 | @Nullable | COMMENT |
| LOW | …rg/apache/pinot/calcite/rel/hint/PinotHintOptions.java | 101 | /// rows which are equal across all projected columns are guaranteed to land on the same worker. Forcing it when | COMMENT |
| LOW | …che/pinot/calcite/rel/hint/PinotHintStrategyTable.java | 101 | /// Check if a hint-able [org.apache.calcite.rel.RelNode] contains an option key for a specific hint name of | COMMENT |
| LOW | …he/pinot/calcite/rel/logical/PinotRelExchangeType.java | 21 | /// Type of exchange. | COMMENT |
| LOW | …lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java | 101 | COMMENT | |
| LOW | …lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java | 161 | /// | COMMENT |
| LOW | …t/calcite/rel/rules/PinotRelDistributionTraitRule.java | 161 | RelDistribution inputRelDistribution = inputs.get(0).getTraitSet().getDistribution(); | COMMENT |
| LOW | …pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java | 41 | COMMENT | |
| LOW | …pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java | 61 | @Override | COMMENT |
| LOW | …che/pinot/calcite/rel/rules/GroupingSetsPlanUtils.java | 41 | import org.apache.calcite.util.ImmutableBitSet; | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 81 | /// - `aggName`\_\_LEAF \[+ `aggName`\_\_INTERMEDIATE\] + `aggName`\_\_FINAL | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 341 | // Create a LEAF aggregate. | COMMENT |
| LOW | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 101 | /// segment-local info (indexing and others) to speed up the execution. | COMMENT |
| LOW | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 141 | /// relocated -- pushed below a join, duplicated onto another input, and so on. | COMMENT |
| LOW | …apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java | 141 | UnionToDistinctRule.Config.DEFAULT | COMMENT |
| LOW | …/calcite/rel/rules/PinotProjectAggregateMergeRule.java | 41 | /// [org.apache.pinot.calcite.rel.hint.PinotHintStrategyTable]). The aggregate's hints are therefore dropped | COMMENT |
| LOW | …calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java | 41 | /// | | | COMMENT |
| LOW | …calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java | 61 | /// | COMMENT |
| LOW | …calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java | 81 | /// | COMMENT |
| LOW | …apache/pinot/calcite/sql2rel/PinotRelDecorrelator.java | 41 | /// | COMMENT |
| LOW | …g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java | 61 | COMMENT | |
| LOW | …g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java | 301 | COMMENT | |
| LOW | …g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java | 521 | /// AVG into SUM / COUNT, since Pinot has native window AVG support via | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 101 | import org.apache.pinot.sql.parsers.CalciteSqlParser; | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 401 | _envConfig.getTableCache()).unwrap(); | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 541 | /// It performs several phases of rule application over the parsed decorrelated trimmed plan: | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 581 | hepProgramBuilder.addRuleCollection(projectPushdownRules); | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 761 | COMMENT | |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 801 | /// Whether to use physical optimizer by default. | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 821 | } | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 841 | default boolean defaultUseBrokerPruning() { | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 901 | /// This is used whenever the query needs to be executed, but can be null when the QueryEnvironment will be used | COMMENT |
| LOW | …/query/planner/explain/PhysicalExplainPlanVisitor.java | 81 | /// as the node that is executing this sub-tree. This is helpful for debugging what is happening | COMMENT |
| LOW | …apache/pinot/query/planner/explain/PlanNodeMerger.java | 61 | /// | COMMENT |
| LOW | …/query/planner/explain/AskingServerStageExplainer.java | 141 | /// and [PlanNodeMerger]. This basically means that plans from different segments should be grouped by a | COMMENT |
| LOW | …anner/explain/MultiStageExplainAskingServersUtils.java | 41 | /// Some of the new nodes may be [org.apache.pinot.core.plan.PinotExplainedRelNode], so once this method is | COMMENT |
| LOW | …pinot/query/planner/explain/ExplainNodeSimplifier.java | 41 | import org.apache.pinot.query.planner.plannode.TableScanNode; | COMMENT |
| LOW | …t/query/planner/physical/DispatchablePlanMetadata.java | 181 | /// are not in partition-class space. | COMMENT |
| LOW | …pinot/query/planner/physical/PinotDispatchPlanner.java | 121 | /// When only _some_ leaf stages are empty (an empty or fully-pruned table combined with a non-empty table in the | COMMENT |
| LOW | …t/query/planner/physical/MailboxAssignmentVisitor.java | 101 | // TODO: Add support for more exchange types | COMMENT |
| LOW | …nner/physical/v2/PlanFragmentAndMailboxAssignment.java | 41 | import org.apache.pinot.query.planner.plannode.PlanNode; | COMMENT |
| LOW | …/pinot/query/planner/physical/v2/ExchangeStrategy.java | 21 | import java.util.List; | COMMENT |
| LOW | …/pinot/query/planner/physical/v2/ExchangeStrategy.java | 41 | SUB_PARTITIONING_HASH_EXCHANGE(true), | COMMENT |
| LOW | …query/planner/physical/v2/PRelToPlanNodeConverter.java | 361 | COMMENT | |
| LOW | …pinot/query/planner/physical/v2/TableScanMetadata.java | 21 | import java.util.List; | COMMENT |
| LOW | …pinot/query/planner/physical/v2/TableScanMetadata.java | 41 | /// ... | COMMENT |
| LOW | …/query/planner/physical/v2/nodes/PhysicalExchange.java | 41 | /// Exchange is a special plan node because it is often used to change the number of streams. Since we track | COMMENT |
| LOW | …hysical/v2/opt/rules/WorkerExchangeAssignmentRule.java | 61 | /// This rule also adds Exchanges when either of the following conditions are met: | COMMENT |
| LOW | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 81 | COMMENT | |
| LOW | …uery/planner/physical/v2/opt/rules/LookupJoinRule.java | 41 | /// 1. **Right side**: Exchange converted to [ExchangeStrategy#LOOKUP_LOCAL_EXCHANGE] — a pseudo-exchange | COMMENT |
| 1907 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 63 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 65 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 135 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 137 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 190 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 192 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 298 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 300 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 351 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 353 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 422 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 424 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 462 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 464 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 606 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …iew/metadata/MaterializedViewPartitionManagerTest.java | 608 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …erializedview/analysis/timeexpr/TimeExprValidator.java | 109 | // ─── Policy layer ────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …erializedview/analysis/timeexpr/TimeExprValidator.java | 200 | // ─── Structural layer: ADT + parser ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ew/consistency/MaterializedViewConsistencyManager.java | 407 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ew/consistency/MaterializedViewConsistencyManager.java | 409 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 149 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 151 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 465 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 467 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 521 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …zedview/metadata/MaterializedViewPartitionManager.java | 523 | // ───────────────────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ry/aggregation/function/funnel/DictIdsWrapperTest.java | 49 | // ── Single-key constructor ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ry/aggregation/function/funnel/DictIdsWrapperTest.java | 58 | // ── HashMap fallback path ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ry/aggregation/function/funnel/DictIdsWrapperTest.java | 112 | // ── Stride path reverseCompositeId ────────────────────────────────────── | COMMENT |
| MEDIUM | …pinot/server/predownload/PredownloadSchedulerTest.java | 442 | // ── Peer download tests ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …gration/tests/StreamStatsReportingIntegrationTest.java | 137 | // ─── helpers ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …gration/tests/StreamStatsReportingIntegrationTest.java | 167 | // ─── tests ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …gration/tests/StreamStatsReportingIntegrationTest.java | 437 | // ─── private helpers ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 194 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 196 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 235 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 237 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 256 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 258 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 339 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 341 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 476 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 478 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 535 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 537 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 636 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 638 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 713 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 715 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 830 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 832 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 1066 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | scripts/update-release-binaries.py | 1068 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 82 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 84 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 122 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 124 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 1261 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | scripts/update-release-binaries.py | 1263 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …tHelixResourceManagerMaterializedViewBackfillTest.java | 87 | // ── backfill ──────────────────────────────────────────────────────────────────────────── | COMMENT |
| 23 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 579 | // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProvider | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 587 | // Step 2: Build broker requests for route calculation | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 601 | // Step 3: Calculate routes | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 605 | // Step 4: Build worker assignment from LogicalTableRouteInfo | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 412 | // Step 1: Build OFFLINE table first - should not have TimeBoundaryManager | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 420 | // Step 2: Build REALTIME table - should add TimeBoundaryManager to existing offline table | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 208 | // Step 1: SQL syntax errors | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 414 | // Step 2: Source table validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 664 | // Step 3: MV schema column validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 747 | // Step 4: Task config parameter validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 1018 | // Step 6: MV time-column alignment (segmentsConfig.timeColumnName) | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 1159 | // Step 7: MV time column TIMESTAMP-only contract (TimeExprValidator) | COMMENT |
| LOW | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 86 | /// Step 1: shape gate | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 98 | /// Step 2: GROUP BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 104 | /// Step 3: projection subsumption | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 110 | /// Step 4: WHERE matching + residual extraction (shared logic) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 145 | /// Step 5: residual validation (subclass-specific) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 151 | /// Step 6: ORDER BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 157 | /// Step 7: HAVING | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 163 | /// Step 8: build result | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 140 | // Step 2: source table existence and time-column checks | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 146 | // Step 3: MV schema column completeness (including dateTime columns) | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 149 | // Step 5: extract and validate time column transformation mappings. | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 156 | // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-produced | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 163 | // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV time | COMMENT |
| LOW | …aterializedview/analysis/MaterializedViewAnalyzer.java | 111 | // Step 1: SQL syntax and Pinot semantic validation | COMMENT |
| LOW | …lizedview/scheduler/MaterializedViewTaskScheduler.java | 342 | /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task. | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 131 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 214 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 250 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 292 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 381 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 417 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …not/core/query/executor/ServerQueryExecutorV1Impl.java | 332 | // NOTE: This method might change indexSegments. Do not use it after calling this method. | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 231 | // Step 1: Copy the file or directory into the temporary file | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 247 | // Step 2: Rename the temporary file to the destination file | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 643 | /// Step 1: Verify MV is currently hit (precondition; SLO disabled). | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 649 | /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is a | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 530 | /// Step 1: baseline — split query before the simulated overlap. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 543 | /// Step 2: simulate endSegmentReplace without postProcess — upload MV segments | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 585 | /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filter | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 672 | /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate). | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 687 | /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 702 | /// Step 5: Query again — the MV should be hit again. | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 195 | # Step 1: Parse assembly descriptor for shipped modules | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 236 | # Step 2: Get Maven artifact IDs for modules | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 257 | # Step 3: Run mvn dependency:list | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 340 | # Step 4: Parse current LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 477 | # Step 5: Compute diff | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 536 | # Step 6: Detect licenses for deps (new and version-bumped) | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 714 | # Step 7: Generate report | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 831 | # Step 8: Generate updated LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1067 | # Step 9: Generate NOTICE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1380 | # Step 4: Parse current LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1389 | # Step 5: Compute diff | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1392 | # Step 6: Detect licenses for new deps | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1424 | # Step 7: Print report | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1428 | # Step 8: Generate updated file | COMMENT |
| LOW | scripts/update-release-binaries.py | 1353 | # Step 1: Parse assembly to find shipped modules | COMMENT |
| LOW | …not/segment/spi/index/metadata/ColumnMetadataImpl.java | 577 | // NOTE: This method is only meant to retain compatibility of serialization for endpoint: | COMMENT |
| 72 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …t/query/planner/physical/v2/PRelNodeTreeValidator.java | 50 | // If joins are disabled in lite mode, we need to check if the plan contains joins | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 579 | // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProvider | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 587 | // Step 2: Build broker requests for route calculation | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 601 | // Step 3: Calculate routes | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 605 | // Step 4: Build worker assignment from LogicalTableRouteInfo | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 412 | // Step 1: Build OFFLINE table first - should not have TimeBoundaryManager | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 420 | // Step 2: Build REALTIME table - should add TimeBoundaryManager to existing offline table | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 208 | // Step 1: SQL syntax errors | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 414 | // Step 2: Source table validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 664 | // Step 3: MV schema column validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 747 | // Step 4: Task config parameter validation | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 1018 | // Step 6: MV time-column alignment (segmentsConfig.timeColumnName) | COMMENT |
| LOW | …ializedview/analysis/MaterializedViewAnalyzerTest.java | 1159 | // Step 7: MV time column TIMESTAMP-only contract (TimeExprValidator) | COMMENT |
| LOW | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 86 | /// Step 1: shape gate | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 98 | /// Step 2: GROUP BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 104 | /// Step 3: projection subsumption | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 110 | /// Step 4: WHERE matching + residual extraction (shared logic) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 145 | /// Step 5: residual validation (subclass-specific) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 151 | /// Step 6: ORDER BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 157 | /// Step 7: HAVING | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 163 | /// Step 8: build result | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 140 | // Step 2: source table existence and time-column checks | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 146 | // Step 3: MV schema column completeness (including dateTime columns) | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 149 | // Step 5: extract and validate time column transformation mappings. | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 156 | // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-produced | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 163 | // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV time | COMMENT |
| LOW | …aterializedview/analysis/MaterializedViewAnalyzer.java | 111 | // Step 1: SQL syntax and Pinot semantic validation | COMMENT |
| LOW | …lizedview/scheduler/MaterializedViewTaskScheduler.java | 342 | /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task. | COMMENT |
| LOW | …/apache/pinot/query/runtime/operator/LeafOperator.java | 618 | /// For selection, we need to check if the columns are in order. If not, we need to re-arrange the columns. | COMMENT |
| LOW | …ction/funnel/window/FunnelBaseAggregationFunction.java | 304 | // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max duration | COMMENT |
| LOW | …indow/FunnelEventsFunctionEvalAggregationFunction.java | 452 | // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max duration | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 131 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 214 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 250 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 292 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 381 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 417 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 231 | // Step 1: Copy the file or directory into the temporary file | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 247 | // Step 2: Rename the temporary file to the destination file | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 643 | /// Step 1: Verify MV is currently hit (precondition; SLO disabled). | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 649 | /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is a | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 530 | /// Step 1: baseline — split query before the simulated overlap. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 543 | /// Step 2: simulate endSegmentReplace without postProcess — upload MV segments | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 585 | /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filter | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 672 | /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate). | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 687 | /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 702 | /// Step 5: Query again — the MV should be hit again. | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 195 | # Step 1: Parse assembly descriptor for shipped modules | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 236 | # Step 2: Get Maven artifact IDs for modules | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 257 | # Step 3: Run mvn dependency:list | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 340 | # Step 4: Parse current LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 477 | # Step 5: Compute diff | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 536 | # Step 6: Detect licenses for deps (new and version-bumped) | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 714 | # Step 7: Generate report | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 831 | # Step 8: Generate updated LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1067 | # Step 9: Generate NOTICE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1380 | # Step 4: Parse current LICENSE-binary | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1389 | # Step 5: Compute diff | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1392 | # Step 6: Detect licenses for new deps | COMMENT |
| LOW⚡ | scripts/update-release-binaries.py | 1424 | # Step 7: Print report | COMMENT |
| 61 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/examples/docker/ingestion-job-specs/airlineStats.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …/examples/docker/ingestion-job-specs/airlineStats.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …examples/docker/ingestion-job-specs/baseballStats.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …examples/docker/ingestion-job-specs/baseballStats.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …apache/pinot/core/function/scalar/SketchFunctions.java | 58 | /// Example usage: | COMMENT |
| LOW | …pi/src/test/resources/ingestion_job_spec_template.yaml | 35 | # Sample usage: | COMMENT |
| LOW | …i/src/main/java/org/apache/pinot/tsdb/spi/AggInfo.java | 43 | /// Example usage: | COMMENT |
| LOW | …ources/examples/batch/testUnnest/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ources/examples/batch/testUnnest/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/githubEvents/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/githubEvents/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …examples/batch/githubEvents/sparkIngestionJobSpec.yaml | 49 | # Sample usage: | COMMENT |
| LOW | …examples/batch/githubEvents/sparkIngestionJobSpec.yaml | 55 | # Sample usage: | COMMENT |
| LOW | …sources/examples/batch/ssb/dates/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …sources/examples/batch/ssb/dates/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/ssb/supplier/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/ssb/supplier/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …esources/examples/batch/ssb/part/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …esources/examples/batch/ssb/part/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/ssb/customer/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/ssb/customer/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/ssb/lineorder/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/ssb/lineorder/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …s/examples/batch/starbucksStores/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …s/examples/batch/starbucksStores/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …es/batch/githubComplexTypeEvents/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …es/batch/githubComplexTypeEvents/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …mples/batch/lookup/userGroupsDim/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …mples/batch/lookup/userGroupsDim/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …examples/batch/clickstreamFunnel/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …examples/batch/clickstreamFunnel/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/lineitem/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/lineitem/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/partsupp/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/partsupp/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/nation/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/nation/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/region/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/region/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/supplier/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/supplier/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …sources/examples/batch/tpch/part/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …sources/examples/batch/tpch/part/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/orders/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …urces/examples/batch/tpch/orders/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/customer/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/tpch/customer/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …xamples/batch/airlineStats/hadoopIngestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …xamples/batch/airlineStats/hadoopIngestionJobSpec.yaml | 59 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/airlineStats/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …rces/examples/batch/airlineStats/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …examples/batch/airlineStats/sparkIngestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …examples/batch/airlineStats/sparkIngestionJobSpec.yaml | 59 | # Sample usage: | COMMENT |
| LOW | …s/examples/batch/fineFoodReviews/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| LOW | …s/examples/batch/fineFoodReviews/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …/resources/examples/batch/sorted/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …/resources/examples/batch/sorted/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …examples/batch/clientSalaryNulls/ingestionJobSpec.yaml | 47 | # Sample usage: | COMMENT |
| LOW | …examples/batch/clientSalaryNulls/ingestionJobSpec.yaml | 53 | # Sample usage: | COMMENT |
| LOW | …ces/examples/batch/baseballStats/ingestionJobSpec.yaml | 48 | # Sample usage: | COMMENT |
| 17 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ration-tests/src/test/resources/ssb/ssb_query_set.yaml | 20 | # This function defines the test set of SSB queries | COMMENT |
| MEDIUM | …s/src/test/resources/udf-test-results/uuidtobytes.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …on-tests/src/test/resources/udf-test-results/acos.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …src/test/resources/udf-test-results/all-functions.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …ests/src/test/resources/udf-test-results/arraymax.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …ion-tests/src/test/resources/udf-test-results/not.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …test/resources/udf-test-results/arrayelementatint.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …tests/src/test/resources/udf-test-results/adler32.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …tests/src/test/resources/udf-test-results/isfalse.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …tion-tests/src/test/resources/udf-test-results/or.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …-tests/src/test/resources/udf-test-results/isuuid.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …s/src/test/resources/udf-test-results/uuidversion.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …on-tests/src/test/resources/udf-test-results/plus.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …/src/test/resources/udf-test-results/uuidtostring.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …ts/src/test/resources/udf-test-results/todatetime.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …ion-tests/src/test/resources/udf-test-results/and.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …-tests/src/test/resources/udf-test-results/touuid.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …-tests/src/test/resources/udf-test-results/uuidv4.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …on-tests/src/test/resources/udf-test-results/year.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …test/resources/udf-test-results/arrayconcatdouble.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …ion-tests/src/test/resources/udf-test-results/abs.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …n-tests/src/test/resources/udf-test-results/array.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …/src/test/resources/udf-test-results/arrayaverage.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …-tests/src/test/resources/udf-test-results/uuidv7.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …tests/src/test/resources/udf-test-results/degrees.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …src/test/resources/udf-test-results/uuidtimestamp.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …s/src/test/resources/udf-test-results/bytestouuid.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …on-tests/src/test/resources/udf-test-results/mult.yaml | 20 | # This file is auto-generated by the UDF test framework. Do not edit it manually. | COMMENT |
| MEDIUM | …va/org/apache/pinot/integration/tests/udf/UdfTest.java | 381 | + "# This file is auto-generated by the UDF test framework. Do not edit it manually.\n" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 100 | /// utility logic to determine if a JOIN can be pushed down to the leaf-stage execution and leverage the | COMMENT |
| MEDIUM | …calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java | 82 | /// - new plan can leverage the indexes and fast filtering of the leaf-stage Pinot server processing logic. | COMMENT |
| MEDIUM | …g/instanceselector/MultiStageReplicaGroupSelector.java | 52 | /// Instance selector for multi-stage queries which can ensure that Colocated Tables always leverage Colocated Join | COMMENT |
| MEDIUM | …va/org/apache/pinot/query/runtime/blocks/MseBlock.java | 42 | /// Meanwhile, the API force callers to do some castings, but it is a trade-off to have a more robust and maintainable | COMMENT |
| MEDIUM | …e/pinot/core/query/reduce/MergeDataTablesOnlyTest.java | 657 | /// the comparison is robust for unordered group-by / distinct results). | COMMENT |
| MEDIUM | …pache/pinot/core/data/manager/InstanceDataManager.java | 143 | /// uploaded segment file. Servers utilize segment uploader to upload llc segment to segment store. | COMMENT |
| MEDIUM | …/connector/spark/v3/datasource/PinotWriteBuilder.scala | 31 | // TODO: utilize filters | COMMENT |
| MEDIUM | …inot/integration/tests/UpsertTableIntegrationTest.java | 188 | // fashion, but query more times to be more robust) | COMMENT |
| MEDIUM | …inot/integration/tests/UpsertTableIntegrationTest.java | 207 | // fashion, but query more times to be more robust) | COMMENT |
| MEDIUM | …/pinot/integration/tests/BaseDedupIntegrationTest.java | 113 | // fashion, but query more times to be more robust) | COMMENT |
| MEDIUM | …/integration/tests/custom/GroupingSetsQueriesTest.java | 319 | /// expressions) executes on both engines without hitting a column-count cap. Assert only what is robust | COMMENT |
| MEDIUM | …/integration/tests/custom/GroupingSetsQueriesTest.java | 346 | /// is robust to either choice. | COMMENT |
| MEDIUM | …gment/local/segment/index/loader/BaseIndexHandler.java | 42 | /// postUpdateIndicesCleanup() method. For [IndexHandler] classes which do not utilize the forward index or do not | COMMENT |
| MEDIUM | …t/segment/local/io/util/FixedBitIntReaderWriterV2.java | 67 | /// leverage the underlying bulk contiguous API as much as possible to | COMMENT |
| MEDIUM | …segment/local/utils/SegmentOperationsThrottlerSet.java | 36 | /// Code paths that do not need to download or rebuild the index or which don't happen on the server need not utilize | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ot/broker/requesthandler/TimeSeriesRequestHandler.java | 88 | public class TimeSeriesRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …ot/broker/requesthandler/BaseBrokerRequestHandler.java | 79 | public abstract class BaseBrokerRequestHandler implements BrokerRequestHandler { | CODE |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 117 | public class MultiStageBrokerRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …questhandler/SingleConnectionBrokerRequestHandler.java | 69 | public class SingleConnectionBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler { | CODE |
| LOW | …ot/broker/requesthandler/GrpcBrokerRequestHandler.java | 59 | public class GrpcBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler { | CODE |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 147 | public abstract class BaseSingleStageBrokerRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …a/manager/realtime/RealtimeSegmentDataManagerTest.java | 1351 | public static class FakeRealtimeSegmentDataManager extends RealtimeSegmentDataManager implements Closeable { | CODE |
| LOW | …ata/manager/realtime/RealtimeTableDataManagerTest.java | 78 | class FakeRealtimeTableDataManager extends RealtimeTableDataManager { | CODE |
| LOW | …ore/data/manager/realtime/ConsumerCoordinatorTest.java | 41 | private static class FakeRealtimeTableDataManager extends RealtimeTableDataManager { | CODE |
| LOW | …pache/pinot/core/transport/InstanceRequestHandler.java | 68 | public class InstanceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> { | CODE |
| LOW | …che/pinot/core/data/manager/DuoSegmentDataManager.java | 32 | public class DuoSegmentDataManager extends SegmentDataManager { | CODE |
| LOW | …ache/pinot/core/data/manager/BaseTableDataManager.java | 133 | public abstract class BaseTableDataManager implements TableDataManager { | CODE |
| LOW | …re/data/manager/realtime/RealtimeTableDataManager.java | 96 | public class RealtimeTableDataManager extends BaseTableDataManager { | CODE |
| LOW | …/data/manager/realtime/RealtimeSegmentDataManager.java | 129 | public class RealtimeSegmentDataManager extends SegmentDataManager { | CODE |
| LOW | …re/data/manager/offline/DimensionTableDataManager.java | 60 | public class DimensionTableDataManager extends OfflineTableDataManager { | CODE |
| LOW | …core/data/manager/offline/OfflineTableDataManager.java | 38 | public class OfflineTableDataManager extends BaseTableDataManager { | CODE |
| LOW | …/data/manager/offline/ImmutableSegmentDataManager.java | 26 | public class ImmutableSegmentDataManager extends SegmentDataManager { | CODE |
| LOW | …not/server/starter/helix/HelixInstanceDataManager.java | 86 | public class HelixInstanceDataManager implements InstanceDataManager { | CODE |
| LOW | …me/utils/FailureInjectingRealtimeTableDataManager.java | 40 | public class FailureInjectingRealtimeTableDataManager extends RealtimeTableDataManager { | CODE |
| LOW | …/utils/FailureInjectingRealtimeSegmentDataManager.java | 40 | public class FailureInjectingRealtimeSegmentDataManager extends RealtimeSegmentDataManager { | CODE |
| LOW⚡ | scripts/update-release-binaries.py | 640 | def find_orphaned_license_files( | CODE |
| LOW⚡ | scripts/update-release-binaries.py | 834 | def generate_updated_license_binary( | CODE |
| LOW | scripts/update-release-binaries.py | 597 | def check_version_bump_license_changes( | CODE |
| LOW | scripts/update-release-binaries.py | 1093 | def extract_notices_from_jars(deps: Set[Dep], m2_repo: Path) -> List[Tuple[str, str]]: | STRING |
| LOW | …/Homepage/Operations/AddRealTimeIngestionComponent.tsx | 45 | export default function AddRealTimeIngestionComponent({ | CODE |
| LOW | …ents/Homepage/Operations/AddOfflineTenantComponent.tsx | 50 | export default function AddOfflineTenantComponent({ | CODE |
| LOW | …ts/Homepage/Operations/AddRealTimePartionComponent.tsx | 46 | export default function AddRealTimePartionComponent({ | CODE |
| LOW | …not/segment/local/data/manager/SegmentDataManager.java | 29 | public abstract class SegmentDataManager { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ot/core/data/function/GroovyFunctionEvaluatorTest.java | 176 | genericRow5, "John Doe" | CODE |
| LOW | …org/apache/pinot/client/DynamicBrokerSelectorTest.java | 130 | _dynamicBrokerSelectorUnderTest.handleDataChange("dummy-data-path", "dummy-date"); | CODE |
| LOW | …org/apache/pinot/client/DynamicBrokerSelectorTest.java | 140 | _dynamicBrokerSelectorUnderTest.handleDataChange("dummy-data-path", "dummy-date"); | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 207 | props.setProperty("headers.X-Dummy-Header-1", "dummy-value-1"); | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 208 | props.setProperty("headers.X-Dummy-Header-2", "dummy-value-2"); | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 218 | assertEquals(headers.get("X-Dummy-Header-1"), "dummy-value-1", | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 222 | assertEquals(headers.get("X-Dummy-Header-2"), "dummy-value-2", | CODE |
| LOW | …che/pinot/common/function/scalar/UrlFunctionsTest.java | 366 | assertEquals(UrlFunctions.urlNetloc("https://user@example.com/path"), "user@example.com"); | CODE |
| LOW | …ache/pinot/common/audit/AuditIdentityResolverTest.java | 69 | when(_requestContext.getHeaderString("X-User-Email")).thenReturn("user@example.com"); | CODE |
| LOW | …ache/pinot/common/audit/AuditIdentityResolverTest.java | 74 | assertThat(result.getPrincipal()).isEqualTo("user@example.com"); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …che/pinot/core/query/request/context/QueryContext.java | 737 | // TODO: Add validation logic here | COMMENT |
| LOW | …rter/helix/IngestionBasedConsumptionStatusChecker.java | 167 | // TODO: implement a way to have this work correctly for kafka consumers | COMMENT |
| LOW | …in/java/org/apache/pinot/spi/plugin/PluginManager.java | 306 | // TODO: implement the self-declaring META-INF/pinot-realm-exports mechanism. | COMMENT |
| LOW | …t/integration/tests/OfflineClusterIntegrationTest.java | 3311 | // TODO: Add test to delete broker instance. Currently, stopBroker() does not work correctly. | COMMENT |
| LOW | …tion/tests/ControllerPeriodicTasksIntegrationTest.java | 70 | // TODO: Add tests for other ControllerPeriodicTasks (RetentionManager, RealtimeSegmentValidationManager). | COMMENT |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 591 | return 0; //TODO: implement this after the complex is supported | CODE |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 611 | return 0; //TODO: implement this after the complex is supported | CODE |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 625 | //TODO: implement this after the complex is supported | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …core/executor/ThrottleOnCriticalHeapUsageExecutor.java | 493 | /// Also handles config parsing and logging as requested in review. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/src/main/java/org/apache/pinot/client/admin/README.md | 264 | "X-API-Key", "your-api-key", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/update-release-binaries.py | 429 | # Check if this line is a dash-underline (indicating previous line was a header) | COMMENT |
| LOW | scripts/update-release-binaries.py | 906 | # Check if previous non-blank line is a section name | COMMENT |
| LOW | scripts/update-release-binaries.py | 949 | # Check if removed | COMMENT |
| LOW | scripts/update-release-binaries.py | 954 | # Check if version changed | COMMENT |
| LOW | scripts/update-release-binaries.py | 972 | # Check if this could be a section header (next line might be dashes) | COMMENT |
| LOW | scripts/update-release-binaries.py | 1161 | # Check if next line is the ASF URL line | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/update-release-binaries.py | 198 | CODE | |
| LOW | scripts/update-release-binaries.py | 260 | CODE | |
| LOW | scripts/update-release-binaries.py | 349 | CODE | |
| LOW | scripts/update-release-binaries.py | 539 | CODE | |
| LOW | scripts/update-release-binaries.py | 834 | CODE | |
| LOW | scripts/update-release-binaries.py | 1093 | CODE | |
| LOW | scripts/update-release-binaries.py | 1141 | CODE | |
| LOW | scripts/update-release-binaries.py | 1265 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/src/main/resources/scripts/timeseries/run_ts_query.py | 48 | except Exception as e: | CODE |
| MEDIUM | …/src/main/resources/scripts/timeseries/run_ts_query.py | 44 | def read_query_file(path, logger): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …controller/recommender/rules/impl/SegmentSizeRule.java | 50 | /// It's worth noting that since this rule gets executed before other rules, we run into chicken-egg problem. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/update-release-binaries.py | 55 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/update-release-binaries.py | 1186 | CODE |