I have a requirement to read the data from redis cache in flink, but as per the requirements the cache data will be refreshed on an average every two hours. I was going through the documentation and other stackoverflow questions…
as we know there's no sharing state mechanism in Flink at the moment, but I suppose we can achieve it. Suppose we have a Flink job (with a single input source) and we want to know what happened at the…
We are looking to use existing redis streams in our application and process messages using Apache Flick, but could not find Redis source connector ? Any reason why Redis source connector is not available ? any constraint, is it technically…
We are comparing storm and flink. What we do is develop storm topology logic to flink app. There is using Thread.sleep(100) in the storm topology bolt, but when using in flink app, flink app performance is not good. Here is…
I'm coding a Java project to create a table within a Dockerized MySQL database using the Apache Flink API. As provided by the doc, I coded the following lines of code in order to define a streaming environment: StreamExecutionEnvironment env…
first of all I have read this post about the same issue and tried to follow the same solution that works for him (create a new quickstart with mvn and migrate the code there) and is not working eighter when…
I'm trying to submit a Flink job created with Scala 2.11 which uses the Twitter streaming API in a local Flink cluster by running in the command line: flink run -c org.myClass C:pathtojarFile.jar And get the following error: 2019-06-09 23:40:47,758…