search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

[bug]The released flink-siddhi_2.11-0.2.2-SNAPSHOT.jar has old code #71

Closed lovepoem closed 3 years ago

lovepoem commented 3 years ago

Recently , I use flink-siddhi in my project , but I find the code from jar did not match the source code here https://github.com/haoch/flink-siddhi

image jars

https://repo.clojars.org/com/github/haoch/flink-siddhi_2.11/0.2.2-SNAPSHOT/

eg. org.apache.flink.streaming.siddhi.utils.SiddhiExecutionPlanner.StreamPartition

have no 


private List<String> partitionWithList = new ArrayList();

        public List<String> getPartitonWithList() {
            return this.partitionWithList;
        }

code in jar , but the source code contains it

Would you please release it again, thanks

haoch commented 3 years ago

Thanks for reporting the issue. It's updated now, please have a try again: https://repo.clojars.org/com/github/haoch/flink-siddhi_2.11/0.2.2-SNAPSHOT/flink-siddhi_2.11-0.2.2-20210106.071414-6.pom

lovepoem commented 3 years ago

image

https://github.com/haoch/flink-siddhi/blob/cf4b2b6935bc69be1b465e49431bb8485e4d670b/core/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiExecutionPlanner.java#L293

It seems that the difference still exist

lovepoem commented 3 years ago

Now fixed , thank you