Apache Pinot - A realtime distributed OLAP datastore
This report presents the forensic synthetic code analysis of apache/pinot, a Java project with 6,106 GitHub stars. SynthScan v2.0 examined 1,369,192 lines of code across 6748 source files, recording 1634 pattern matches distributed across 18 syntactic categories. The overall adjusted score of 3.9 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).
Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.
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 1634 distinct pattern matches across 18 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 | 81 | com.google.common.collect.ImmutableList.copyOf(origAboveFilters), joinType); | CODE |
| CRITICAL | …sthandler/BaseSingleStageBrokerRequestHandlerTest.java | 696 | 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 | …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 | 83 | + "org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2})", | CODE |
| CRITICAL | …ot/core/data/function/GroovyFunctionEvaluatorTest.java | 196 | "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 | 1271 | 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 | 244 | // @see org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory.createHttpServer(java.net.URI, org | COMMENT |
| CRITICAL | …ava/org/apache/pinot/core/common/ObjectSerDeUtils.java | 1176 | return org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes), | CODE |
| CRITICAL | …ava/org/apache/pinot/core/common/ObjectSerDeUtils.java | 1184 | return org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes), | CODE |
| CRITICAL | …ava/org/apache/pinot/core/common/ObjectSerDeUtils.java | 1770 | org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes), | CODE |
| CRITICAL | …unction/DistinctCountCPCSketchAggregationFunction.java | 678 | return org.apache.datasketches.common.Util.exactLog2OfInt(_nominalEntries); | CODE |
| CRITICAL | …ier/src/main/java/org/apache/pinot/compat/TableOp.java | 165 | 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 | …ache/pinot/server/predownload/PredownloadZKClient.java | 175 | if (!CommonConstants.Helix.StateModel.SegmentStateModel.ONLINE.equals(entry.getValue())) { | CODE |
| CRITICAL | …/apache/pinot/server/api/resources/TablesResource.java | 596 | File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(tmpSegmentTarDir, | CODE |
| CRITICAL | …/apache/pinot/server/api/resources/TablesResource.java | 1154 | File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(segmentTarUploadDir, | CODE |
| 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 | …on-tests/src/test/resources/udf-test-results/plus.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …ts/src/test/resources/udf-test-results/todatetime.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/and.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/year.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| CRITICAL | …test/resources/udf-test-results/arrayconcatdouble.yaml | 21 | # Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it. | COMMENT |
| 241 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | .codecov.yml | 1 | # | COMMENT |
| LOW | …inot/query/planner/physical/v2/LookupJoinPlanTest.java | 181 | COMMENT | |
| LOW | …pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java | 121 | } | COMMENT |
| LOW | …te/rel/rules/PinotAggregateExchangeNodeInsertRule.java | 481 | private static boolean isGroupTrimmingEnabled(RelOptRuleCall call, Map<String, String> hintOptions, | COMMENT |
| LOW | …g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java | 301 | OperandTypes.family(List.of(SqlTypeFamily.ARRAY, SqlTypeFamily.ARRAY, SqlTypeFamily.NUMERIC), i -> i == 2)), | COMMENT |
| LOW | …t/query/planner/physical/MailboxAssignmentVisitor.java | 81 | } else { | 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 | …ot/query/planner/logical/PinotLogicalQueryPlanner.java | 81 | // for (Map.Entry<Integer, PlanNode> subPlanEntry : subPlanContext._subPlanIdToRootNodeMap.entrySet()) { | COMMENT |
| LOW | …inot/query/planner/logical/EquivalentStagesFinder.java | 121 | COMMENT | |
| LOW | …org/apache/pinot/query/planner/rules/PinotRuleSet.java | 41 | /// 2. For every [RuleSetCustomizer] (in supplied order), call | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 321 | balancedInstanceSelector.init(_tableConfig, propertyStore, brokerMetrics, null, Clock.systemUTC(), | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 361 | assertTrue(selectionResult.getUnavailableSegments().isEmpty()); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 401 | replicaGroupInstanceSelector.onInstancesChange(enabledInstances, List.of(instance0)); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 501 | expectedReplicaGroupInstanceSelectorResult.put(segment2, instance1); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 541 | // segment4 is a newly added segment with 3 online instances in idealStage and 2 online instances in externalView. | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 641 | selectionResult = replicaGroupInstanceSelector.select(brokerRequest, segments, requestId); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 681 | Map<String, String> externalViewInstanceStateMap2 = new TreeMap<>(); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 901 | // segment3 -> instance0 | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1061 | // Iterate 5 times | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1081 | selectionResult = strictReplicaGroupInstanceSelector.select(brokerRequest, segments, 0); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1141 | balancedInstanceSelector.onAssignmentChange(idealState, externalView, onlineSegments); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1221 | // (Note that for StrictReplicaGroupInstanceSelector, segment1 but it is old so it will mark instance down for | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1241 | assertEquals(selectionResult.getUnavailableSegments(), Arrays.asList(segment0, segment1)); | COMMENT |
| LOW | …ker/routing/instanceselector/InstanceSelectorTest.java | 1261 | assertTrue(selectionResult.getSegmentToInstanceMap().isEmpty()); | COMMENT |
| LOW | …he/pinot/broker/requesthandler/EmptyResponseUtils.java | 161 | } | COMMENT |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 121 | /// Disabled by default, but can be enabled with | COMMENT |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 361 | // If the error code is not recognized, does nothing | COMMENT |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 381 | /// - The error message and part of the stack trace will be sent to the user and the error message will be logged | COMMENT |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 561 | routeProvider = _implicitHybridTableRouteProvider; | COMMENT |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 921 | // - Alias handling | COMMENT |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 1201 | _tableName = tableName; | COMMENT |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 1221 | /// multi-cluster routing map. Without this early-exit, a FULL_REWRITE swap would turn a | COMMENT |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 2641 | /// Processes an MV-split query by issuing two independent scatter-gather requests - one to the | COMMENT |
| LOW | …ker/routing/instanceselector/BaseInstanceSelector.java | 61 | /// | COMMENT |
| LOW | …routing/instanceselector/BalancedInstanceSelector.java | 21 | import java.util.HashMap; | COMMENT |
| LOW | …te/equivalence/AggregationEquivalenceRegistryTest.java | 21 | import org.testng.annotations.Test; | COMMENT |
| LOW | …ializedview/metadata/MaterializedViewMetadataTest.java | 161 | /// znode from a prior failed CREATE doesn't get classified as "different content". | COMMENT |
| LOW | …va/org/apache/pinot/materializedview/package-info.java | 21 | /// are produced by a saved SQL query against one or more base Pinot tables. The MV is | COMMENT |
| LOW | …va/org/apache/pinot/materializedview/package-info.java | 41 | /// and generates `PinotTaskConfig`s. | COMMENT |
| LOW | …va/org/apache/pinot/materializedview/package-info.java | 61 | /// | COMMENT |
| LOW | …lizedview/handler/MaterializedViewSplitDispatcher.java | 41 | /// always-false-filter pruning), builds the MV-side broker request and route, then issues two | COMMENT |
| LOW | …/materializedview/handler/MaterializedViewHandler.java | 21 | import org.apache.helix.store.zk.ZkHelixPropertyStore; | COMMENT |
| LOW | …/materializedview/handler/MaterializedViewHandler.java | 41 | /// scatter-gather, and merging the results. | COMMENT |
| LOW | …/materializedview/handler/MaterializedViewHandler.java | 81 | /// model on ONLINE→OFFLINE / ONLINE→DROPPED transitions. | COMMENT |
| LOW | …/materializedview/handler/MaterializedViewHandler.java | 101 | } | COMMENT |
| LOW | …pache/pinot/materializedview/handler/package-info.java | 21 | /// | COMMENT |
| LOW | …pache/pinot/materializedview/handler/package-info.java | 41 | /// | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewQueryShape.java | 21 | import java.util.List; | COMMENT |
| LOW | …edview/rewrite/MaterializedViewQueryRewriteEngine.java | 41 | /// | COMMENT |
| LOW | …edview/rewrite/MaterializedViewQueryRewriteEngine.java | 181 | /// partition map is permitted — V1 routing uses `watermarkMs` as the split point, so the | COMMENT |
| LOW | …edview/rewrite/MaterializedViewQueryRewriteEngine.java | 221 | /// | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 41 | /// from the broker hot path. Future contributors adding caching to any method must preserve | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 61 | if (func != null && "as".equals(func.getOperator())) { | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 121 | /// @param expr a SELECT-list expression from the user's query | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 181 | return null; | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 201 | /// **TODO(materialized-view): OR / IN subsumption is currently correctness-safe but conservative.** | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 281 | return RequestUtils.getFunctionExpression(FilterKind.AND.name(), operands); | COMMENT |
| LOW | …terializedview/rewrite/MaterializedViewMatchUtils.java | 341 | } | COMMENT |
| LOW | …ializedview/rewrite/MaterializedViewMetadataCache.java | 81 | /// runtime znode listener may fire ahead of the definition znode listener. Dropping the | COMMENT |
| 799 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 | 142 | // ─── helpers ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …gration/tests/StreamStatsReportingIntegrationTest.java | 176 | // ─── tests ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …gration/tests/StreamStatsReportingIntegrationTest.java | 463 | // ─── 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 | 595 | // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProvider | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 603 | // Step 2: Build broker requests for route calculation | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 617 | // Step 3: Calculate routes | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 621 | // Step 4: Build worker assignment from LogicalTableRouteInfo | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 408 | // Step 1: Build OFFLINE table first - should not have TimeBoundaryManager | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 417 | // 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 | 87 | /// Step 1: shape gate | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 95 | /// Step 2: GROUP BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 101 | /// Step 3: projection subsumption — use the projection map cached on the entry. | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 108 | /// Step 4: WHERE matching + residual extraction (shared logic) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 143 | /// Step 5: residual validation (subclass-specific) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 149 | /// Step 6: ORDER BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 155 | /// Step 7: HAVING | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 161 | /// Step 8: build result | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 141 | // Step 2: source table existence and time-column checks | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 147 | // Step 3: MV schema column completeness (including dateTime columns) | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 150 | // Step 5: extract and validate time column transformation mappings. | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 157 | // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-produced | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 164 | // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV time | COMMENT |
| LOW | …aterializedview/analysis/MaterializedViewAnalyzer.java | 112 | // Step 1: SQL syntax and Pinot semantic validation | COMMENT |
| LOW | …lizedview/scheduler/MaterializedViewTaskScheduler.java | 343 | /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task. | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 134 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 217 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 253 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 297 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 386 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 422 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …not/core/query/executor/ServerQueryExecutorV1Impl.java | 328 | // NOTE: This method might change indexSegments. Do not use it after calling this method. | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 217 | // Step 1: Copy the file or directory into the temporary file | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 233 | // Step 2: Rename the temporary file to the destination file | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 627 | /// Step 1: Verify MV is currently hit (precondition; SLO disabled). | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 633 | /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is a | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 514 | /// Step 1: baseline — split query before the simulated overlap. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 527 | /// Step 2: simulate endSegmentReplace without postProcess — upload MV segments | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 569 | /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filter | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 656 | /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate). | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 671 | /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 686 | /// 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 | 537 | // NOTE: This method is only meant to retain compatibility of serialization for endpoint: | COMMENT |
| 55 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …t/query/planner/physical/v2/PRelNodeTreeValidator.java | 56 | // If joins are disabled in lite mode, we need to check if the plan contains joins | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 595 | // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProvider | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 603 | // Step 2: Build broker requests for route calculation | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 617 | // Step 3: Calculate routes | COMMENT |
| LOW⚡ | …ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java | 621 | // Step 4: Build worker assignment from LogicalTableRouteInfo | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 408 | // Step 1: Build OFFLINE table first - should not have TimeBoundaryManager | COMMENT |
| LOW⚡ | …uting/manager/BrokerRoutingManagerConcurrencyTest.java | 417 | // 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 | 87 | /// Step 1: shape gate | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 95 | /// Step 2: GROUP BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 101 | /// Step 3: projection subsumption — use the projection map cached on the entry. | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 108 | /// Step 4: WHERE matching + residual extraction (shared logic) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 143 | /// Step 5: residual validation (subclass-specific) | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 149 | /// Step 6: ORDER BY | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 155 | /// Step 7: HAVING | COMMENT |
| LOW⚡ | …view/rewrite/strategy/AbstractSubsumptionStrategy.java | 161 | /// Step 8: build result | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 141 | // Step 2: source table existence and time-column checks | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 147 | // Step 3: MV schema column completeness (including dateTime columns) | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 150 | // Step 5: extract and validate time column transformation mappings. | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 157 | // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-produced | COMMENT |
| LOW⚡ | …aterializedview/analysis/MaterializedViewAnalyzer.java | 164 | // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV time | COMMENT |
| LOW | …aterializedview/analysis/MaterializedViewAnalyzer.java | 112 | // Step 1: SQL syntax and Pinot semantic validation | COMMENT |
| LOW | …lizedview/scheduler/MaterializedViewTaskScheduler.java | 343 | /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task. | COMMENT |
| LOW | …/apache/pinot/query/runtime/operator/LeafOperator.java | 602 | * 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 | 293 | // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max duration | COMMENT |
| LOW | …indow/FunnelEventsFunctionEvalAggregationFunction.java | 422 | // 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 | 134 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 217 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 253 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 297 | // Step 1: Convert output range to millis range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 386 | // Step 2: Convert millis range to input range | COMMENT |
| LOW | …ery/optimizer/filter/TimePredicateFilterOptimizer.java | 422 | // Step 3: Rewrite the filter function | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 217 | // Step 1: Copy the file or directory into the temporary file | COMMENT |
| LOW | …java/org/apache/pinot/spi/filesystem/LocalPinotFS.java | 233 | // Step 2: Rename the temporary file to the destination file | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 627 | /// Step 1: Verify MV is currently hit (precondition; SLO disabled). | COMMENT |
| LOW⚡ | …tion/tests/MaterializedViewClusterIntegrationTest.java | 633 | /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is a | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 514 | /// Step 1: baseline — split query before the simulated overlap. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 527 | /// Step 2: simulate endSegmentReplace without postProcess — upload MV segments | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 569 | /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filter | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 656 | /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate). | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 671 | /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0. | COMMENT |
| LOW | …tion/tests/MaterializedViewClusterIntegrationTest.java | 686 | /// 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 |
| 54 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 | …pi/src/test/resources/ingestion_job_spec_template.yaml | 31 | # Sample 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 |
| LOW | …ces/examples/batch/baseballStats/ingestionJobSpec.yaml | 54 | # Sample usage: | COMMENT |
| LOW | …xamples/batch/baseballStats/sparkIngestionJobSpec.yaml | 49 | # Sample usage: | COMMENT |
| 11 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 | …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 | …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 | …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 | …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/degrees.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 | 77 | public abstract class BaseBrokerRequestHandler implements BrokerRequestHandler { | CODE |
| LOW | …ker/requesthandler/MultiStageBrokerRequestHandler.java | 119 | public class MultiStageBrokerRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …questhandler/SingleConnectionBrokerRequestHandler.java | 71 | public class SingleConnectionBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler { | CODE |
| LOW | …ot/broker/requesthandler/GrpcBrokerRequestHandler.java | 61 | public class GrpcBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler { | CODE |
| LOW | …equesthandler/BaseSingleStageBrokerRequestHandler.java | 144 | public abstract class BaseSingleStageBrokerRequestHandler extends BaseBrokerRequestHandler { | CODE |
| LOW | …a/manager/realtime/RealtimeSegmentDataManagerTest.java | 1367 | 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 | 70 | public class InstanceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> { | CODE |
| LOW | …che/pinot/core/data/manager/DuoSegmentDataManager.java | 34 | 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 | 97 | public class RealtimeTableDataManager extends BaseTableDataManager { | CODE |
| LOW | …/data/manager/realtime/RealtimeSegmentDataManager.java | 131 | public class RealtimeSegmentDataManager extends SegmentDataManager { | CODE |
| LOW | …re/data/manager/offline/DimensionTableDataManager.java | 63 | public class DimensionTableDataManager extends OfflineTableDataManager { | CODE |
| LOW | …core/data/manager/offline/OfflineTableDataManager.java | 40 | public class OfflineTableDataManager extends BaseTableDataManager { | CODE |
| LOW | …/data/manager/offline/ImmutableSegmentDataManager.java | 28 | public class ImmutableSegmentDataManager extends SegmentDataManager { | 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 | 41 | 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 | 31 | public abstract class SegmentDataManager { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | …/connector/spark/v3/datasource/PinotWriteBuilder.scala | 31 | // TODO: utilize filters | COMMENT |
| MEDIUM | …inot/integration/tests/UpsertTableIntegrationTest.java | 190 | // fashion, but query more times to be more robust) | COMMENT |
| MEDIUM | …inot/integration/tests/UpsertTableIntegrationTest.java | 209 | // 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ot/core/data/function/GroovyFunctionEvaluatorTest.java | 178 | 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 | 215 | props.setProperty("headers.X-Dummy-Header-1", "dummy-value-1"); | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 216 | props.setProperty("headers.X-Dummy-Header-2", "dummy-value-2"); | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 226 | assertEquals(headers.get("X-Dummy-Header-1"), "dummy-value-1", | CODE |
| LOW⚡ | …rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java | 230 | 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 | 801 | // TODO: Add validation logic here | COMMENT |
| LOW | …rter/helix/IngestionBasedConsumptionStatusChecker.java | 169 | // TODO: implement a way to have this work correctly for kafka consumers | COMMENT |
| LOW | …in/java/org/apache/pinot/spi/plugin/PluginManager.java | 310 | // TODO: implement the self-declaring META-INF/pinot-realm-exports mechanism. | COMMENT |
| LOW | …t/integration/tests/OfflineClusterIntegrationTest.java | 3241 | // TODO: Add test to delete broker instance. Currently, stopBroker() does not work correctly. | COMMENT |
| LOW | …tion/tests/ControllerPeriodicTasksIntegrationTest.java | 72 | // TODO: Add tests for other ControllerPeriodicTasks (RetentionManager, RealtimeSegmentValidationManager). | COMMENT |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 607 | return 0; //TODO: implement this after the complex is supported | CODE |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 627 | return 0; //TODO: implement this after the complex is supported | CODE |
| LOW | …ache/pinot/controller/recommender/io/InputManager.java | 641 | //TODO: implement this after the complex is supported | 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 | 51 | * 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 |