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()的正确性。