Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
通过算子的构造方法传递变量失效
Classic
List
Threaded
♦
♦
Locked
2 messages
freeza1982@outlook.com
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
通过算子的构造方法传递变量失效
hi all:
我定义了1个flatMap,通过构造方法传递了1个int类型的变量, 我在最外层定义了2条流,流定义的时候.flatMap(int)传入了这个变量, 目前有2个不同的flatmap,构造方法传入的这个int变量为2个不同的值,
当有数据流过这2个算子的时候,发现该int变量并没有发生变化,请如何给算子传递变量。
[hidden email]
Shubin Ruan
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Re:通过算子的构造方法传递变量失效
hi,可以把部分代码贴出来看一下吗?
在 2020-10-28 17:29:58,"
[hidden email]
" <
[hidden email]
> 写道:
>hi all:
> 我定义了1个flatMap,通过构造方法传递了1个int类型的变量, 我在最外层定义了2条流,流定义的时候.flatMap(int)传入了这个变量, 目前有2个不同的flatmap,构造方法传入的这个int变量为2个不同的值,
>当有数据流过这2个算子的时候,发现该int变量并没有发生变化,请如何给算子传递变量。
>
>
>
>
[hidden email]
Free forum by Nabble
Edit this page