diff --git a/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt b/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt index 6bcd3aaccadb..e453f2e47da3 100644 --- a/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt +++ b/presto-native-execution/presto_cpp/main/connectors/CMakeLists.txt @@ -17,5 +17,6 @@ if(PRESTO_ENABLE_ARROW_FLIGHT_CONNECTOR) target_link_libraries(presto_connectors presto_flight_connector) endif() -target_link_libraries(presto_connectors presto_velox_expr_conversion - velox_clp_connector velox_type_fbhive) +target_link_libraries( + presto_connectors presto_velox_expr_conversion velox_clp_connector + velox_type_fbhive velox_type_fbclp_parser) diff --git a/presto-native-execution/presto_cpp/main/connectors/PrestoToVeloxConnector.cpp b/presto-native-execution/presto_cpp/main/connectors/PrestoToVeloxConnector.cpp index 0784ad5ab152..fb6270f0e8d6 100644 --- a/presto-native-execution/presto_cpp/main/connectors/PrestoToVeloxConnector.cpp +++ b/presto-native-execution/presto_cpp/main/connectors/PrestoToVeloxConnector.cpp @@ -20,6 +20,7 @@ #include "presto_cpp/presto_protocol/connector/iceberg/IcebergConnectorProtocol.h" #include "presto_cpp/presto_protocol/connector/tpch/TpchConnectorProtocol.h" +#include #include #include "velox/connectors/clp/ClpColumnHandle.h" #include "velox/connectors/clp/ClpConnectorSplit.h" @@ -1580,7 +1581,7 @@ ClpPrestoToVeloxConnector::toVeloxColumnHandle( return std::make_unique( clpColumn->columnName, clpColumn->originalColumnName, - typeParser.parse(clpColumn->columnType)); + facebook::velox::type::fbclp::parseClpType(clpColumn->columnType)); } std::unique_ptr diff --git a/presto-native-execution/velox b/presto-native-execution/velox index 7ae511984245..1725ea8dba85 160000 --- a/presto-native-execution/velox +++ b/presto-native-execution/velox @@ -1 +1 @@ -Subproject commit 7ae51198424559a7ed6d245ce4c4214ef7047d9d +Subproject commit 1725ea8dba85015f9ae84e38e3993c8cd8f6ef5e