apache-flink

1热度

2回答

我选择哪种开源CEP应用于分布式和流水线处理; siddhi，Flink，Esper？

我对siddhi cep很少有兴趣，因为它具有siddhi查询语言，但它使用storm进行分布式处理，WSO2提供了一个Web界面/仪表板来创建和部署应用程序。我认为这会降低我独立性来增强/使用某些功能。 Flink另一方面似乎是不错的选择，但它需要很多代码来实现简单的逻辑。难道还有比这更好的选择，我困惑

0热度

1回答

即使在阿帕奇弗林克

我已经写了简单的样品甚至实现AppendTableSink接口后下沉表，但得到这个例外在Apache中弗林克实施AppendTableStream接口后获得下面的错误。 package com.cc.flink.functionUtils; import java.io.IOException; import java.util.ArrayList; import

1热度

2回答

Flink删除旧检查点文件

我们使用文件系统作为检查点状态后端。以下是我们的设置： StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setStreamTimeCharacteristic(timeCharacteristic); env.getConfig().setAutoWaterma

2热度

1回答

弗林克流：在序列化的字符串消息意外charaters

我的流是生产类型的记录Tuple2<String,String> .toString()输出(usr12345,{"_key":"usr12345","_temperature":46.6}) 其中键是usr12345和值是{"_key":"usr12345","_temperature":46.6} 在流输出的.print()该值正确： (usr12345,{"_key":"usr12345",

0热度

1回答

使用Flink和kinesis流的流窗口处理处理不起作用

我正在使用Flink读取kinesis流。它基于时间窗口和密钥聚合某个事件。代码在reduce之后不做任何事情。没有数据被映射到输出csv中。我等了很多分钟（即使时间窗口只有两分钟）。 public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExec

-1热度

1回答

flink的状态可以在多个流中共享吗？

我有一个关于flink'状态的问题。我想知道状态是否可以被多个流共享。谢谢。

2热度

1回答

Flink上Beam管道运行期间与内存段相关的EOFException

我试图在我们的测试集群上的Flink上运行Apache Beam管道。在通过序列化对对象进行编码期间，EOFException在org.apache.flink.runtime.io.disk.SimpleCollectingOutputView:79处失败。我还没有能够在本地重现错误。你可以找到the entire job log here。一些值已被假数据取代。用于运行管道命令：虽然我认为这

0热度

1回答

处理在弗林克CEP多个图案并联

我有以下情况有其发送流卡夫卡正在被由CEP引擎接收其中警告时产生的特定条件2的虚拟机对个人Stream满意。目前，CEP是检查两个流上相同条件下（当心脏率> 65和呼吸率> 68）患者和如下图所示 // detecting pattern Pattern<joinEvent, ? > pattern = Pattern.<joinEvent>begin("start")

1热度

1回答

Flink卡夫卡连接器0.10.0事件时间澄清和处理功能澄清

我正在努力解决flink的卡夫卡用户连接器的事件时间问题。援引Flink doc 因为Apache卡夫卡0.10+，卡夫卡的消息可以携带的时间戳，表示当该消息已被写入到卡夫卡该事件已经发生（参见阿帕奇弗林克“事件时间”）的时刻或时间经纪人。如果Flink中的时间特征设置为TimeCharacteristic.EventTime（StreamExecutionEnvironment.setStr

0热度

1回答

neo4j与Flink和斯卡拉

我正在处理数据与斯卡拉2.11.7和Flink 1.3.2。现在我想将生成的org.apache.flink.api.scala.DataSet存储在neo4j图形数据库中。有Github上项目的兼容性：弗林克用的Neo4j：https://github.com/s1ck/flink-neo4j 斯卡拉与Neo4j的：_HTTPS：//github.com/FaKod/neo4j-scala