Home / trinodb / trino
Repository Analysis

trinodb/trino

Official repository of Trino, the distributed SQL query engine for big data, formerly known as PrestoSQL (https://trino.io)

0.7 Likely human-written View on GitHub
0.7
Adjusted Score
0.7
Raw Score
100%
Time Factor
2026-05-30
Last Push
12,873
Stars
Java
Language
2,163,881
Lines of Code
13614
Files
323
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 68HIGH 114MEDIUM 13LOW 128

Pattern Findings

323 matches across 14 categories. Click a row to expand file-level details.

Hallucination Indicators68 hits · 750 pts
SeverityFileLineSnippet
CRITICAL…c/main/resources/webapp/src/components/StageDetail.jsx453 this.props.stage.stageStats.operatorSummaries.forEach((operator) => {
CRITICAL…o-main/src/test/java/io/trino/server/ui/TestWebUi.java436 return jakarta.ws.rs.core.Response.ok()
CRITICAL…ava/io/trino/server/security/TestResourceSecurity.java1199 return jakarta.ws.rs.core.Response.ok()
CRITICAL…n/src/test/java/io/trino/execution/TestStageStats.java96 Optional.of(io.trino.plugin.base.metrics.DistributionSnapshot.fromDistribution(getTDigestHistogram(10))),
CRITICAL…src/main/java/io/trino/operator/OperatorFactories.java53 return createAdapterOperatorFactory(new io.trino.operator.join.nonspilling.LookupJoinOperatorFactory(
CRITICAL…n/java/io/trino/sql/planner/LocalExecutionPlanner.java3000 new io.trino.operator.join.nonspilling.PartitionedLookupSourceFactory(
CRITICAL…rino/plugin/iceberg/TestIcebergAvroDataConversion.java36 VARIANT.writeObject(blockBuilder, io.trino.spi.variant.Variant.ofLong(41));
CRITICAL…rino/plugin/iceberg/TestIcebergAvroDataConversion.java37 VARIANT.writeObject(blockBuilder, io.trino.spi.variant.Variant.ofLong(42));
CRITICAL…rino/plugin/iceberg/TestIcebergAvroDataConversion.java43 assertThat(org.apache.iceberg.variants.Variant.toString((org.apache.iceberg.variants.Variant) converted))
CRITICAL…rino/plugin/iceberg/TestIcebergAvroDataConversion.java52 VARIANT.writeObject(blockBuilder, io.trino.spi.variant.Variant.ofString("hello"));
CRITICAL…rino/plugin/iceberg/TestIcebergAvroDataConversion.java58 assertThat(org.apache.iceberg.variants.Variant.toString((org.apache.iceberg.variants.Variant) converted))
CRITICAL…plugin/iceberg/delete/DefaultDeletionVectorWriter.java316 io.trino.plugin.iceberg.delete.DeleteFile.fromIceberg(deleteFile),
CRITICAL…rino/plugin/iceberg/catalog/jdbc/TrinoJdbcCatalog.java331 // "Cannot invoke "org.apache.iceberg.util.SerializableSupplier.get()" because "this.hadoopConf" is null"
CRITICAL…/lakehouse/TestLakehouseIcebergConnectorSmokeTest.java77 assertThat(io.trino.plugin.iceberg.TableType.values())
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java97 private final software.amazon.awssdk.services.glue.model.Database glueDatabase = software.amazon.awssdk.services.glu
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java104 private final software.amazon.awssdk.services.glue.model.Table glueMaterializedView = software.amazon.awssdk.service
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java117 private final software.amazon.awssdk.services.glue.model.Table glueView = software.amazon.awssdk.services.glue.model
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java130 private final software.amazon.awssdk.services.glue.model.Table glueTable = software.amazon.awssdk.services.glue.mode
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java135 .partitionKeys(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java142 .columns(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java162 private final software.amazon.awssdk.services.glue.model.Partition gluePartition = software.amazon.awssdk.services.g
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java169 .columns(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java281 .columns(ImmutableList.of(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java334 .partitionKeys(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java350 .columns(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…rino/plugin/hive/metastore/glue/TestGlueConverter.java369 .columns(software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…gin/hive/metastore/thrift/TestThriftMetastoreUtil.java106 private static final io.trino.hive.thrift.metastore.Table TEST_TABLE = new io.trino.hive.thrift.metastore.Table(
CRITICAL…gin/hive/metastore/thrift/TestThriftMetastoreUtil.java126 private static final io.trino.hive.thrift.metastore.Partition TEST_PARTITION = new io.trino.hive.thrift.metastore.Pa
CRITICAL…gin/hive/metastore/thrift/TestThriftMetastoreUtil.java145 private static final io.trino.hive.thrift.metastore.Table TEST_TABLE_WITH_UNSUPPORTED_FIELDS = new io.trino.hive.thr
CRITICAL…gin/hive/metastore/thrift/TestThriftMetastoreUtil.java160 private static final io.trino.hive.thrift.metastore.Partition TEST_PARTITION_WITH_UNSUPPORTED_FIELDS = new io.trino.
CRITICAL…gin/hive/metastore/thrift/TestThriftMetastoreUtil.java179 private static final io.trino.hive.thrift.metastore.Partition TEST_PARTITION_WITH_MISSING_COLUMNS = new io.trino.hiv
CRITICAL…o/trino/plugin/hive/metastore/thrift/TestTxnUtils.java41 var hiveResponse = new org.apache.hadoop.hive.metastore.api.GetOpenTxnsResponse(
CRITICAL…o/trino/plugin/hive/metastore/thrift/TestTxnUtils.java45 String hiveValue = org.apache.hadoop.hive.metastore.txn.TxnUtils.createValidReadTxnList(hiveResponse, currentTxn
CRITICAL…o/trino/plugin/hive/metastore/thrift/TestTxnUtils.java69 String hiveValue = org.apache.hadoop.hive.metastore.txn.TxnUtils.createValidTxnWriteIdList(currentTxn, hiveIds).
CRITICAL…o/trino/plugin/hive/metastore/thrift/TestTxnUtils.java88 String hiveValue = org.apache.hadoop.hive.metastore.txn.TxnUtils.createValidReaderWriteIdList(hiveIds).toString(
CRITICAL…o/trino/plugin/hive/metastore/thrift/TestTxnUtils.java97 var result = new org.apache.hadoop.hive.metastore.api.TableValidWriteIds(
CRITICAL…ve/metastore/CoralSemiTransactionalHiveMSCAdapter.java92 var result = new com.linkedin.coral.hive.metastore.api.Database();
CRITICAL…ve/metastore/CoralSemiTransactionalHiveMSCAdapter.java102 var result = new com.linkedin.coral.hive.metastore.api.Table();
CRITICAL…ve/metastore/CoralSemiTransactionalHiveMSCAdapter.java118 var result = new com.linkedin.coral.hive.metastore.api.StorageDescriptor();
CRITICAL…ve/metastore/CoralSemiTransactionalHiveMSCAdapter.java134 var result = new com.linkedin.coral.hive.metastore.api.SerDeInfo();
CRITICAL…ve/metastore/CoralSemiTransactionalHiveMSCAdapter.java145 var result = new com.linkedin.coral.hive.metastore.api.FieldSchema();
CRITICAL…io/trino/plugin/hive/metastore/glue/GlueConverter.java312 return software.amazon.awssdk.services.glue.model.Column.builder()
CRITICAL…io/trino/plugin/hive/metastore/glue/GlueConverter.java678 .map(uri -> software.amazon.awssdk.services.glue.model.ResourceUri.builder()
CRITICAL…/plugin/hive/metastore/thrift/ThriftMetastoreUtil.java179 io.trino.hive.thrift.metastore.Database result = new io.trino.hive.thrift.metastore.Database();
CRITICAL…/plugin/hive/metastore/thrift/ThriftMetastoreUtil.java199 io.trino.hive.thrift.metastore.Table result = new io.trino.hive.thrift.metastore.Table();
CRITICAL…/plugin/hive/metastore/thrift/ThriftMetastoreUtil.java360 io.trino.hive.thrift.metastore.Partition result = new io.trino.hive.thrift.metastore.Partition();
CRITICAL…/plugin/hive/metastore/thrift/ThriftMetastoreUtil.java993 return new io.trino.hive.thrift.metastore.Function()
CRITICAL…io/trino/plugin/pinot/TestPinotConnectorSmokeTest.java609 org.apache.pinot.spi.data.Schema pinotSchema = org.apache.pinot.spi.data.Schema.fromInputStream(pinotSchemaI
CRITICALdocs/src/main/sphinx/client/cli.md692at io.trino.sql.analyzer.SemanticExceptions.semanticException(SemanticExceptions.java:48)
CRITICALdocs/src/main/sphinx/client/cli.md693at io.trino.sql.analyzer.SemanticExceptions.semanticException(SemanticExceptions.java:43)
CRITICAL.mvn/modernizer/violations.xml276 <comment>Use io.trino.plugin.base.util.JsonUtils.jsonFactory()</comment>
CRITICAL.mvn/modernizer/violations.xml282 <comment>Use io.trino.plugin.base.util.JsonUtils.jsonFactoryBuilder() instead</comment>
CRITICAL.github/workflows/upload-test-results.yml26 const opts = github.rest.actions.listWorkflowRunArtifacts.endpoint.merge({
CRITICAL.github/actions/update-check/action.yml88 const comments = await github.paginate(github.rest.issues.listComments.endpoint.merge({
CRITICAL…in/java/io/trino/filesystem/s3/S3FileSystemConfig.java98 case AwsS3V4Signer -> software.amazon.awssdk.auth.signer.AwsS3V4Signer.create();
CRITICAL…in/java/io/trino/filesystem/s3/S3FileSystemConfig.java99 case Aws4Signer -> software.amazon.awssdk.auth.signer.Aws4Signer.create();
CRITICAL…in/java/io/trino/filesystem/s3/S3FileSystemConfig.java100 case AsyncAws4Signer -> software.amazon.awssdk.auth.signer.AsyncAws4Signer.create();
CRITICAL…in/java/io/trino/filesystem/s3/S3FileSystemConfig.java101 case Aws4UnsignedPayloadSigner -> software.amazon.awssdk.auth.signer.Aws4UnsignedPayloadSigner.create();
CRITICAL…in/java/io/trino/filesystem/s3/S3FileSystemConfig.java102 case EventStreamAws4Signer -> software.amazon.awssdk.auth.signer.EventStreamAws4Signer.create();
CRITICAL…/test/java/io/trino/parquet/reader/TestPageReader.java503 assertThat(parquetEncoding).isEqualTo(ParquetTypeUtils.getParquetEncoding(org.apache.parquet.column.Encoding.val
8 more matches not shown…
Cross-File Repetition110 hits · 550 pts
SeverityFileLineSnippet
HIGH…in/src/test/java/io/trino/type/TestArrayOperators.java0array_sort(a, (x, y) -> case when x is null then -1 when y is null then 1 when x < y then 1 when x = y then 0 else -1 en
HIGH…in/src/test/java/io/trino/type/TestArrayOperators.java0array_sort(a, (x, y) -> case when x is null then -1 when y is null then 1 when x < y then 1 when x = y then 0 else -1 en
HIGH…in/src/test/java/io/trino/type/TestArrayOperators.java0array_sort(a, (x, y) -> case when x is null then -1 when y is null then 1 when x < y then 1 when x = y then 0 else -1 en
HIGH…in/src/test/java/io/trino/type/TestArrayOperators.java0array_sort(a, (x, y) -> case when x is null then -1 when y is null then 1 when x < y then 1 when x = y then 0 else -1 en
HIGH…in/src/test/java/io/trino/type/TestArrayOperators.java0array_sort(a, (x, y) -> case when x is null then -1 when y is null then 1 when x < y then 1 when x = y then 0 else -1 en
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select count(column_a) from table_with_stats_a group by column_b
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from (table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a) join small_tabl
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from (table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a) join small_tabl
HIGH…planner/optimizations/TestDeterminePartitionCount.java0select a.column_a from (table_with_stats_a as a join table_with_stats_b as b on a.column_a = b.column_a) join small_tabl
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select (select "$row_id" from %s where id = 2) = (select "$row_id" from %s for version as of %s where id = 2)
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select (select "$row_id" from %s where id = 2) = (select "$row_id" from %s for version as of %s where id = 2)
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select (select "$row_id" from %s where id = 2) = (select "$row_id" from %s for version as of %s where id = 2)
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select count(*) as row_count, count_if("$row_id" is null) as row_id_nulls, count_if("$last_updated_sequence_number" is n
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select count(*) as row_count, count_if("$row_id" is null) as row_id_nulls, count_if("$last_updated_sequence_number" is n
HIGH…c/test/java/io/trino/plugin/iceberg/TestIcebergV3.java0select count(*) as row_count, count_if("$row_id" is null) as row_id_nulls, count_if("$last_updated_sequence_number" is n
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, 25, 0, null, '0', '24'), ('regionkey', null, 5, 0, null, '0', '4'), ('comment', 2087.0, 25, 0
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, 25, 0, null, '0', '24'), ('regionkey', null, 5, 0, null, '0', '4'), ('comment', 2087.0, 25, 0
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, 25, 0, null, '0', '24'), ('regionkey', null, 5, 0, null, '0', '4'), ('comment', 2087.0, 25, 0
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, 25, 0, null, '0', '24'), ('regionkey', null, 5, 0, null, '0', '4'), ('comment', 2087.0, 25, 0
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, 25, 0, null, '0', '24'), ('regionkey', null, 5, 0, null, '0', '4'), ('comment', 2087.0, 25, 0
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, null, 0, null, '0', '24'), ('regionkey', null, null, 0, null, '0', '4'), ('comment', 2087.0,
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, null, 0, null, '0', '24'), ('regionkey', null, null, 0, null, '0', '4'), ('comment', 2087.0,
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', null, null, 0, null, '0', '24'), ('regionkey', null, null, 0, null, '0', '4'), ('comment', 2087.0,
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', 0, 0, 1, null, null, null), ('regionkey', 0, 0, 1, null, null, null), ('comment', 0, 0, 1, null, nu
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', 0, 0, 1, null, null, null), ('regionkey', 0, 0, 1, null, null, null), ('comment', 0, 0, 1, null, nu
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('nationkey', 0, 0, 1, null, null, null), ('regionkey', 0, 0, 1, null, null, null), ('comment', 0, 0, 1, null, nu
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('a', null, null, null, null, null, null), ('b', null, null, null, null, null, null), (null, null, null, null, 2,
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('a', null, null, null, null, null, null), ('b', null, null, null, null, null, null), (null, null, null, null, 2,
HIGH…ava/io/trino/plugin/iceberg/TestIcebergStatistics.java0values ('a', null, null, null, null, null, null), ('b', null, null, null, null, null, null), (null, null, null, null, 2,
HIGH…o/plugin/iceberg/TestIcebergLocalConcurrentWrites.java0merge into %s t using (values (21, 30)) as s(a, part) on (t.part = s.part) when matched then delete
HIGH…/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java0merge into %s t using (values (21, 30)) as s(a, part) on (t.part = s.part) when matched then delete
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0merge into %s t using (values (21, 30)) as s(a, part) on (t.part = s.part) when matched then delete
HIGH…o/plugin/iceberg/TestIcebergLocalConcurrentWrites.java0merge into %s t using (values (32, 40)) as s(a, part) on (t.part = s.part) when matched then update set a = s.a
HIGH…/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java0merge into %s t using (values (32, 40)) as s(a, part) on (t.part = s.part) when matched then update set a = s.a
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0merge into %s t using (values (32, 40)) as s(a, part) on (t.part = s.part) when matched then update set a = s.a
HIGH…/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java0merge into %s t using (values (12, 20)) as s(a, part) on (false) when not matched then insert (a, part) values(s.a, s.pa
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0merge into %s t using (values (12, 20)) as s(a, part) on (false) when not matched then insert (a, part) values(s.a, s.pa
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0merge into %s t using (values (12, 20)) as s(a, part) on (false) when not matched then insert (a, part) values(s.a, s.pa
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0values ('create table as select', 'writeserializable'), ('merge', 'writeserializable'), ('write', 'writeserializable'),
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0values ('create table as select', 'writeserializable'), ('merge', 'writeserializable'), ('write', 'writeserializable'),
HIGH…/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java0values ('create table as select', 'writeserializable'), ('merge', 'writeserializable'), ('write', 'writeserializable'),
HIGH…rc/test/java/io/trino/plugin/faker/TestFakerViews.java0select * from (values ('%1$s', '%2$s'), ('%1$s', '%3$s')) cross join unnest(array['orderkey', 'orderstatus', 'half'])
HIGH…rc/test/java/io/trino/plugin/faker/TestFakerViews.java0select * from (values ('%1$s', '%2$s'), ('%1$s', '%3$s')) cross join unnest(array['orderkey', 'orderstatus', 'half'])
HIGH…rc/test/java/io/trino/plugin/faker/TestFakerViews.java0select * from (values ('%1$s', '%2$s'), ('%1$s', '%3$s')) cross join unnest(array['orderkey', 'orderstatus', 'half'])
HIGH…r/src/main/java/io/trino/plugin/faker/FakerConfig.java0if true, when creating a table using existing data, columns with the number of distinct values close to the number of ro
HIGH…rc/main/java/io/trino/plugin/faker/FakerConnector.java0if true, when creating a table using existing data, columns with the number of distinct values close to the number of ro
HIGH…rc/main/java/io/trino/plugin/faker/FakerConnector.java0if true, when creating a table using existing data, columns with the number of distinct values close to the number of ro
HIGH…r/src/main/java/io/trino/plugin/faker/FakerConfig.java0if true, when creating a table using existing data, columns with a low number of distinct values are treated as dictiona
HIGH…rc/main/java/io/trino/plugin/faker/FakerConnector.java0if true, when creating a table using existing data, columns with a low number of distinct values are treated as dictiona
HIGH…rc/main/java/io/trino/plugin/faker/FakerConnector.java0if true, when creating a table using existing data, columns with a low number of distinct values are treated as dictiona
50 more matches not shown…
Over-Commented Block91 hits · 86 pts
SeverityFileLineSnippet
LOW…trino-spi/src/main/java/io/trino/spi/type/MapType.java321 Block rawKeyBlock = sqlMap.getRawKeyBlock();
LOW…trino-spi/src/main/java/io/trino/spi/type/MapType.java341 // non-null keys is not always enforced, and null keys may be allowed in the future.
LOW…ino-spi/src/main/java/io/trino/spi/type/ArrayType.java261 // FLAT MEMORY LAYOUT
LOW…no-spi/src/main/java/io/trino/spi/variant/Variant.java801 /// - Arrays become {@code List<Object>}
LOW…no-spi/src/main/java/io/trino/spi/variant/Variant.java861 yield unmodifiableList(array);
LOW…no-spi/src/main/java/io/trino/spi/variant/Variant.java881 ///
LOW…in/java/io/trino/spi/variant/VariantFieldRemapper.java21import static io.trino.spi.variant.VariantDecoder.decode;
LOW…ino/sql/planner/TestDeleteAndInsertMergeProcessor.java81 // The single operation is a delete
LOW…ql/planner/optimizations/TestAdaptivePartitioning.java141
LOW…/java/io/trino/sql/routine/TestSqlRoutineCompiler.java101 }
LOW…/java/io/trino/sql/routine/TestSqlRoutineCompiler.java181 // SET a = a + 1;
LOW…no-main/src/main/java/io/trino/util/DateTimeUtils.java401 // Ensures fixed-width, zero-padded minutes. This affects printing only, not parsing.
LOW…src/main/java/io/trino/util/variant/VariantWriter.java81 /// field IDs from the `Metadata.Builder`.
LOW…/src/main/java/io/trino/cost/TopNRankingStatsRule.java101 else if (node.getRankingType() == RANK) {
LOW…/src/main/java/io/trino/cost/TopNRankingStatsRule.java121 // rowsPerDistinctValue is always >= 1.0, otherwise we will underestimate the rows per partition.
LOW…/src/main/java/io/trino/cost/TopNRankingStatsRule.java201 // Consider that order by columns are COL1, COL2 for the below single partition:
LOW…ain/src/main/java/io/trino/server/ThrowableMapper.java41 @Inject
LOW…in/java/io/trino/server/remotetask/HttpRemoteTask.java1101 // Update the taskInfo with the new taskStatus.
LOW…/main/java/io/trino/execution/buffer/ClientBuffer.java321 // provided sequenceId. Then pages starting from the sequenceId are
LOW…o/operator/join/nonspilling/LookupJoinPageBuilder.java201 verify(position >= 0 && previousPosition <= position);
LOW…rino/operator/join/spilling/LookupJoinPageBuilder.java161 estimatedProbeBlockBytes += Integer.BYTES;
LOW…o/trino/operator/output/SkewedPartitionRebalancer.java141 PartitionFunctionProvider partitionFunctionProvider,
LOW…main/java/io/trino/sql/rewrite/ShowQueriesRewrite.java481 // and thus failing due to a single bad table would make the system unusable.
LOW…trino/sql/ir/optimizer/rule/SimplifyRedundantCase.java81 // WHEN a5 THEN true
LOW…n/java/io/trino/sql/planner/LocalExecutionPlanner.java3921 for (int i = 0; i < lambdas.size(); i++) {
LOW…src/main/java/io/trino/sql/planner/PlanFragmenter.java441 // context is mutable. The leaf node should set the PartitioningHandle.
LOW…src/main/java/io/trino/sql/planner/PlanFragmenter.java461 // - CurrentPlan
LOW…c/main/java/io/trino/sql/planner/DomainTranslator.java441 //
LOW…trino/sql/planner/planprinter/WindowOperatorStats.java101 // In such case, WindowOperator will be inefficient because parallelism will go down.
LOW…no/sql/planner/optimizations/PlanNodeDecorrelator.java201 return rewriteLimitWithRowCountGreaterThanOne(childDecorrelationResult, node);
LOW…l/planner/optimizations/StreamPropertyDerivations.java241 .translate(column -> PropertyDerivations.filterOrRewrite(node.getOutputSymbols(), node.getCriter
LOW…planner/iterative/rule/PushPredicateIntoTableScan.java341 // * Unenforced constraints go next because they can only be simple column references,
LOW…anner/iterative/rule/ImplementTableFunctionSource.java401 new Comparison(EQUAL, leftRowNumber, new Constant(BIGINT, 1L)))))))
LOW…anner/iterative/rule/ImplementTableFunctionSource.java421 //
LOW…/iterative/rule/PushPartialAggregationThroughJoin.java221 // Only push aggregation down if pushed grouping set is of same size or smaller. This is because
LOW…/sql/planner/iterative/rule/PushTopNIntoTableScan.java101 Optional.empty());
LOW…ain/java/io/trino/sql/analyzer/ExpressionAnalyzer.java2801 // When an IN-predicate containing a subquery: `x IN (SELECT ...)` is planned, both `value` and `valueList`
LOW…java/io/trino/sql/tree/PatternRecognitionRelation.java201 // Output a single summary row for every match, including empty matches.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml1# Cassandra storage config YAML
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml21# a random token, which will lead to hot spots.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml41# The following setting populates the page cache on memtable flush and compaction
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml61# - CassandraAuthorizer stores permissions in system_auth.permissions table. Please
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml81# Hash Function instead of md5. When in doubt, this is the best option.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml101
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml121# NOTE: if you reduce the size, you may not get you hottest keys loaded on startup.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml141# Maximum size of the row cache in memory.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml161
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml181# segment may be archived, deleted, or recycled once all the data
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml201 # Ex: "<ip1>,<ip2>,<ip3>"
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml221
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml241trickle_fsync_interval_in_kb: 10240
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml261
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml281# RPC address to broadcast to drivers and other Cassandra nodes. This cannot
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml301#
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml321# rpc_min_threads: 16
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml341incremental_backups: false
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml361# that wastefully either.
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml381# order to keep the sstable count down, but in general, setting this to
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml401# that contends with other proposals for the same row
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml421# When a timeout occurs during streaming, streaming is retried from the start
31 more matches not shown…
Synthetic Comment Markers4 hits · 41 pts
SeverityFileLineSnippet
HIGHdocs/src/main/sphinx/release/release-410.md13* Fix query failure when reading Parquet files generated by Airbyte. ({issue}`16362`)
HIGHdocs/src/main/sphinx/release/release-410.md24* Fix query failure when reading Parquet files generated by Airbyte. ({issue}`16362`)
HIGHdocs/src/main/sphinx/release/release-410.md30* Fix query failure when reading Parquet files generated by Airbyte. ({issue}`16362`)
HIGHdocs/src/main/sphinx/release/release-410.md35* Fix query failure when reading Parquet files generated by Airbyte. ({issue}`16362`)
AI Slop Vocabulary10 hits · 29 pts
SeverityFileLineSnippet
MEDIUM…t/java/io/trino/sql/planner/TestEqualityInference.java295 // All scope equalities should utilize the constant if possible
MEDIUM…/main/java/io/trino/operator/MarkDistinctOperator.java180 // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage
MEDIUM…src/main/java/io/trino/operator/RowNumberOperator.java263 // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage
MEDIUM…main/java/io/trino/operator/DistinctLimitOperator.java225 // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage
MEDIUM…src/main/java/io/trino/sql/planner/PlanOptimizers.java742 // to leverage predicate pushdown on projected columns.
MEDIUM…src/main/java/io/trino/sql/planner/PlanOptimizers.java834 // to leverage predicate pushdown on projected columns.
MEDIUM…src/main/java/io/trino/sql/planner/PlanOptimizers.java987 // Run predicate push down one more time in case we can leverage new information from layouts' effective predica
MEDIUM…src/main/java/io/trino/sql/planner/PlanOptimizers.java1014 // to leverage predicate pushdown on projected columns and to pushdown dynamic filters.
MEDIUM…/trino/spooling/filesystem/SimpleFileSystemLayout.java51 return Optional.empty(); // Definitely not a segment
MEDIUM…main/java/io/trino/testing/tpch/TpchIndexMetadata.java57 // Note: technically we could more efficiently utilize the overlapped columns, but this way is simpler for now
Fake / Example Data13 hits · 13 pts
SeverityFileLineSnippet
LOW…th2/TestOAuth2WebUiAuthenticationFilterWithOpaque.java78 assertThat(claims.getSubject()).isEqualTo("foo@bar.com");
LOW…oauth2/TestOAuth2WebUiAuthenticationFilterWithJwt.java68 assertThat(claims.getSubject()).isEqualTo("foo@bar.com");
LOW…rver/security/oauth2/TestingHydraIdentityProvider.java296 mapper.writeValueAsString(mapper.createObjectNode().put("subject", "foo@bar.
LOW…ty/oauth2/BaseOAuth2WebUiAuthenticationFilterTest.java220 .put("sub", "foo@bar.com")
LOW…ty/oauth2/BaseOAuth2WebUiAuthenticationFilterTest.java355 assertThat(claims.getSubject()).isEqualTo("foo@bar.com");
LOW…trino/plugin/ai/functions/AbstractTestAiFunctions.java187 .isEqualTo(ImmutableMap.of("person", "John Doe", "location", "New York", "organization", "Acme Corp"));
LOW…trino/plugin/ai/functions/AbstractTestAiFunctions.java187 .isEqualTo(ImmutableMap.of("person", "John Doe", "location", "New York", "organization", "Acme Corp"));
LOWdocs/src/main/sphinx/udf/sql/examples.md113SELECT hello('Jane Doe'); -- Hello, Jane Doe!
LOW…o/trino/tests/product/iceberg/TestIcebergOptimize.java52 "(1, 'Poland', 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque rutrum erat faucib
LOW…o/trino/tests/product/iceberg/TestIcebergOptimize.java52 "(1, 'Poland', 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque rutrum erat faucib
LOW…on/hydra-identity-provider/login_and_consent_server.py35 data=json.dumps({"subject": "foo@bar.com"}).encode()),
LOW…ching/src/test/java/io/trino/matching/TestMatcher.java49 assertMatch(any(), "John Doe");
LOW…ching/src/test/java/io/trino/matching/TestMatcher.java54 assertNoMatch(typeOf(Integer.class), "John Doe");
Hyper-Verbose Identifiers11 hits · 11 pts
SeverityFileLineSnippet
LOW…re/trino-web-ui/src/main/resources/webapp/src/utils.js188export function addExponentiallyWeightedToHistory(value: number, valuesArray: number[]): number[] {
LOW…i/src/main/resources/webapp-preview/src/utils/utils.ts84export function addExponentiallyWeightedToHistory(value: number, valuesArray: number[]): number[] {
LOW…n/src/main/java/io/trino/server/ui/WorkerResource.java214 private static class StreamingJsonResponseHandler
LOW…no/server/security/oauth2/NimbusAirliftHttpClient.java105 public static class NimbusResponseHandler<T>
LOW…in/java/io/trino/server/remotetask/HttpRemoteTask.java1206 private class UpdateResponseHandler
LOW…trino/server/remotetask/SimpleHttpResponseHandler.java27public class SimpleHttpResponseHandler<T>
LOW…/main/java/io/trino/operator/HttpPageBufferClient.java651 public static class PageResponseHandler
LOW.github/bin/check-cla.js185function findMissingClaContributors(commits, contributors) {
LOW.github/bin/check-cla.js382async function bestEffortUpdatePullRequests(update) {
LOW.github/bin/build-pt-matrix-from-impacted-connectors.py85def load_available_features_for_config(config, suites, ptl_binary_path):
LOW…sloader/ClassLoaderSafeTableFunctionDataProcessor.java24public class ClassLoaderSafeTableFunctionDataProcessor
Self-Referential Comments2 hits · 6 pts
SeverityFileLineSnippet
MEDIUMdocs/src/main/sphinx/conf.py18# This file is execfile()d with the current directory set to its containing dir.
MEDIUM.github/workflows/ci.yml571 # Create an empty S3 bucket for S3 filesystem cloud tests and add the bucket name to GitHub environment variab
Redundant / Tautological Comments3 hits · 4 pts
SeverityFileLineSnippet
LOWcore/docker/container-test.sh51 # Check if JAVA_HOME works
LOW…rino-product-tests/health-checks/trino-health-check.sh9# Check if TrinoServer is listed as running Java process
LOW…ino-product-tests/health-checks/hadoop-health-check.sh14# Check if all Hadoop services are running
Deep Nesting4 hits · 4 pts
SeverityFileLineSnippet
LOWdocs/src/main/sphinx/ext/redirects.py33
LOW.github/bin/build-pt-matrix-from-impacted-connectors.py85
LOW.github/bin/build-pt-matrix-from-impacted-connectors.py134
LOW.github/bin/build-pt-matrix-from-impacted-connectors.py176
Verbosity Indicators2 hits · 3 pts
SeverityFileLineSnippet
LOW…c/main/java/io/trino/spi/predicate/SortedRangeSet.java763 // otherwise we need to check if each range is single value
LOW…c/main/java/io/trino/spi/predicate/SortedRangeSet.java1138 // otherwise we need to check if each range is single value
Decorative Section Separators1 hit · 3 pts
SeverityFileLineSnippet
MEDIUM…rino/plugin/hive/crypto/TestHiveParquetEncryption.java184 // ───────────────────────── writer ─────────────────────────
Unused Imports3 hits · 3 pts
SeverityFileLineSnippet
LOWdocs/src/main/sphinx/ext/download.py16
LOWdocs/src/main/sphinx/ext/download.py18
LOWdocs/src/main/sphinx/ext/issue.py16
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippet
LOW…n/trino-cassandra/src/test/resources/cu-cassandra.yaml416# Warning: before enabling this property make sure to ntp is installed