問題タブ [flink-cep]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-flink - flink cepでタプルにsubtype()を行うにはどうすればよいですか?
subtype(Tuple.getTupleClass( 2 ))、およびエラーが発生しました
Inferred type 'capture<? extends org.apapche.flink.api.java.tuple.Tuple>' for type parameter 'S' is not within its bound;should extend 'org.apapche.flink.api.java.tuple.Tuple3<java.lang.String,java.lang.String,java.lang.String>'
これを変更する必要がありますか?しかし、どのように?Pattern< Tuple3< String, String, String >, ? > pattern
2017年までに更新012
私はこれを試しましたが、何を記入する必要はありませんPatternStream< ...>.助けを提供できる人に感謝します.
apache-flink - TaskManager の Flink 状態バックエンド
独自の VM にそれぞれ 1 つのジョブ マネージャー、2 つのタスク マネージャーを備えた Flink v1.2 セットアップがあります。状態バックエンドをファイルシステムに構成し、上記の各ホストの場合にローカルの場所を指すようにしました (state.backend.fs.checkpointdir: file:///home/ubuntu/Prototype/flink/flink-checkpoints)。並列処理を 1 に設定し、各 taskanager には 1 つのスロットがあります。次に、JobManager でイベント処理ジョブを実行し、それを TaskManager に割り当てます。ジョブを実行している TaskManager を強制終了し、失敗した TaskManager で数回失敗した後、Flink は残りの TaskManager でジョブを実行しようとします。この時点で、対応するチェックポイント/状態が見つからないため、再び失敗します: java.io.FileNotFoundException:
フォルダー /home/ubuntu/Prototype/flink/flink-checkpoints/56c409681baeaf205bc1ba6cbe9f8091 は、私が強制終了した TaskManager にのみ存在し、他のフォルダーには存在しません。
私の質問は、上記の機能が必要な場合、すべてのタスクマネージャーでチェックポイント/状態に同じ場所を設定することになっていますか?
ありがとう！
apache-flink - Flink 1.2 が HA クラスター モードで起動しない
Flink 1.2 を HA クラスター モード 2 JobManagers 1 TaskManager ローカルにインストールしましたが、このモードで実際に開始することを拒否し続け、「クラスターを開始しています」と表示されます。「ZooKeeper クォーラムで 2 つのマスターと 1 つのピアを使用して HA クラスターを開始しています」というメッセージの代わりに。
どうやら bin/config.sh で、次のような構成を読み取ります。
つまり、構成ファイルで「高可用性」キーに構成されているもの (私の場合、値は「zookeeper」) とは無関係に、それを「none」に設定し、bin/start-cluster.sh で設定します。
最初の if ブランチに入ることはありません。
他の誰かがこれに直面しましたか？