whoami20241210

If data is mixed with delay data the cep pattern cannot output correct

6

Description: In our project we need process real time data and delay data at same time. But If data is mixed with delay data the cep pattern cannot output correct....

使用hdfs的bug(将mock_local置为false)

8

1.dist/index-0.1/lib里的docformat,index,indexmeta的jar包分别为(build.sh生成的)： index-0.1.jar，indexmeta-0.1.jar，docmeta-0.1.jar 但是start.sh却写着： cmd="$HADOOP jar ${current_dir}/lib/docmeta-1.0-SNAPSHOT.jar ... cmd="$HADOOP jar ${current_dir}/lib/index-1.0-SNAPSHOT.jar ... cmd="$HADOOP jar ${current_dir}/lib/indexmeta-1.0-SNAPSHOT.jar ... 2.start.sh在某些情况下时无法正确的将dist/index-0.1/lib中的jar包加入HADOOP_CLASSPATH,导致hadoop jar docmeta-1.0.jar...命令会报错，no class found meta/MetaConfigured。 3.hadoop jar docmeta-1.0.jar....会报如下错误： java.io.IOException: Incomplete HDFS URI, no host:...

How to mirror traffic?

1

We use Calico to manage containers network in our k8s cluster, and want to mirror network traffic between pods to other machine network card. Does Calico provide any api/command to...

custom function in an external jar

2

In my case user can define custom function in their own project and package a jar file, then upload it to a common local path(~/plugins). Flink application(we call it engine...

If input is mixed with delayed data cep cannot output correct

5

Below is the code: ``` package org.apache.flink.streaming.siddhi.testdelaydata; import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.streaming.api.TimeCharacteristic; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks; import org.apache.flink.streaming.api.functions.source.SourceFunction; import org.apache.flink.streaming.api.watermark.Watermark; import org.apache.flink.streaming.siddhi.SiddhiCEP; import javax.annotation.Nullable; import java.io.Serializable; class MyTimestampExtractor implements...

custom function cannot use in retturn()

2

If I register a custom function like this: `cep.registerExtension("str:groupConcat", GroupConcatFunctionExtension.class);` Below code will return an exception like 'groupConcat() is neither a function or aggregate': `DataStream outstream2 = cep.from("inputstream2").cql("from inputstream2#window.timeBatch(1 sec)...

I can't find the v0.3 release. The relase page shows that the latest version is 0.2.