We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
pike引用了其他第三方库,使用pike cli提交sql需要在storm集群每台机器上安装pike,并将pike依赖的jar加入到storm classpath中。
下载pike安装包并解压
tar xzvf pike-$version.tgz -C /usr/local
在$STORM_CONF_DIR/storm_env.init中配置pike环境变量
PIKE_HOME:/usr/loca/pike
PIKE_CONF_DIR:/usr/local/pike/conf
将PIKE_HOME、PIKE_CONF_DIR添加至classpath中,在storm启动脚本get_classpath(extrajars)方法中添加
pike_home = os.environ.get("PIKE_HOME")
pike_conf_dir = os.environ.get("PIKE_CONF_DIR")
ret.extend(get_jars_full(pike_home + "/lib"))
ret.append(pike_conf_dir)