作为PyFlink pipeline.classpath配置的一部分传递的类加载类与将它们放入$FLINK_HOME\lib目录之间有什么区别?
当我想使用flink-sql-connector-kafka-*.jar时,只要使用pipeline.classpath传递它就可以了,但是当我想使用一些具有一些外部依赖项的东西时,比如需要avro-*.jar jars的flink-avro-*.jar。它似乎加载了flink-avro-*.jar,但它似乎无法加载avro-*.jar并抛出:
java.lang.NoClassDefFoundError: Could not initialize
我在Apache Flink的BroadcastStream中有一组规则。当新规则应用到我的事件流中时,我能够应用新规则。但是,如果我的规则像这样,我不知道该如何实现
rule 1> alert when count of event a is greater than 5 in a window of 5 mins
rule 2> alert when count of event a is greater than 4 in a window of 15 mins
我是flink的新手。我不能弄明白这一点。