首页 > TAG信息列表 > flink-streaming

Java-Flink-多个源的集成测试

我有一个Flink作业,正在使用此处描述的方法进行集成测试：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#integration-testing 作业从两个来源获取输入,这两个来源合并在CoFlatMapFuntion中.在测试环境中,我当前正在使用两个简单的SourceFunction

java-如何增加Flink taskmanager.numberOfTaskSlots以在没有Flink服务器的情况下运行它(在IDE或胖子中)

我有一个关于在IDE中或作为胖子运行Flink流作业而不将其部署到Flink服务器的问题. 问题是,当我的工作中有多个任务槽时,无法在IDE中运行它. public class StreamingJob { public static void main(String[] args) throws Exception { // set up the streaming execution envi

java-Apache Flink：如何计算DataStream中事件的总数

我有两个原始流,我正在加入这些流,然后我要计算已加入的事件总数是多少,尚未加入的事件有多少.我通过在joinedEventDataStream上使用地图来执行此操作,如下所示 joinedEventDataStream.map(new RichMapFunction<JoinedEvent, Object>() { @Override publ

java – Apache Flink：由TupleSerializer引起的NullPointerException

当我执行我的Flink应用程序时,它给我这个NullPointerException： 2017-08-08 13:21:57,690 INFO com.datastax.driver.core.Cluster - New Cassandra host /127.0.0.1:9042 added 2017-08-08 13:22:02,427 INFO org.apache.flink.runtime.taskmanager.Task

java – JpaRepository不在自定义RichSinkFunction中自动装配

我创建了一个自定义的Flink RichSinkFunction并试图在这个自定义类中自动装配JpaRepository,但我不断得到一个NullPointerException. 如果我在构造函数中自动装配它,我可以看到找到了JpaRepo – 但是当调用invoke方法时,我收到一个NullPointerException. public interface Messag