Re: Will broadcast stream affect performance because of the absence of operator chaining?

2019-08-06 Thread
you! -- Original -- From: "Piotr Nowojski"; Date: Tue, Aug 6, 2019 06:57 PM To: "黄兆鹏"; Cc: "user"; Subject: Re: Will broadcast stream affect performance because of the absence of operator chaining? Hi, Have you meas

Re: Will broadcast stream affect performance because of the absence of operator chaining?

2019-08-06 Thread
ificant number of messages, run both jobs, compare the throughput and decide based on those results wether this is ok for you or not. Piotrek > On 6 Aug 2019, at 09:56, 黄兆鹏 wrote: > > Hi all, > My flink job has dynamic schema of data, so I want to consume a schema kafka > t

Will broadcast stream affect performance because of the absence of operator chaining?

2019-08-06 Thread
Hi all, My flink job has dynamic schema of data, so I want to consume a schema kafka topic and try to broadcast to every operator so that each operator could know what kind of data it is handling. For example, the two streams just like this: OperatorA -> OperatorB -> OperatorC ^