安装OmniShuffle Shuffle加速组件前请先参考环境要求章节获取软件安装包并通过完整性校验。请在所有节点安装OmniShuffle Shuffle加速组件并配置相关参数文件。
cd /home/ockadmin tar --no-same-owner -zxvf /home/ockadmin/BoostKit-omnishuffle_1.7.0.tar.gz cd /home/ockadmin/BoostKit-omnishuffle_1.7.0 tar --no-same-owner -zxvf omnishuffleUtils_aarch64.tar.gz
cd omnishuffleUtils/common
vi common_params.sh
ock_root_path=/home/ockadmin/opt spark_version="spark-3.3" ... #RSS or ESS,配置RSS或ESS模式。 ock_mode="rss" ...
cd ../bin sh ock_install.sh source ~/.bashrc
ock-broadcast-sdk-24.0.0.jar ock-launch-cluster-24.0.0.jar ock-Shuffle-manager-24.0.0-for-spark-3.3.jar # 3.3跟Spark版本一致 ock-Shuffle-sdk-24.0.0.jar zk-server-auth-plugin-tls-24.0.0-assembly.jar zk-server-auth-plugin-keytab-24.0.0-assembly.jar
ock-broadcast-sdk-24.0.0.jar ock-launch-cluster-24.0.0.jar ock-Shuffle-manager-24.0.0-for-spark-3.3.jar # 3.3跟Spark版本一致 ock-Shuffle-sdk-24.0.0.jar zk-server-auth-plugin-tls-24.0.0-assembly.jar zk-server-auth-plugin-keytab-24.0.0-assembly.jar
这里的jar包用户是ockadmin,请保证提交spark任务的用户有改jar包的操作权限,请至少配置为550。
cd /home/ockadmin/opt/ock/conf
vi mf.conf
ock.mf.ip_mask = 192.168.xx.xx-192.168.xx.xx #区间包含所有节点的IP地址 ock.mf.protocol = tcp ock.ucache.rpc.enableAuthentication = false ock.ucache.rpc.enableTLS = false ock.ucache.rpc.enableAuthorization = false
vi ock.conf
ock.ucache.rpc.transport.protocol = tcp ock.ucache.rpc.shuffle_server.port = 3891 ock.ucache.master.ip = 192.168.xx.xx ock.ucache.rpc.enableAuthentication = false ock.ucache.rpc.enableTLS = false ock.ucache.rpc.enableAuthorization = false ock.zookeeper.security.enable = false ock.ucache.server.swap.threshold.higher_watermark = 60 ock.ucache.server.swap.threshold.lower_watermark = 20 ock.ucache.server.swap.path = /data/data1/ock_swap,/data/data2/ock_swap,/data/data3/ock_swap,/data/data4/ock_swap //根据挂盘数量填写,RSS模式推荐挂载NVMe盘 ock.ucache.rpc.openssl.path=/home/ockadmin/opt/ock/ucache/24.0.0/linux-aarch64/lib/common/openssl/libssl.so ock.ucache.rpc.crypto.path = /home/ockadmin/opt/ock/ucache/24.0.0/linux-aarch64/lib/common/openssl/libcrypto.so ock.ucache.rss.mode = false // ESS模式配置为false,RSS模式配置为true ock.ucache.rpc.transport.ipfilter = 192.168.xx.xx/24