Apache Pinot - A realtime distributed OLAP datastore
This report summarizes scanner evidence for apache/pinot, a Java project with 6,149 GitHub stars. SynthScan examined 1,482,756 lines of code across 7109 source files, recording 3037 pattern matches distributed across 21 syntactic categories. The legacy adjusted pattern signal is 4.8 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 2615 finding(s).
Are imports declared and package/API names verified? 334 finding(s).
Are wrappers, guards, and repeated structures necessary? 180 finding(s).
Which changes need focused human review? 3037 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 3037 distinct pattern matches across 21 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| 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 | 805 | org.apache.pinot.spi.exception.QueryErrorCode.TOO_MANY_REQUESTS.getId(), | CODE |
| CRITICAL | …e/pinot/broker/requesthandler/QueryValidationTest.java | 138 | + "\"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 | 1566 | 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⚡ | …/apache/pinot/queries/ArrayAggStarTreeQueriesTest.java | 132 | new org.apache.pinot.spi.config.table.StarTreeAggregationConfig(INT_METRIC, "arrayAgg", null, null, null, | CODE |
| CRITICAL⚡ | …/apache/pinot/queries/ArrayAggStarTreeQueriesTest.java | 134 | new org.apache.pinot.spi.config.table.StarTreeAggregationConfig(LONG_METRIC, "arrayAgg", null, null, null, | CODE |
| CRITICAL⚡ | …/apache/pinot/queries/ArrayAggStarTreeQueriesTest.java | 136 | new org.apache.pinot.spi.config.table.StarTreeAggregationConfig(STRING_METRIC, "arrayAgg", null, null, null, | CODE |
| CRITICAL⚡ | …/apache/pinot/queries/ArrayAggStarTreeQueriesTest.java | 138 | new org.apache.pinot.spi.config.table.StarTreeAggregationConfig(BYTES_METRIC, "arrayAgg", null, null, null, | CODE |
| CRITICAL | …/apache/pinot/queries/ArrayAggStarTreeQueriesTest.java | 307 | set.add(element instanceof byte[] ? new org.apache.pinot.spi.utils.ByteArray((byte[]) element) : element); | 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 | 243 | // @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 | …ver/warmup/PageCacheWarmupServerQueryExecutorTest.java | 127 | com.google.common.util.concurrent.Futures.immediateFuture(new byte[0])); | 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 | 610 | File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(tmpSegmentTarDir, | CODE |
| CRITICAL | …/apache/pinot/server/api/resources/TablesResource.java | 1101 | 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 |
| 262 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 | 241 | // The representable ones (TINYINT/SMALLINT/INTEGER UNSIGNED) are ACCEPTED and reach the converter via real SQL | 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 | @FunctionalInterface | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 261 | /// For example: | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 281 | /// Usually this is the kind of builder used by most builder methods (like [#tableScan(String)]) because hints | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 301 | /// it is in the initial state and can [#newReceiver()] can be called multiple times to create multiple | COMMENT |
| LOW | …apache/pinot/query/planner/logical/StagesTestBase.java | 341 | /// Returns the sender node for this spool. | COMMENT |
| LOW | …/org/apache/pinot/query/routing/WorkerManagerTest.java | 1081 | COMMENT | |
| LOW | …/org/apache/pinot/query/routing/WorkerManagerTest.java | 1101 | @Test | COMMENT |
| LOW | …/org/apache/pinot/query/routing/WorkerManagerTest.java | 1721 | // Classes 1 and 2 dropped, one segment each on each side. | COMMENT |
| LOW | …pache/pinot/calcite/rex/PinotSealedSearchOperator.java | 41 | /// | COMMENT |
| LOW | …in/java/org/apache/pinot/calcite/rex/SearchSealer.java | 61 | /// | COMMENT |
| LOW | …in/java/org/apache/pinot/calcite/rex/SearchSealer.java | 121 | } | COMMENT |
| LOW | …in/java/org/apache/pinot/calcite/rex/SearchSealer.java | 221 | // -------------------------------------------------------------------------- | 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 | 121 | } else { | COMMENT |
| LOW | …lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java | 141 | exchange = PinotLogicalExchange.create(input, RelDistributions.hash(windowGroup.keys.toList()), prePartitioned); | COMMENT |
| LOW | …lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java | 181 | /// The 'ProjectWindowTransposeRule' looks at the columns present in the LogicalProject above the LogicalWindow and | 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`\_\_FINAL | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 101 | /// col1, COUNT(\*) AS cnt FROM myTable GROUP BY col1 ORDER BY cnt DESC LIMIT 10 | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 361 | /// the rest of the plan is an ordinary aggregate. Layout: | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 621 | if (option != null) { | COMMENT |
| LOW | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 101 | return unboxRel(rel) instanceof Aggregate; | COMMENT |
| LOW | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 141 | return funcSqlKind == SqlKind.OTHER_FUNCTION ? function.getOperator().getName() : funcSqlKind.name(); | COMMENT |
| LOW | …te/rel/rules/PinotApproximateAggregateRewriteRule.java | 41 | import org.apache.pinot.query.QueryEnvironment; | 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/PinotConvertletTable.java | 161 | } | 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 | 121 | /// | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 401 | if (plannerContext.isUsePhysicalOptimizer()) { | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 441 | /// Converts a validated SqlNode into a relational expression formed by a [RelRoot] which contains a [RelNode]. | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 561 | /// - In the second phase, it performs predicate pushdown -> projection pushdown -> predicate pushdown. | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 601 | // Pushdown filters again since filter should be pushed down at the lowest level, after project pushdown. | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 781 | /// | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 861 | /// | COMMENT |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 881 | COMMENT | |
| LOW | …main/java/org/apache/pinot/query/QueryEnvironment.java | 901 | } | 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 |
| 2046 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⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 174 | // Step 1: Enable warmup on restart in the table config. This serializes pageCacheWarmupConfig to | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 182 | // Step 2: Store the warmup queries on the controller. | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 186 | // Step 3: Verify the stored queries round-trip through the controller's data dir. | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 190 | // Step 4: Capture the baseline of the host-level warmup-queries meter before the restart. The | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 195 | // Step 5: Restart the server. On startup it runs startWarmupOnRestart(), which finds the resident | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 200 | // Step 6: The warmup should have executed at least the stored queries against the resident | COMMENT |
| LOW | …/integration/tests/PageCacheWarmupIntegrationTest.java | 213 | // Step 7: The server must still serve queries correctly after warming up. | 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 |
| 79 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 | 628 | /// 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⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 174 | // Step 1: Enable warmup on restart in the table config. This serializes pageCacheWarmupConfig to | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 182 | // Step 2: Store the warmup queries on the controller. | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 186 | // Step 3: Verify the stored queries round-trip through the controller's data dir. | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 190 | // Step 4: Capture the baseline of the host-level warmup-queries meter before the restart. The | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 195 | // Step 5: Restart the server. On startup it runs startWarmupOnRestart(), which finds the resident | COMMENT |
| LOW⚡ | …/integration/tests/PageCacheWarmupIntegrationTest.java | 200 | // Step 6: The warmup should have executed at least the stored queries against the resident | COMMENT |
| LOW | …/integration/tests/PageCacheWarmupIntegrationTest.java | 213 | // Step 7: The server must still serve queries correctly after warming up. | 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 |
| 68 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 |
|---|---|---|---|---|
| LOW | …ot/broker/requesthandler/TimeSeriesRequestHandler.java | 88 | public class TimeSeriesRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …ot/broker/requesthandler/BaseBrokerRequestHandler.java | 76 | public abstract class BaseBrokerRequestHandler implements BrokerRequestHandler { | CODE |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 117 | public class MultiStageBrokerRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …questhandler/SingleConnectionBrokerRequestHandler.java | 91 | 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 | 1650 | public static class FakeRealtimeSegmentDataManager extends RealtimeSegmentDataManager implements Closeable { | CODE |
| LOW | …ata/manager/realtime/RealtimeTableDataManagerTest.java | 582 | private static class LifecycleTableDataManager extends RealtimeTableDataManager { | CODE |
| LOW | …ata/manager/realtime/RealtimeTableDataManagerTest.java | 688 | class FakeRealtimeTableDataManager extends RealtimeTableDataManager { | CODE |
| LOW | …ore/data/manager/realtime/ConsumerCoordinatorTest.java | 42 | 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 | 134 | 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 | 37 | public class OfflineTableDataManager extends BaseTableDataManager { | CODE |
| LOW | …/data/manager/offline/ImmutableSegmentDataManager.java | 26 | public class ImmutableSegmentDataManager extends SegmentDataManager { | CODE |
| LOW | …arter/helix/HelixInstanceDataManagerLifecycleTest.java | 367 | private static class TestInstanceDataManager extends HelixInstanceDataManager { | CODE |
| LOW | …not/server/starter/helix/HelixInstanceDataManager.java | 88 | 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⚡ | .github/scripts/pr_flow/test_model.py | 266 | def test_rejects_header_injection_credentials_before_network(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_model.py | 273 | def test_no_usable_patch_does_not_consume_a_model_call(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_model.py | 282 | def test_quota_is_deferred_without_retry_or_reading_error_body(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 107 | def test_valid_graph_is_independent_copy(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 114 | def test_structural_limits_and_unknown_fields(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 132 | def test_ids_edges_and_evidence_are_validated(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 150 | def test_change_colors_need_supporting_line_types(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 160 | def test_markup_urls_and_invisible_controls_are_rejected(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 172 | def test_unsafe_publication_coordinates_rejected(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 184 | def test_invalid_file_metadata_always_raises_safe_model_error(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 198 | def test_free_only_strict_single_request_and_credential_isolation(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 239 | def test_rejects_paid_routers_and_malformed_models_before_network(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 247 | def test_edge_evidence_rules_are_system_instructions_not_pr_claims(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 296 | def test_only_gateway_failures_get_one_retry(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 316 | def test_redirects_and_other_errors_never_retry_or_forward_credentials(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 330 | def test_network_errors_are_sanitized_even_in_tracebacks(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 353 | def test_oversized_request_and_response_are_bounded(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 366 | def test_invalid_response_shapes_and_tool_calls_fail_without_repair_calls(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 388 | def test_error_envelopes_and_bad_json_never_expose_upstream_text(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 401 | def test_usage_is_allowlisted_and_missing_values_are_unknown(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 419 | def test_fixed_colors_legend_evidence_and_pinned_links(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 440 | def test_label_punctuation_cannot_escape_mermaid_quotes(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 452 | def test_caption_and_filenames_are_escaped_with_url_quoted_paths(self): | CODE |
| LOW | .github/scripts/pr_flow/test_model.py | 461 | def test_renamed_files_use_valid_previous_path_for_before_link(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 129 | def test_copying_or_key_rotation_cannot_adopt_a_block(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 135 | def test_malformed_markers_fail_closed(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 141 | def test_author_edits_outside_owned_section_are_preserved(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 148 | def test_current_flow_skips_model_work_but_edit_or_checkbox_invalidates(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 532 | def test_unavailable_edit_history_prevents_write(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 540 | def test_provider_error_preserves_existing_flow(self): | CODE |
| LOW⚡ | .github/scripts/pr_flow/test_main.py | 550 | def test_main_quota_writes_status_and_summary(self): | CODE |
| LOW | .github/scripts/pr_flow/test_main.py | 68 | def test_preserves_author_text_exactly_on_insert_and_replace(self): | CODE |
| LOW | .github/scripts/pr_flow/test_main.py | 80 | def test_only_checkbox_can_change_without_invalidating_signature(self): | CODE |
| LOW | .github/scripts/pr_flow/test_main.py | 89 | def test_crlf_normalized_block_preserves_ownership_and_author_text(self): | CODE |
| 31 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java | 104 | /// 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 | 51 | /// 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 | 145 | /// 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 |
|---|---|---|---|---|
| HIGH | scripts/update-release-binaries.py | 591 | except ET.ParseError: | CODE |
| HIGH | scripts/update-release-binaries.py | 1134 | except (zipfile.BadZipFile, KeyError, OSError): | CODE |
| HIGH | .github/scripts/pr_flow/model.py | 326 | except (OSError, http.client.HTTPException): | 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 | 764 | // 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 |
|---|---|---|---|---|
| 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 | |
| LOW | .github/scripts/pr_flow/test_model.py | 330 | CODE | |
| LOW | .github/scripts/pr_flow/main.py | 280 | CODE | |
| LOW | .github/scripts/pr_flow/test_main.py | 371 | CODE | |
| LOW | .github/scripts/pr_flow/test_main.py | 495 | CODE |
| 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 |
|---|---|---|---|---|
| MEDIUM | …erator/streaming/StreamingDistinctCombineOperator.java | 72 | /// - The distinct guardrails weaken. All three (`maxRowsInDistinct`, `maxRowsWithoutChangeInDistinct`, | COMMENT |
| 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 |