Re: Flink 1.4: Queryable State Client

2018-10-14 Thread Jörn Franke
You have to file an issue. One workaround to see if this really fixes your problem could be to use reflection to mark this method as public and then call it (it is of course nothing for production code). You can also try a newer Flink version. > Am 13.10.2018 um 18:02 schrieb Seye Jin : > > I

Re: Error restoring from savepoint while there's no modification to the job

2018-10-14 Thread Averell
Hi everyone, In the StreamExecutionEnvironment.createFileInput method, a file source is created as following: /SingleOutputStreamOperator source = *addSource*(monitoringFunction, sourceName) .*transform*("Split Reader: " + sourceName, typeInfo, rea

Flink streaming-job with redis sink: SocketTimeoutException

2018-10-14 Thread Marke Builder
Hi, what can be the reasons for the following exceptions. We are using flink with a redis sink, but from time to time the flink job failed with the follwing excpetions. Thanks, Builder. 10/13/2018 15:37:48 Flat Map -> (Sink: Unnamed, Sink: Unnamed)(9/10) switched to FAILED redis.clients.jed

Re: Flink streaming-job with redis sink: SocketTimeoutException

2018-10-14 Thread Amit Jain
Hi Marke, Stacktrace suggests it is more of a Redis connection issue rather than something with Flink. Could you share JedisPool configuration of Redis sink? Are you writing into Redis in continuity or some bulk logic? Looks like Redis connections are getting timeout here. -- Thanks, Amit On Mon