2017-08-19 6 views
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デベロッパーに

答えて

2

ああルックを実行している - あなたはマニュアルを読んでいない、なぜ....: - 「FlinkCEPは現在、一部ではないことに注意してくださいバイナリの分布の。

これは実際にそこにあなたのクラスを見つけることができない理由を説明するかもしれません。頭を振る。

+0

./bin/flinkを実行すると./WordCount.jarがFlinkによって提供されるように動作することができるので、独自のカスタムのFlink CEP jarを実行できますか –

関連する問題