Re:通过算子的构造方法传递变量失效

[Shubin Ruan]

hi，可以把部分代码贴出来看一下吗？







在 2020-10-28 17:29:58，"freeza1...@outlook.com"  写道：
>hi all:
>我定义了1个flatMap，通过构造方法传递了1个int类型的变量， 我在最外层定义了2条流，流定义的时候.flatMap(int)传入了这个变量， 
>  目前有2个不同的flatmap，构造方法传入的这个int变量为2个不同的值，
>当有数据流过这2个算子的时候，发现该int变量并没有发生变化，请如何给算子传递变量。
>
>
>
>freeza1...@outlook.com

通过算子的构造方法传递变量失效

[freeza1...@outlook.com]

hi all:
我定义了1个flatMap，通过构造方法传递了1个int类型的变量， 我在最外层定义了2条流，流定义的时候.flatMap(int)传入了这个变量，  
目前有2个不同的flatmap，构造方法传入的这个int变量为2个不同的值，
当有数据流过这2个算子的时候，发现该int变量并没有发生变化，请如何给算子传递变量。



freeza1...@outlook.com