Re: Integration Test for Kafka Streaming job

Hi I would recommend to use kafka-junit5 from salesforce https://github.com/salesforce/kafka-junit On top of that, you can use org.apache.flink.runtime.minicluster.TestingMiniCluster Your stack should be complete. Cheers Le jeu. 21 avr. 2022 à 07:10, Aeden Jameson a écrit : > I've had success

Running two versions of Flink with testcontainers

onResponse (org.apache.flink.util.SerializedValue and org.apache.flink.runtime.registration.RegistrationResponse are in unnamed module of loader 'app') ... 8 common frames omitted Thanks Farouk

Re: Savepoint documentation

on. >>> >>> >>> If you want more detail than the quick answer, see [2]. >>> >>> Best, >>> David >>> >>> [1] >>> https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/state/savepoints/#can-i-move-the-savepo

Savepoint documentation

ate/savepoints.html#top> Thanks Farouk

RE: Flink 1.10 feedback

Thanks I’ll give a try De : danrtsey...@gmail.com Envoyé : jeudi 6 février 2020 15:24 À : Farouk Cc : user Objet : Re: Flink 1.10 feedback Hi Farouk, Currently, the community does not provide the image on docker hub for un-released version. I think you could using the following steps to

Flink 1.10 feedback

Hi guys Is there an easy way to test in advance Flink 1.10 with docker images before releasing 1.10 ? We can may be give you a feedback. We have tests running with TestContainers. Thanks Farouk

Re: Docker flink 1.9.1

Hi I checked there is 2 PR on github for Flink 1.9.1. It should come soon enough :) Thanks Farouk Le mer. 23 oct. 2019 à 17:46, vino yang a écrit : > Hi Farouk, > > Not long after Flink 1.9.1 was released, the community may not have time > to provide the corresponding Docker

Docker flink 1.9.1

Hi Is there an official image published for Flink 1.9.1 on Docker hub ? I can't find anything and there is one for minor flink version 1.8.2. Thanks Farouk

Re: Job manager failing because Flink does not find checkpoints on HDFS

Hi all I am sorry. We found out that's it's a problem in our deployment. The directories in Zookeeper and HDFS are not the same. Thanks for the help Farouk Le jeu. 1 août 2019 à 11:38, Zhu Zhu a écrit : > Hi Farouk, > > This issue does not relate to checkpoints. The JM

Job manager failing because Flink does not find checkpoints on HDFS

org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getBlockLocationsInt(FSNamesystem.java:2025) at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getBlockLocations(FSNamesystem.java:1996) at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getBlockLocations(FSNamesystem.java:1909) Thanks Farouk error.log Description

Re: NPE in Flink 1.8.0

Hi We had the same issue. Make sure everything is using Flink 1.8 and not half on 1.7.2 and the other half on 1.8. Make sure to prune docker images and so on, even maven repo. Farouk Le mer. 15 mai 2019 à 18:08, Akshay Shinde a écrit : > Hi > > > We would highly appreciate any

Re: Migration from flink 1.7.2 to 1.8.0

Hi Till Thanks. I'll check it out. Farouk <http://www.avg.com/email-signature?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail> Garanti sans virus. www.avg.com <http://www.avg.com/email-signature?utm_medium=email&utm_source=link&

Migration from flink 1.7.2 to 1.8.0

(StreamTask.java:267) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:748) Any idea on what's happening ? I think it's a problem with classloading. With Flink 1.7.2, every thing works fine Thanks Farouk