Thanks for your information.
So there is no solution for this as of now ?
On Mon 10 Dec, 2018, 1:16 PM Shuyi Chen We've seen similar issue in our production, you can refer to this JIRA (
> https://issues.apache.org/jira/browse/FLINK-10848) for more detail.
>
> Shuyi
>
> On Sun, Dec 9, 2018 at
Hi Jorn,
There are no more logs . Attaching yarn aggregated logs for first problem .
For second one job is not even getting submitted.
- Sohi
On Sun, Dec 9, 2018 at 2:13 PM Jörn Franke wrote:
> Can you check the Flink log files? You should get there a better
> description of the error.
>
> >
Hi Stefan ,
Here is main class code :
final String outFile = getOutFileName(backupDir);
final Set keys = getAllRedisKeys(parameters);
final ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(parallelism);
env
.fromCollection(keys)
