whoami20241210

就是要和hdfs一起用，然后发现有报错。

If I change URLClassLoader from local to system, following is the code: ` SiddhiCEP cep = SiddhiCEP.getSiddhiEnvironment(env); String pluginSql = "select class_path,function_name,file_path from plugins"; List pluginRtn = PgUtil.getInstance(host,port,database,username,password).query(pluginSql); for(int i=0;i

Ok, I have found a way walk around this issue. 1.config flink-conf.yaml: classloader.resolve-order: parent-first (flink default configure is child-first, maybe some packages in flink-siddhi/siddhi conflict with flink) 2.code: `SiddhiCEP cep...


The reason of custom function cannot use in returns(): 1.returns() has one line: TypeInformation typeInformation = SiddhiTypeFactory.getTupleTypeInformation(siddhiContext.getAllEnrichedExecutionPlan(), outStreamId); 2.SiddhiTypeFactory.getTupleTypeInformation() calls the getStreamDefinition() of SiddiTypeFactory 3. `public static AbstractDefinition getStreamDefinition(String executionPlan,...

It's an issue of Siddhi. https://github.com/wso2/siddhi/issues/981.

I'm very confused and anxious. Wish your reply, thanks! (PS： In our project must process the real time data and delay data at the same time)

issue link:https://github.com/siddhi-io/siddhi/issues/1144

@haoch Yes, I have already found and the detail is in the issue link: https://github.com/siddhi-io/siddhi/issues/1144

链接是siddhi的性能测试结果：https://docs.wso2.com/display/SP400/Performance+Analysis+Results 按理flink-siddhi和siddhi的性能应该差不多才对。