The official home of the Presto distributed SQL query engine for big data
645 matches across 13 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| CRITICAL | …ebook/presto/hive/metastore/TestHiveMetastoreUtil.java | 63 | private static final org.apache.hadoop.hive.metastore.api.Table TEST_TABLE = new org.apache.hadoop.hive.metastore.ap |
| CRITICAL | …ebook/presto/hive/metastore/TestHiveMetastoreUtil.java | 83 | private static final org.apache.hadoop.hive.metastore.api.Partition TEST_PARTITION = new org.apache.hadoop.hive.meta |
| CRITICAL | …ebook/presto/hive/metastore/TestHiveMetastoreUtil.java | 102 | private static final org.apache.hadoop.hive.metastore.api.Table TEST_TABLE_WITH_UNSUPPORTED_FIELDS = new org.apache. |
| CRITICAL | …ebook/presto/hive/metastore/TestHiveMetastoreUtil.java | 117 | private static final org.apache.hadoop.hive.metastore.api.Partition TEST_PARTITION_WITH_UNSUPPORTED_FIELDS = new org |
| CRITICAL | …n/java/com/facebook/presto/hive/HiveStorageFormat.java | 57 | com.facebook.hive.orc.OrcSerde.class.getName(), |
| CRITICAL | …n/java/com/facebook/presto/hive/HiveStorageFormat.java | 58 | com.facebook.hive.orc.OrcInputFormat.class.getName(), |
| CRITICAL | …n/java/com/facebook/presto/hive/HiveStorageFormat.java | 59 | com.facebook.hive.orc.OrcOutputFormat.class.getName(), |
| CRITICAL | …book/presto/hive/metastore/glue/GlueHiveMetastore.java | 718 | newDataColumns.add(software.amazon.awssdk.services.glue.model.Column.builder() |
| CRITICAL | …/hive/metastore/glue/converter/GlueInputConverter.java | 143 | return software.amazon.awssdk.services.glue.model.Column.builder() |
| CRITICAL | …/presto/hive/metastore/thrift/ThriftMetastoreUtil.java | 145 | org.apache.hadoop.hive.metastore.api.Database result = new org.apache.hadoop.hive.metastore.api.Database(); |
| CRITICAL | …/presto/hive/metastore/thrift/ThriftMetastoreUtil.java | 158 | org.apache.hadoop.hive.metastore.api.Table result = new org.apache.hadoop.hive.metastore.api.Table(); |
| CRITICAL | …/presto/hive/metastore/thrift/ThriftMetastoreUtil.java | 374 | org.apache.hadoop.hive.metastore.api.Partition result = new org.apache.hadoop.hive.metastore.api.Partition(); |
| CRITICAL | …c/src/test/java/com/facebook/presto/orc/OrcTester.java | 1999 | com.facebook.hive.orc.Reader reader = com.facebook.hive.orc.OrcFile.createReader( |
| CRITICAL | …c/src/test/java/com/facebook/presto/orc/OrcTester.java | 2434 | com.facebook.hive.orc.OrcConf.setVar(jobConf, HIVE_ORC_COMPRESSION, compressionCodec.name()); |
| CRITICAL | …c/src/test/java/com/facebook/presto/orc/OrcTester.java | 2435 | com.facebook.hive.orc.OrcConf.setIntVar(jobConf, HIVE_ORC_ENTROPY_STRING_THRESHOLD, 1); |
| CRITICAL | …c/src/test/java/com/facebook/presto/orc/OrcTester.java | 2436 | com.facebook.hive.orc.OrcConf.setIntVar(jobConf, HIVE_ORC_DICTIONARY_ENCODING_INTERVAL, 2); |
| CRITICAL | …c/src/test/java/com/facebook/presto/orc/OrcTester.java | 2437 | com.facebook.hive.orc.OrcConf.setBoolVar(jobConf, HIVE_ORC_BUILD_STRIDE_DICTIONARY, true); |
| CRITICAL | …to/spark/execution/http/PrestoSparkHttpTaskClient.java | 828 | com.google.common.net.MediaType parsedMediaType = com.google.common.net.MediaType.parse(value); |
| CRITICAL | …m/facebook/presto/pinot/TestPinotBrokerPageSource.java | 137 | "{ \"exceptions\": [ { \"errorCode\": 200, \"message\": \"QueryExecutionError:\\njava.lang.NumberFor |
| CRITICAL | …to/teradata/functions/dateformat/DateFormatParser.java | 131 | DateFormat lexer = new com.facebook.presto.teradata.functions.DateFormat(new ANTLRInputStream(format)); |
| CRITICAL | …acebook/presto/plugin/clickhouse/ClickHouseClient.java | 624 | com.facebook.presto.plugin.clickhouse.RemoteTableNameCacheKey cacheKey = new com.facebook.presto.plugin. |
| CRITICAL | …c/main/java/com/facebook/presto/druid/DruidConfig.java | 121 | configuration.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName()); |
| CRITICAL | …c/main/java/com/facebook/presto/druid/DruidConfig.java | 122 | configuration.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …java/com/facebook/presto/iceberg/TestIcebergTypes.java | 112 | com.facebook.presto.testing.assertions.Assert.assertEquals(lateRows, lateRowsFromEquals); |
| CRITICAL | …java/com/facebook/presto/iceberg/TestIcebergTypes.java | 118 | com.facebook.presto.testing.assertions.Assert.assertEquals(earlyRows, earlyRowsFromEquals); |
| CRITICAL | …cebook/presto/iceberg/IcebergNativeCatalogFactory.java | 157 | configuration.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName()); |
| CRITICAL | …cebook/presto/iceberg/IcebergNativeCatalogFactory.java | 158 | configuration.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …t/java/com/facebook/presto/mongodb/TestMongoViews.java | 85 | QueryRunner queryRunner = com.facebook.presto.tests.DistributedQueryRunner.builder(session) |
| CRITICAL | …book/presto/plugin/prometheus/TestPrometheusSplit.java | 144 | com.facebook.airlift.units.Duration.timeUnitToString(config.getQueryChunkSizeDuration().getUnit()); |
| CRITICAL | …book/presto/plugin/prometheus/TestPrometheusSplit.java | 151 | config.setMaxQueryRangeDuration(com.facebook.airlift.units.Duration.valueOf("21d")); |
| CRITICAL | …book/presto/plugin/prometheus/TestPrometheusSplit.java | 152 | config.setQueryChunkSizeDuration(com.facebook.airlift.units.Duration.valueOf("1d")); |
| CRITICAL | …book/presto/plugin/prometheus/TestPrometheusSplit.java | 153 | config.setCacheDuration(com.facebook.airlift.units.Duration.valueOf("30s")); |
| CRITICAL | …/com/facebook/presto/hive/TestHudiDirectoryLister.java | 59 | hadoopConf.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName()); |
| CRITICAL | …/com/facebook/presto/hive/TestHudiDirectoryLister.java | 60 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …/com/facebook/presto/hive/TestHudiDirectoryLister.java | 76 | hadoopConf.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName()); |
| CRITICAL | …/com/facebook/presto/hive/TestHudiDirectoryLister.java | 77 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …est/java/com/facebook/presto/hive/TestHiveAnalyze.java | 66 | assertUpdate(format("CREATE TABLE %s (a_varchar varchar, month varchar) WITH (partitioned_by = ARRAY['month'], e |
| CRITICAL | …est/java/com/facebook/presto/hive/TestHiveAnalyze.java | 107 | assertUpdate(format("CREATE TABLE %s (a_varchar varchar, month varchar) WITH (partitioned_by = ARRAY['month'], e |
| CRITICAL | …k/presto/hive/TestGenericHiveRecordCursorProvider.java | 169 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …k/presto/hive/TestGenericHiveRecordCursorProvider.java | 186 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); |
| CRITICAL | …va/com/facebook/presto/hive/parquet/ParquetTester.java | 414 | org.apache.parquet.hadoop.metadata.CompressionCodecName compressionCodecName = org.apache.parquet.hadoop |
| CRITICAL | …resto/hive/metastore/glue/TestingMetastoreObjects.java | 108 | return com.facebook.presto.hive.metastore.Database.builder() |
| CRITICAL | …resto/hive/metastore/glue/TestingMetastoreObjects.java | 119 | return com.facebook.presto.hive.metastore.Table.builder() |
| CRITICAL | …resto/hive/metastore/glue/TestingMetastoreObjects.java | 134 | return com.facebook.presto.hive.metastore.Partition.builder() |
| CRITICAL | …resto/hive/metastore/glue/TestingMetastoreObjects.java | 146 | return new com.facebook.presto.hive.metastore.Column("test-col" + generateRandom(), HiveType.HIVE_STRING, Option |
| CRITICAL | …ava/com/facebook/presto/hive/OrcFileWriterFactory.java | 214 | else if (com.facebook.hive.orc.OrcOutputFormat.class.getName().equals(storageFormat.getOutputFormat())) { |
| CRITICAL | …/com/facebook/presto/hive/util/ConfigurationUtils.java | 110 | com.facebook.hive.orc.OrcConf.setVar(config, HIVE_ORC_COMPRESSION, compression.getOrcCompressionKind().name()); |
| CRITICAL | …m/facebook/presto/lance/TestLanceSqlFilterBuilder.java | 87 | ImmutableMap.of(column, Domain.multipleValues(BIGINT, com.google.common.collect.ImmutableList.of(1L, 2L, |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 174 | new com.facebook.presto.spi.plan.PartitioningScheme( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 175 | com.facebook.presto.spi.plan.Partitioning.create( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 186 | new com.facebook.presto.spi.plan.PartitioningScheme( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 187 | com.facebook.presto.spi.plan.Partitioning.create( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 203 | new com.facebook.presto.spi.plan.PlanFragmentId(0), |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 205 | com.google.common.collect.ImmutableSet.of(col), |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 208 | new com.facebook.presto.spi.plan.PartitioningScheme( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 209 | com.facebook.presto.spi.plan.Partitioning.create( |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 214 | com.facebook.presto.spi.plan.StageExecutionDescriptor.ungroupedExecution(), |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 225 | new com.facebook.presto.spi.plan.PlanFragmentId(1), |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 227 | com.google.common.collect.ImmutableSet.of(col), |
| CRITICAL | …o/sql/planner/TestBasePlanFragmenterTransportType.java | 230 | new com.facebook.presto.spi.plan.PartitioningScheme( |
| 24 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | .yamlfmt.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | .pre-commit-config.yaml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | .yamllint.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …book/presto/hive/metastore/glue/GlueHiveMetastore.java | 161 | public class GlueHiveMetastore |
| LOW | …est/java/com/facebook/presto/orc/TestStreamLayout.java | 141 | // Node 6, Column 1, Type: INT (absent in flat maps) |
| LOW | …com/facebook/presto/orc/stream/LongOutputStreamV2.java | 641 | // header to record the gap width. To deal with this case, we will save |
| LOW | …/facebook/presto/orc/writer/TimestampColumnWriter.java | 161 | } |
| LOW | …/facebook/presto/orc/writer/TimestampColumnWriter.java | 181 | // 2 0b001 123456700 (1234567 << 3) | 0b001 |
| LOW | …book/presto/orc/writer/LongDictionaryColumnWriter.java | 161 | } |
| LOW | …om/facebook/presto/orc/metadata/OrcMetadataReader.java | 421 | break; |
| LOW | …presto/pinot/query/PinotFilterExpressionConverter.java | 141 | // Handle the binary comparison logic of <DATE/TIMESTAMP field> <binary op> <DATE/TIMESTAMP literal>. |
| LOW | …m/facebook/presto/pinot/query/PinotQueryGenerator.java | 401 | } |
| LOW | presto-native-execution/CMakeLists.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | presto-native-execution/docker-compose.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | presto-native-execution/entrypoint.sh | 1 | #!/bin/sh |
| LOW | presto-native-execution/presto_cpp/CMakeLists.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | presto-native-execution/presto_cpp/docs/conf.py | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | presto-native-execution/presto_cpp/docs/conf.py | 21 | # add these directories to sys.path here. If the directory is relative to the |
| LOW | presto-native-execution/presto_cpp/docs/conf.py | 41 | |
| LOW | …ve-execution/presto_cpp/presto_protocol/topological.py | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …ve-execution/presto_cpp/presto_protocol/CMakeLists.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …to-native-execution/presto_cpp/presto_protocol/util.py | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …execution/presto_cpp/presto_protocol/presto_protocol.h | 21 | #include "presto_cpp/presto_protocol/connector/iceberg/presto_protocol_iceberg.h" |
| LOW | …ecution/presto_cpp/presto_protocol/presto_protocol.cpp | 21 | #include "presto_cpp/presto_protocol/connector/tpcds/presto_protocol_tpcds.cpp" |
| LOW | …ecution/presto_cpp/presto_protocol/presto_protocol.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …tion/presto_cpp/presto_protocol/java-to-struct-json.py | 1 | #!/usr/bin/env python3 |
| LOW | …presto_cpp/presto_protocol/core/presto_protocol_core.h | 21 | #include <exception> |
| LOW | …esto_cpp/presto_protocol/core/presto_protocol_core.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …cution/presto_cpp/presto_protocol/tests/CMakeLists.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …onnector/arrow_flight/presto_protocol_arrow_flight.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …protocol/connector/iceberg/presto_protocol_iceberg.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …sto_protocol/connector/tpcds/presto_protocol_tpcds.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …resto_protocol/connector/tpch/presto_protocol_tpch.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | …resto_protocol/connector/hive/presto_protocol_hive.yml | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 161 | # define XXH32_state_s XXH_IPREF(XXH32_state_s) |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 181 | /* specific declaration modes for Windows */ |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 201 | * (therefore, avoid empty or numeric values). |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 221 | # define XXH64_createState XXH_NAME2(XXH_NAMESPACE, XXH64_createState) |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 481 | #ifdef XXH_NAMESPACE |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 521 | * Note: seed==0 produces the same results as XXH3_64bits(). |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 841 | /* ************************************* |
| LOW | presto-native-execution/presto_cpp/external/xxhash.h | 1001 | # define XXH_rotl32 __builtin_rotateleft32 |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 61 | /* special: when including `xxh3.h` directly, turn on XXH_INLINE_ALL */ |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 81 | # define XXH_unlikely(x) __builtin_expect(x, 0) |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 181 | # if defined(__AVX2__) |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 201 | * This is for compatibility with aligned vector loads, which are usually faster. |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 361 | # endif |
| LOW | presto-native-execution/presto_cpp/external/xxh3.h | 441 | /* prefetch |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 21 | #include <algorithm> // all_of, find, for_each |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 41 | // SPDX-License-Identifier: MIT |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 61 | #if defined(NLOHMANN_JSON_VERSION_MAJOR) && defined(NLOHMANN_JSON_VERSION_MINOR) && defined(NLOHMANN_JSON_VERSION_PA |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 81 | #define JSON_USE_LEGACY_DISCARDED_VALUE_COMPARISON 0 |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 161 | // __ _____ _____ _____ |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 181 | #include <type_traits> // is_arithmetic, is_same, is_enum, underlying_type, is_convertible |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 201 | #endif |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 221 | |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 241 | // SPDX-License-Identifier: MIT |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 341 | // SPDX-FileCopyrightText: 2016 - 2021 Evan Nemerson <evan@nemerson.com> |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 361 | #endif |
| LOW | …e-execution/presto_cpp/external/json/nlohmann/json.hpp | 381 | #endif |
| 367 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 17 | # Step 1: Generate CA private key and self-signed certificate. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 22 | # Step 2: Generate server private key. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 25 | # Step 3: Generate server certificate signing request (CSR). |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 30 | # Step 4: Sign server CSR with the CA certificate to generate the server certificate. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 35 | # Step 5: Generate client private key. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 38 | # Step 6: Generate client certificate signing request (CSR). |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 42 | # Step 7: Sign client CSR with the CA certificate to generate the client certificate. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 46 | # Step 8: Output summary. |
| LOW | …n/connectors/arrow_flight/tests/data/generate_certs.sh | 53 | # Step 9: Remove unused files. |
| LOW | …ook/presto/hive/functions/gen/ScalarMethodHandles.java | 90 | // Step 1: Declare default constructor |
| LOW | …ook/presto/hive/functions/gen/ScalarMethodHandles.java | 93 | // Step 2: Declare method |
| LOW | …ook/presto/hive/functions/gen/ScalarMethodHandles.java | 105 | // Step 3: Implement method body |
| LOW | …ook/presto/hive/functions/gen/ScalarMethodHandles.java | 116 | // Step 4: Generate class |
| LOW | …ook/presto/hive/functions/gen/ScalarMethodHandles.java | 122 | // Step 5: Lookup MethodHandle |
| LOW | …o/hive/functions/scalar/HiveScalarFunctionInvoker.java | 74 | // Step 1: Create function instance |
| LOW | …o/hive/functions/scalar/HiveScalarFunctionInvoker.java | 77 | // Step 2: Initialize function |
| LOW | …o/hive/functions/scalar/HiveScalarFunctionInvoker.java | 83 | // Step 3: Create invoker |
| LOW | …o/hive/functions/scalar/HiveScalarFunctionInvoker.java | 94 | // Step 4: Create ThreadLocal GenericUDF |
| LOW | …/planner/iterative/rule/PreAggregateBeforeGroupId.java | 208 | // Step 1: Create new PARTIAL AggregationNode on Source |
| LOW | …/planner/iterative/rule/PreAggregateBeforeGroupId.java | 222 | // Step 2: Create Exchange (hash partitioned by grouping keys) to shuffle partial states |
| LOW | …/planner/iterative/rule/PreAggregateBeforeGroupId.java | 231 | // Step 3: Create INTERMEDIATE AggregationNode below GroupId to merge partial states after shuffle |
| LOW | …/planner/iterative/rule/PreAggregateBeforeGroupId.java | 272 | // Step 4: Create new GroupIdNode with INTERMEDIATE output as source |
| LOW | …/planner/iterative/rule/PreAggregateBeforeGroupId.java | 285 | // Step 5: Change the original PARTIAL aggregation above GroupId to INTERMEDIATE. |
| LOW | …c/test/java/com/facebook/presto/server/TestServer.java | 648 | // Step 1: Simulate router POSTing query to backup server with retry header |
| LOW | …c/test/java/com/facebook/presto/server/TestServer.java | 670 | // Step 2: Configure retry URL to point to the backup cluster's retry endpoint |
| LOW | …c/test/java/com/facebook/presto/server/TestServer.java | 673 | // Step 3: Router redirects client to primary server with retry parameters |
| LOW | …c/test/java/com/facebook/presto/server/TestServer.java | 733 | // Step 4: Client follows the redirect link from primary server to backup server |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | presto-native-execution/presto_cpp/main/PrestoTask.cpp | 154 | // To leverage this logic we need to supply Presto's operator names. |
| MEDIUM | …a/com/facebook/presto/iceberg/IcebergSplitManager.java | 118 | // propagate it at split level so the parquet pushdown can leverage it. |
| MEDIUM | …va/com/facebook/presto/iceberg/IcebergSplitSource.java | 156 | // TODO: We should leverage residual expression and convert that to TupleDomain. |
| MEDIUM | …/com/facebook/presto/tests/tpch/TpchIndexMetadata.java | 78 | // Note: technically we could more efficiently utilize the overlapped columns, but this way is simpler for now |
| MEDIUM | …facebook/presto/sql/planner/TestEqualityInference.java | 305 | // All scope equalities should utilize the constant if possible |
| MEDIUM | …com/facebook/presto/operator/MarkDistinctOperator.java | 183 | // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage |
| MEDIUM | …va/com/facebook/presto/operator/RowNumberOperator.java | 254 | // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage |
| MEDIUM | …om/facebook/presto/operator/DistinctLimitOperator.java | 272 | // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage |
| MEDIUM | …ggregation/builder/InMemoryHashAggregationBuilder.java | 369 | // Essentially we would love to have clean interfaces to support both pushing and pulling memory usage |
| MEDIUM | …va/com/facebook/presto/sql/planner/PlanOptimizers.java | 933 | builder.add(predicatePushDown); // Run predicate push down one more time in case we can leverage new information |
| MEDIUM | …va/com/facebook/presto/sql/planner/PlanOptimizers.java | 1085 | builder.add(predicatePushDown); // Run predicate push down one more time in case we can leverage new information |
| MEDIUM | …lanner/iterative/properties/LogicalPropertiesImpl.java | 312 | // Some optimizations (e.g. canBeHomogenized) may utilize these |
| MEDIUM | …lanner/iterative/properties/LogicalPropertiesImpl.java | 432 | // Some optimizations (e.g. canBeHomogenized) may utilize these |
| MEDIUM | …resto/sql/analyzer/MaterializedViewQueryOptimizer.java | 460 | // TODO: We should be able to leverage this information in the StatementAnalyzer as well. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …cution/presto_cpp/main/tests/TaskUpdateRequestTest.cpp | 281 | {"Name", "John Doe"}, {"Age", "30"}, {"City", "New York"}}; |
| LOW | …cution/presto_cpp/main/tests/TaskUpdateRequestTest.cpp | 283 | {"Name", "Jane Doe"}, {"Age", "25"}, {"City", "Los Angeles"}}; |
| LOW | …sto/nativeworker/AbstractTestNativeGeneralQueries.java | 503 | "'Jane Doe'," + |
| LOW | …k/presto/iceberg/TestIcebergMaterializedViewsBase.java | 1384 | "(1, ARRAY['tag1', 'tag2'], MAP(ARRAY['key1', 'key2'], ARRAY['value1', 'value2']), ROW('123 Main St', 'N |
| LOW | …com/facebook/presto/hive/AbstractTestCteExecution.java | 281 | " (1, ARRAY[ROW('John Doe', 30)], from_base64('Sm9obiBEb2U=')), " + |
| LOW | …com/facebook/presto/hive/AbstractTestCteExecution.java | 431 | " (1, ARRAY[ROW('John Doe', 30)], from_base64('Sm9obiBEb2U=')), -- 'John Doe' in base64\n" + |
| LOW | …est/java/com/facebook/presto/matching/TestMatcher.java | 47 | assertMatch(any(), "John Doe"); |
| LOW | …est/java/com/facebook/presto/matching/TestMatcher.java | 52 | assertNoMatch(typeOf(Integer.class), "John Doe"); |
| LOW | …/java/com/facebook/presto/jdbc/TestJdbcConnection.java | 71 | return new Object[][] {{"test.com:1234"}, {"test@test.com"}}; |
| LOW | …esto/operator/scalar/sql/TestReplaceFirstFunction.java | 41 | "REPLACE_FIRST('John Doe', ' ', '')", |
| LOW | …esto/operator/scalar/sql/TestReplaceFirstFunction.java | 43 | "John Doe"); |
| LOW | …facebook/presto/sql/planner/TestPredicatePushdown.java | 535 | " AND l.comment = 'lorem ipsum' ") |
| LOW | …facebook/presto/sql/planner/TestPredicatePushdown.java | 552 | filter("L_COMMENT = 'lorem ipsum'", |
| LOW | …facebook/presto/sql/planner/TestPredicatePushdown.java | 571 | " AND l.comment = 'lorem ipsum' ") |
| LOW | …facebook/presto/sql/planner/TestPredicatePushdown.java | 588 | filter("L_COMMENT = 'lorem ipsum'", |
| LOW | …rver/security/oauth2/TestingHydraIdentityProvider.java | 296 | mapper.writeValueAsString(mapper.createObjectNode().put("subject", "foo@bar. |
| LOW | …ecurity/oauth2/BaseOAuth2AuthenticationFilterTest.java | 206 | .put("sub", "foo@bar.com") |
| LOW | …ecurity/oauth2/BaseOAuth2AuthenticationFilterTest.java | 325 | assertThat(claims.getSubject()).isEqualTo("foo@bar.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 79 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 80 | body.put("email", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 87 | assertThat(successResponse.getUserInfo().getSubject().getValue()).isEqualTo("user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 136 | body.put("email", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 152 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 168 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 184 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 203 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 219 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 235 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 254 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 273 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 289 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 305 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 344 | body.put("sub", "user@example.com"); |
| LOW | …urity/oauth2/TestNimbusOAuth2ClientUserInfoParser.java | 360 | body.put("sub", "user@example.com"); |
| LOW | …/java/com/facebook/presto/delta/TestColumnMapping.java | 100 | "555-0101", LocalDate.of(2025, 1, 15)); |
| LOW | …/java/com/facebook/presto/delta/TestColumnMapping.java | 103 | "555-0105", LocalDate.of(2026, 1, 20)); |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …to/spark/execution/http/PrestoSparkHttpTaskClient.java | 515 | private static class BytesResponseHandler |
| LOW | …to/spark/execution/http/PrestoSparkHttpTaskClient.java | 693 | public static class PageResponseHandler |
| LOW | …k/execution/http/server/SimpleHttpResponseHandler.java | 31 | public class SimpleHttpResponseHandler<T> |
| LOW | …ion/http/server/smile/AdaptingJsonResponseHandler.java | 30 | public class AdaptingJsonResponseHandler<T> |
| LOW | …ive-execution/presto_cpp/main/PrestoServerOperations.h | 21 | class ResponseHandler; |
| LOW | presto-native-execution/presto_cpp/main/PrestoServer.h | 52 | class ResponseHandler; |
| LOW | …sto-native-execution/presto_cpp/main/http/HttpServer.h | 55 | class AbstractRequestHandler : public proxygen::RequestHandler { |
| LOW | …sto-native-execution/presto_cpp/main/http/HttpServer.h | 137 | class CallbackRequestHandler : public AbstractRequestHandler { |
| LOW | …sto-native-execution/presto_cpp/main/http/HttpServer.h | 171 | class ErrorRequestHandler : public AbstractRequestHandler { |
| LOW | …sto-native-execution/presto_cpp/main/http/HttpClient.h | 154 | class ResponseHandler; |
| LOW | …o-native-execution/presto_cpp/main/http/HttpClient.cpp | 178 | class ResponseHandler : public proxygen::HTTPTransactionHandler { |
| LOW | …/presto_cpp/main/http/filters/tests/HttpFilterTest.cpp | 25 | class DummyRequestHandler : public proxygen::RequestHandler { |
| LOW | …c/main/java/com/facebook/presto/druid/DruidClient.java | 183 | private static class StreamingJsonResponseHandler |
| LOW | …to/functionNamespace/rest/RestSqlFunctionExecutor.java | 159 | public static class SqlFunctionResultResponseHandler |
| LOW | …book/presto/tests/querystats/HttpQueryStatsClient.java | 59 | private final class GetQueryStatsResponseHandler |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 702 | public static class IdentityPassThroughFunctionDataProcessor |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 790 | public static class RepeatFunctionDataProcessor |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 884 | private static class EmptyOutputDataProcessor |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 937 | private static class EmptyOutputWithPassThroughDataProcessor |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 1063 | private static class PassThroughInputDataProcessor |
| LOW | …cebook/presto/connector/tvf/TestingTableFunctions.java | 1157 | private static class TestInputDataProcessor |
| LOW | …va/com/facebook/presto/operator/JoinBridgeManager.java | 219 | private static class TaskWideInternalJoinBridgeDataManager<T extends JoinBridge> |
| LOW | …va/com/facebook/presto/operator/JoinBridgeManager.java | 295 | private static class OneToOneInternalJoinBridgeDataManager<T extends JoinBridge> |
| LOW | …va/com/facebook/presto/operator/JoinBridgeManager.java | 395 | private static class SharedInternalJoinBridgeDataManager<T extends JoinBridge> |
| LOW | …va/com/facebook/presto/proxy/ProxyResponseHandler.java | 34 | public class ProxyResponseHandler |
| LOW | presto-ui/src/utils.ts | 182 | export function addExponentiallyWeightedToHistory(value: number, valuesArray: number[]): number[] { |
| LOW | presto-ui/src/static/tableau/presto-connector.html | 201 | function addSessionParameterToForm(name, value) { |
| LOW | …/presto/server/smile/TestFullSmileResponseHandler.java | 42 | public class TestFullSmileResponseHandler |
| LOW | …ebook/presto/resourcemanager/ResourceManagerProxy.java | 177 | private static class ResponseHandler |
| LOW | …in/java/com/facebook/presto/server/WorkerResource.java | 89 | private static class StreamingJsonResponseHandler |
| LOW | …/facebook/presto/server/SimpleHttpResponseHandler.java | 30 | public class SimpleHttpResponseHandler<T> |
| LOW | …to/server/security/oauth2/NimbusAirliftHttpClient.java | 105 | public static class NimbusResponseHandler<T> |
| LOW | …ok/presto/server/thrift/ThriftHttpResponseHandler.java | 31 | public class ThriftHttpResponseHandler<T> |
| LOW | …sto/server/remotetask/HttpRemoteTaskWithEventLoop.java | 1294 | private class UpdateResponseHandler |
| LOW | …k/presto/server/smile/AdaptingJsonResponseHandler.java | 31 | public class AdaptingJsonResponseHandler<T> |
| LOW | …book/presto/server/smile/FullSmileResponseHandler.java | 35 | public class FullSmileResponseHandler<T> |
| LOW | …com/facebook/presto/operator/HttpRpcShuffleClient.java | 125 | public static class PageResponseHandler |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | …a/com/facebook/presto/hive/HivePageSourceProvider.java | 855 | // In nested columns, if the resolved type is same as requested type don't add the coercion mapp |
| HIGH | …c/test/java/com/facebook/presto/server/TestServer.java | 291 | // verify slug in nextUri is same as requested |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | presto-native-execution/docker-compose.yml | 14 | # Usage: |
| LOW | presto-native-execution/docker-compose.yml | 23 | # Usage: |
| LOW | presto-native-execution/docker-compose.yml | 40 | # Usage: |
| LOW | presto-native-execution/docker-compose.yml | 49 | # Usage: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …tion/presto_cpp/presto_protocol/java-to-struct-json.py | 92 | |
| LOW | …tion/presto_cpp/presto_protocol/java-to-struct-json.py | 189 | |
| LOW | …native-execution/presto_cpp/main/thrift/thrift2json.py | 61 | |
| LOW | …esto_cpp/main/thrift/presto_protocol-to-thrift-json.py | 90 | |
| LOW | presto-native-execution/scripts/license-header.py | 137 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | presto-native-execution/scripts/setup-macos.sh | 22 | # Set DEPENDENCY_DIR to a directory outside of Presto |
| LOW | .github/workflows/prestocpp-linux-build.yml | 40 | # Set compiler to GCC 14 |
| LOW | …uct-tests/conf/docker/files/presto-launcher-wrapper.sh | 38 | # Check if Java version is 17 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | presto-docs/src/main/sphinx/ext/download.py | 16 | |
| LOW | presto-docs/src/main/sphinx/ext/download.py | 18 | |
| LOW | presto-docs/src/main/sphinx/ext/pr.py | 16 | |
| LOW | presto-docs/src/main/sphinx/ext/issue.py | 16 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | presto-docs/src/main/sphinx/conf.py | 18 | # This file is execfile()d with the current directory set to its containing dir. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | presto-cassandra/src/test/resources/cu-cassandra.yaml | 419 | # Warning: before enabling this property make sure to ntp is installed |