flink-cep

1熱度

1回答

的CEP庫使得如果X後跟Y. val pattern = Pattern.begin("start").where(_.value == "X") .next("end).where(_.value == "Y") 簡單寫一個程序來描述，它可以告訴但是，我將如何描述一個程序，我不關心X和Y的順序，而只關心另一個順序。例如X，Y和Y，X都很有意思。但是，X，X或Y，Y不是很有趣，所以我無法在第三個共

0熱度

1回答

如何弗林克CEP使用「每」模式操作

在艾斯波CEP引擎事件模式，有Every運營商這表明當由每個關鍵字合格的子表達式的計算結果爲真或假的圖案子表達式應該重新啓動。 According to this document，我們可以像不同的方式使用every操作： A -> B every (A -> B) every A -> B A -> every B every A -> every B

0熱度

2回答

如何做subtype（）元組在flink cep？

Pattern< Tuple3< String, String, String >, ? > pattern = Pattern.<Tuple3< String, String, String > > begin("start") .next("3").where(new FilterFunction< Tuple3< String, String, String > >()

1熱度

1回答

當任務管理器失敗時，Flink預期HA行爲

我創建了一個由1個JobManager和2個任務管理器組成的HA Flink v1.2羣集，每個羣集都在其自己的VM（不使用YARN或hdfs）中。在JobManager節點上啓動作業後，我終止了一個TaskManager實例。立即在Web儀表板中，我可以看到該作業被取消，然後失敗。如果我檢查日誌： 03/06/2017 16:23:50 Flat Map(1/2) switched to DE

0熱度

1回答

任務管理器的Flink狀態後端

我有一個Flink v1.2安裝程序，其中有1個JobManager，2個TaskManagers都在它自己的VM中。我將狀態後端配置爲文件系統，並在每個上述主機（state.backend.fs.checkpointdir：file：/// home/ubuntu/Prototype/flink/flink-checkpoints）的情況下將其指向本地位置。我已將並行度設置爲1，每個taskan

2熱度

1回答

在調用execute（）之後是否可以在FLINK CEP中添加新模式？

我的代碼如下： StreamExecutionEnvironment env= StreamExecutionEnvironment.getExecutionEnvironment(); DataStream<MyObject> input = env.addSource(new MyCustomSource()); Pattern<MyObject, ?> pattern = Patte

0熱度

1回答

Flink發射事件當找不到匹配的事件對時

我有兩個事件流：一個發出一個事件來指示一個項目的生命週期的開始，另一個流發出一個事件來指示一個項目的生命週期結束。（視頻流可上itemId加入。）我怎麼能發出在弗林克每個itemId1該只有有一個事件「壽命終點」的新事件，並沒有相應的開始？（這些開始和結束事件可能相隔幾小時或幾天。）

0熱度

1回答

Flink 1.2無法在HA羣集模式下啓動

我已在本地HA集羣模式2 JobManager 1 TaskManager中安裝Flink 1.2，並且它始終拒絕以此模式啓動，顯示「正在啓動羣集」。消息而不是「在ZooKeeper仲裁中啓動2個主節點和1個對等節點的HA羣集。」顯然在bin/config.sh它讀起來就像配置： # High availability if [ -z "${HIGH_AVAILABILITY}" ]; t

0熱度

1回答

基於第三個事件鏈接Flink中的兩個事件

如果兩個事件流入Flink，它們是否可以使用第三個事件中的信息進行邏輯連接（使用DataStream API或CEP）？例如，以下示例中的第三個事件是否可用於根據其right_id和left_id鏈接前兩個事件？ ID: AAAA ID: BBBB ID: ZZZZ, right_id: AAAA, left_id: BBBB

1熱度

1回答

Flink-CEP使用hashCode並等於

如果模式定義僅具有屬性級別比較，Flink-CEP是否使用hashCode()和equals()進行比較？我在問，因爲我無法保證hashCode()的正確性。