Top "Apache-flink" questions

What is/are the main difference(s) between Flink and Storm?

Flink has been compared to Spark, which, as I see it, is the wrong comparison because it compares a windowed …

apache-storm apache-flink flink-streaming

What are the benefits of Apache Beam over Spark/Flink for batch processing?

Apache Beam supports multiple runner backends, including Apache Spark and Flink. I'm familiar with Spark/Flink and I'm trying to …

apache-spark apache-flink apache-beam

java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object

I am working with flink and kafka, i got this error. java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)…

java scala apache-flink flink-streaming

could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[...]

I am trying to write some use cases for Apache Flink. One error I run into pretty often is could …

scala apache-flink flink-streaming

How to use multi-thread consumer in kafka 0.9.0?

The doc of kafka give an approach about with following describes: One Consumer Per Thread:A simple option is to …

java multithreading apache-kafka distributed-computing apache-flink

difference between exactly-once and at-least-once guarantees

I'm studying distributed systems and referring to this old question: stackoverflow link I really can't understand the difference between exactly-once, …

cassandra apache-kafka apache-storm apache-flink

Combine two streams in Apache Flink regardless on window time

I have two data streams that I want to combine. The problem is that one data stream has a much …

apache join stream streaming apache-flink

Flink cluster configuration issue - no slots available

I have deployed Flink cluster with configuration for parallelism as follows: jobmanager.heap.mb: 2048 taskmanager.heap.mb: 2048 taskmanager.numberOfTaskSlots: 5 parallelism.…

apache-flink

Could not resolve substitution to a value: ${akka.stream.materializer} in AWS Lambda

I have a java application, in which I'm using the Flink Api. So basically what I'm trying to do with …

java amazon-web-services akka aws-lambda apache-flink