StreamDM中运行.spark.sh 中关于ArrayIndexOutOfBoundsException错误的解决

这篇博客是对于我的上一个博客的一个补充与问题的解决:原链接如下:https://blog.csdn.net/it_neu_lee/article/details/79878753

运行StreamDM中的quick start中的下列命令后会出现数组越界问题:

StreamDM中运行.spark.sh 中关于ArrayIndexOutOfBoundsException错误的解决

问题截图如下:

StreamDM中运行.spark.sh 中关于ArrayIndexOutOfBoundsException错误的解决

经过查找,推断可能是因为StreamDM默认使用了SGDLearner算法,即调用了.spark.sh 后,会默认运行SGDLearner中的参数设定,使用开发工具如IDEA或者其他工具打开源码,SGDLearner.scala代码,其中把numFeaturesOption的参数修改为较大一点的值即可如上述错误是4   那么改为比4大的数即可 

StreamDM中运行.spark.sh 中关于ArrayIndexOutOfBoundsException错误的解决


这样就可以运行成功了