1
Eclipseでかなりうまく動作しているアプリがあります。クラスタにデプロイするときには、これで非常に迅速に失敗します。Apache flink CEPライブラリの問題(クラスタ)
java.lang.RuntimeException:メイン(String []型)クラスorg.ice.drmcl.Applicationから 方法を検索できませんでした: ORG/apache/flink/cep/pattern/conditions/IterativeCondition
パターンマッチングコードを含めると発生します。このような:
Pattern<TransferMonitor, ?> pattern = Pattern.<TransferMonitor>begin("start")
.where(new SimpleCondition<TransferMonitor>() {
// ...
});
Eclipseとクラスタの両方がFLINK v1.3.2デベロッパーに
./bin/flinkを実行すると./WordCount.jarがFlinkによって提供されるように動作することができるので、独自のカスタムのFlink CEP jarを実行できますか –