Hello, I have a standalone cluster setup with Flink 1.8. Task manager processes
configured via systemd units with the always restart policy. An error occurred
during execution of the JobGraph and caused termination of the task manager.
Logs from task manager:
{"time":"2019-09-02
11:33:14.797",
I have a simple job that reads JSON messages from Kafka topic and proccesses
them like this:
SingleOutputStreamOperator result = ds
.filter(ev -> ev.has(cookieFieldName))
.map(ev -> ev.get(cookieFieldName).asText())
.keyBy(new CookieKeySelector(env.getParallelism()))
