diff --git a/bin/pulsar b/bin/pulsar index a621ae15d532f4..8ca7c742eab06e 100755 --- a/bin/pulsar +++ b/bin/pulsar @@ -180,14 +180,20 @@ fi # find pulsar sql trino distribution location check_trino_libraries() { if [ ! -d "${TRINO_HOME}" ]; then - BUILT_TRINO_HOME="${SQL_HOME}/presto-distribution/target/pulsar-presto-distribution" - if [ ! -d "${BUILT_TRINO_HOME}" ]; then - echo "\nCouldn't find trino distribution."; - echo "Make sure you've run 'mvn package'\n"; - exit 1; + # TODO: Refactor when we drop this backward compatibility. + FALLBACK_PRESTO_HOME="${PULSAR_HOME}/lib/presto" + if [ ! -d "${FALLBACK_PRESTO_HOME}" ]; then + BUILT_TRINO_HOME="${SQL_HOME}/presto-distribution/target/pulsar-presto-distribution" + if [ ! -d "${BUILT_TRINO_HOME}" ]; then + echo "\nCouldn't find trino distribution."; + echo "Make sure you've run 'mvn package'\n"; + exit 1; + fi + TRINO_HOME=${BUILT_TRINO_HOME} + PULSAR_TRINO_CONF=${BUILT_TRINO_HOME}/conf + else + TRINO_HOME=${FALLBACK_PRESTO_HOME} fi - TRINO_HOME=${BUILT_TRINO_HOME} - PULSAR_TRINO_CONF=${BUILT_TRINO_HOME}/conf fi } @@ -259,6 +265,10 @@ fi if [ -z "$PULSAR_TRINO_CONF" ]; then PULSAR_TRINO_CONF=$DEFAULT_PULSAR_TRINO_CONF + # TODO: Refactor to remove when we drop this backward compatibility. + if [ ! -d "${PULSAR_TRINO_CONF}" ]; then + FALLBACK_PULSAR_PRESTO_CONF=${PULSAR_HOME}/conf/presto + fi fi if [ -z "$FUNCTIONS_LOG_CONF"]; then