rrect check should be this,
> though:
> if (translator == null || !applyCanTranslate(transform, node, translator))
>
> Cheers,
> Aljoscha
>
> On Wed, 31 Aug 2016 at 12:07 Demin Alexey wrote:
>
> > Program for reproduce
> >
> > https://gist.
ow)
2016-08-31 13:53 GMT+04:00 Demin Alexey :
> Hi
>
> If we can change code on translator != null then next line (
> applyStreamingTransform(transform, node, translator); ) will cause NPE
>
> It's main problem why I don't understand code:
>
> x = nul
te(transform, node, translator))
>
> With what program did you encounter an NPE, it seems to me that this should
> rarely happen, at least it doesn't happen in all the Beam runner tests.
>
> Cheers,
> Aljoscha
>
> On Wed, 31 Aug 2016 at 11:27 Demin Alexey wrote:
>
>
Hi
Sorry if i mistake with mailing list.
After BEAM-102 was solved in FlinkStreamingPipelineTranslator we have code
in visitPrimitiveTransform:
if (translator == null && applyCanTranslate(transform, node, translator)) {
LOG.info(node.getTransform().getClass().toString());
throw new Unsuppo
