Wrong argument used in StreamTask when user-defined backend is used

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Wrong argument used in StreamTask when user-defined backend is used

Vladislav Pernin
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L716

This should be :

LOG.info("Using user-defined state backend: {}.", fromJob);


Regards,
Vladislav
Reply | Threaded
Open this post in threaded view
|

Re: Wrong argument used in StreamTask when user-defined backend is used

Till Rohrmann
Thanks for the pointer. I will fix it.

Cheers,
Till

On Mon, Mar 13, 2017 at 4:28 PM, Vladislav Pernin <
[hidden email]> wrote:

> https://github.com/apache/flink/blob/master/flink-
> streaming-java/src/main/java/org/apache/flink/streaming/
> runtime/tasks/StreamTask.java#L716
>
> This should be :
>
> LOG.info("Using user-defined state backend: {}.", fromJob);
>
>
> Regards,
> Vladislav
>