Apache Flink: could not find implicit value for evidence parameter of type This is a common error when transforming streams in Apache Flink based applications. The solution is simple. We just need to import the following: Which should import the necessary types for the operations.
Apache Flink: History Server One of the problems we have faced running Apache Flink that we have a very limited windows for getting access to the details about failed / crashed jobs. The job details just disappear and cannot be retrieved especially form web front end. Here is how it looks like: Actually we are… Continue reading »
Flink – Interactive Scala Shell Interactive scala shell is available in Flink download package. It allows us to run flink streams and batch processing statements in scala by building and executing the jobs directly created from the shell. We can simply call execute() method, which should request to run the job. The shell supports including… Continue reading »