我在flink上有个问题。我实时计算引擎使用groovy脚本扩展计算类型(如:sum、average、、count等)。我们定义了一个标准的计算接口(AbstractCompute),如果我想在这个框架中扩展一个计算类型,我只需要执行AbstractCompute.and,然后将groovy脚本存储在数据库中。然后,应用程序可以逐个任务地读取脚本,并通过GroovyClassLoader加载到虚拟机中。这个程序不用再用Flink了,看工作做的很好。)
at org.<em
GenericType<scala.Tuple5>Exception in thread "main" org.apache.flink.api.common.InvalidProgramExceptionType: GenericType<scala.Tuple5>
at org.apache.flink.api.common.operators.Keys$ExpressionKey