Блог

Главная - Вопросы по программированию - Сбой запуска события управления Flink-Siddhi

Сбой запуска события управления Flink-Siddhi

#flink-streaming #siddhi

Вопрос:

При попытке настроить и реализовать flink — сиддхи(https://clojars.org/com.github.haoch/flink-siddhi_2.11/версии/0.2.2-СНИМОК) поток управления для приема правил , я получаю ошибку ниже: ошибка абстрактного метода, как показано ниже:

 Exception in thread "main" java.lang.AbstractMethodError
    at org.apache.flink.streaming.api.graph.StreamGraphGenerator.lambda$generate$0(StreamGraphGenerator.java:305)
    at java.util.stream.MatchOps$1MatchSink.accept(MatchOps.java:90)
    at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1361)
    at java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:126)
    at java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:499)
    at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:486)
    at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
    at java.util.stream.MatchOps$MatchOp.evaluateSequential(MatchOps.java:230)
    at java.util.stream.MatchOps$MatchOp.evaluateSequential(MatchOps.java:196)
    at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
    at java.util.stream.ReferencePipeline.anyMatch(ReferencePipeline.java:449)
    at org.apache.flink.streaming.api.graph.StreamGraphGenerator.generate(StreamGraphGenerator.java:305)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:2010)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1995)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1834)
    at flinksidhi.app.s3.SiddhiTestApp.start(SiddhiTestApp.java:104)
    at flinksidhi.S3SidhiApp.main(S3SidhiApp.java:8)

Код для контрольного события:

 Properties properties = new Properties();
properties.setProperty("bootstrap.servers", kafkaAddress);
properties.setProperty("zookeeper.connect",zkAddress );
properties.setProperty("group.id","test_rule");
DataStream<? extends ControlEvent> ruleControlStream = env.addSource(new FlinkKafkaConsumer("S3_RULE_STREAM_INPUT",
                new ControlEventSchema(), properties));

Любая помощь в этом будет очень необходима …

С уважением Дипанджан

Комментарии:

1. Просто обновление вышеуказанная проблема не отмечена в случае Flink 1.11.0 , это происходит только в случае Flink 1.12.0 и 1.13.0

2. Возможно, библиотека Сиддхи работает только с Flink

3. Верно , но есть ли какая-либо альтернатива сиддхи на финке в этом случае , или флинк планирует что-то в этом отношении, или Флинк КЭП является полноценным и может ли он заменить сиддхи в этом случае, у меня есть несколько вопросов, чтобы решить использовать Флинк КЭП в этом случае.

4. Сообщество Flink не ведет активной работы по замене библиотеки Сиддхи. Вы можете проверить, соответствует ли FlinkCEP вашим требованиям.

Метки: