Skip to content

Commit

Permalink
fix shellcheck
Browse files Browse the repository at this point in the history
  • Loading branch information
AshinGau committed Jul 9, 2024
1 parent 9fcc761 commit 4ae788f
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 41 deletions.
12 changes: 6 additions & 6 deletions samples/datalake/hudi/scripts/spark-hudi.sh
Original file line number Diff line number Diff line change
Expand Up @@ -21,15 +21,15 @@ export SPARK_HOME=/opt/spark-hudi
export HIVE_HOME=/opt/apache-hive-3.1.2-bin
export HADOOP_HOME=/opt/hadoop-3.3.1

if [ ! -d "$SPARK_HOME" ]; then
cp -r /opt/spark-3.4.2-bin-hadoop3 $SPARK_HOME
if [[ ! -d "${SPARK_HOME}" ]]; then
cp -r /opt/spark-3.4.2-bin-hadoop3 "${SPARK_HOME}"
fi

cp ${HIVE_HOME}/conf/hive-site.xml ${SPARK_HOME}/conf/
cp ${HIVE_HOME}/lib/postgresql-jdbc.jar ${SPARK_HOME}/jars/
cp ${HADOOP_HOME}/etc/hadoop/core-site.xml ${SPARK_HOME}/conf/
cp "${HIVE_HOME}"/conf/hive-site.xml "${SPARK_HOME}"/conf/
cp "${HIVE_HOME}"/lib/postgresql-jdbc.jar "${SPARK_HOME}"/jars/
cp "${HADOOP_HOME}"/etc/hadoop/core-site.xml "${SPARK_HOME}"/conf/

${SPARK_HOME}/bin/spark-sql \
"${SPARK_HOME}"/bin/spark-sql \
--master local[*] \
--name "spark-hudi-sql" \
--conf spark.serializer=org.apache.spark.serializer.KryoSerializer \
Expand Down
65 changes: 30 additions & 35 deletions samples/datalake/hudi/start-hudi-compose.sh
Original file line number Diff line number Diff line change
Expand Up @@ -20,68 +20,65 @@
DORIS_PACKAGE=apache-doris-2.1.4-bin-x64
DORIS_DOWNLOAD_URL=https://apache-doris-releases.oss-accelerate.aliyuncs.com


md5_aws_java_sdk="452d1e00efb11bff0ee17c42a6a44a0a"
md5_hadoop_aws="a3e19d42cadd1a6862a41fd276f94382"
md5_hudi_bundle="a9cb8c752d1d7132ef3cfe3ead78a30d"
md5_jdk17="0930efa680ac61e833699ccc36bfc739"
md5_spark="b393d314ffbc03facdc85575197c5db9"
md5_doris="a4d8bc9730aca3a51294e87d7d5b3e8e"


download_source_file() {
local FILE_PATH="$1"
local EXPECTED_MD5="$2"
local DOWNLOAD_URL="$3"

echo "Download $FILE_PATH"
echo "Download ${FILE_PATH}"

if [ -f "$FILE_PATH" ]; then
if [[ -f "${FILE_PATH}" ]]; then
local FILE_MD5
FILE_MD5=$(md5sum "$FILE_PATH" | awk '{ print $1 }')
FILE_MD5=$(md5sum "${FILE_PATH}" | awk '{ print $1 }')

if [ "$FILE_MD5" = "$EXPECTED_MD5" ]; then
echo "$FILE_PATH is ready!"
if [[ "${FILE_MD5}" = "${EXPECTED_MD5}" ]]; then
echo "${FILE_PATH} is ready!"
else
echo "$FILE_PATH is broken, Redownloading ..."
rm $FILE_PATH
wget ${DOWNLOAD_URL}/${FILE_PATH}
echo "${FILE_PATH} is broken, Redownloading ..."
rm "${FILE_PATH}"
wget "${DOWNLOAD_URL}"/"${FILE_PATH}"
fi
else
echo "Downloading $FILE_PATH ..."
wget ${DOWNLOAD_URL}/${FILE_PATH}
echo "Downloading ${FILE_PATH} ..."
wget "${DOWNLOAD_URL}"/"${FILE_PATH}"
fi
}


curdir="$(cd "$(dirname "${BASH_SOURCE[0]}")" &>/dev/null && pwd)"
cd ${curdir}
cd "${curdir}" || exit

if [ ! -d "packages" ]; then
if [[ ! -d "packages" ]]; then
mkdir packages
fi
cd packages
cd packages || exit

download_source_file "aws-java-sdk-bundle-1.12.48.jar" "$md5_aws_java_sdk" "https://repo1.maven.org/maven2/com/amazonaws/aws-java-sdk-bundle/1.12.48"
download_source_file "hadoop-aws-3.3.1.jar" "$md5_hadoop_aws" "https://repo1.maven.org/maven2/org/apache/hadoop/hadoop-aws/3.3.1"
download_source_file "hudi-spark3.4-bundle_2.12-0.14.1.jar" "$md5_hudi_bundle" "https://repo1.maven.org/maven2/org/apache/hudi/hudi-spark3.4-bundle_2.12/0.14.1"
download_source_file "openjdk-17.0.2_linux-x64_bin.tar.gz" "$md5_jdk17" "https://download.java.net/java/GA/jdk17.0.2/dfd4a8d0985749f896bed50d7138ee7f/8/GPL"
download_source_file "spark-3.4.2-bin-hadoop3.tgz" "$md5_spark" "https://archive.apache.org/dist/spark/spark-3.4.2"
download_source_file "${DORIS_PACKAGE}.tar.gz" "$md5_doris" "$DORIS_DOWNLOAD_URL"
download_source_file "aws-java-sdk-bundle-1.12.48.jar" "${md5_aws_java_sdk}" "https://repo1.maven.org/maven2/com/amazonaws/aws-java-sdk-bundle/1.12.48"
download_source_file "hadoop-aws-3.3.1.jar" "${md5_hadoop_aws}" "https://repo1.maven.org/maven2/org/apache/hadoop/hadoop-aws/3.3.1"
download_source_file "hudi-spark3.4-bundle_2.12-0.14.1.jar" "${md5_hudi_bundle}" "https://repo1.maven.org/maven2/org/apache/hudi/hudi-spark3.4-bundle_2.12/0.14.1"
download_source_file "openjdk-17.0.2_linux-x64_bin.tar.gz" "${md5_jdk17}" "https://download.java.net/java/GA/jdk17.0.2/dfd4a8d0985749f896bed50d7138ee7f/8/GPL"
download_source_file "spark-3.4.2-bin-hadoop3.tgz" "${md5_spark}" "https://archive.apache.org/dist/spark/spark-3.4.2"
download_source_file "${DORIS_PACKAGE}.tar.gz" "${md5_doris}" "${DORIS_DOWNLOAD_URL}"

if [ ! -f "jdk-17.0.2/SUCCESS" ]; then
if [[ ! -f "jdk-17.0.2/SUCCESS" ]]; then
echo "Prepare jdk17 environment"
if [ -d "jdk-17.0.2" ]; then
if [[ -d "jdk-17.0.2" ]]; then
echo "Remove broken jdk-17.0.2"
rm -rf jdk-17.0.2
fi
echo "Unpackage jdk-17.0.2"
tar xzf openjdk-17.0.2_linux-x64_bin.tar.gz
touch jdk-17.0.2/SUCCESS
fi
if [ ! -f "spark-3.4.2-bin-hadoop3/SUCCESS" ]; then
if [[ ! -f "spark-3.4.2-bin-hadoop3/SUCCESS" ]]; then
echo "Prepare spark3.4 environment"
if [ -d "spark-3.4.2-bin-hadoop3" ]; then
if [[ -d "spark-3.4.2-bin-hadoop3" ]]; then
echo "Remove broken spark-3.4.2-bin-hadoop3"
rm -rf spark-3.4.2-bin-hadoop3
fi
Expand All @@ -92,15 +89,15 @@ if [ ! -f "spark-3.4.2-bin-hadoop3/SUCCESS" ]; then
cp hudi-spark3.4-bundle_2.12-0.14.1.jar spark-3.4.2-bin-hadoop3/jars/
touch spark-3.4.2-bin-hadoop3/SUCCESS
fi
if [ ! -f "doris-bin/SUCCESS" ]; then
echo "Prepare $DORIS_PACKAGE environment"
if [ -d "doris-bin" ]; then
echo "Remove broken $DORIS_PACKAGE"
if [[ ! -f "doris-bin/SUCCESS" ]]; then
echo "Prepare ${DORIS_PACKAGE} environment"
if [[ -d "doris-bin" ]]; then
echo "Remove broken ${DORIS_PACKAGE}"
rm -rf doris-bin
fi
echo "Unpackage $DORIS_PACKAGE"
tar xzf ${DORIS_PACKAGE}.tar.gz
mv ${DORIS_PACKAGE} doris-bin
echo "Unpackage ${DORIS_PACKAGE}"
tar xzf "${DORIS_PACKAGE}".tar.gz
mv "${DORIS_PACKAGE}" doris-bin
touch doris-bin/SUCCESS
fi

Expand All @@ -119,5 +116,3 @@ echo "Success to launch spark+doris+hudi+minio environments!"
echo "./login-spark.sh to login into spark"
echo "./login-doris.sh to login into doris"
echo "======================================================"


0 comments on commit 4ae788f

Please sign in to comment.