创建java多线程,三个线程,每个线程读取kafka中三个partition中其中一个partition中的数据进行决策流计算,发现会抛出异常:
1、com.bstek.urule.RuleException: Class[com.rongcloud.TextContentAuditClient.common.bean.Text] not found in workingmemory
2、com.bstek.urule.RuleException: java.lang.reflect.InvocationTargetException
3、java.util.ConcurrentModificationException
为了您的问题能得到及时准确解答,请认真填写下面各个选项,感谢您的配合。
当前使用的URule的具体版本号:
2.1.7
遇到的问题详细描述:
创建java多线程,三个线程,每个线程读取kafka中三个partition中其中一个partition中的数据进行决策流计算,发现会抛出异常: 1、com.bstek.urule.RuleException: Class[com.rongcloud.TextContentAuditClient.common.bean.Text] not found in workingmemory 2、com.bstek.urule.RuleException: java.lang.reflect.InvocationTargetException 3、java.util.ConcurrentModificationException
涉及到的异常信息(完整异常信息):
相关截图: