Re: Re: How to set disableChaining like streaming multiple INSERT statements in a StatementSet ?

[Hang Ruan]

Hi, Hjw,

Maybe this configuration is helpful.
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/config/#pipeline-operator-chaining

Best,
Hang

hjw  于2022年12月8日周四 12:01写道：

> hi,yuxia.
>
> The Dag Image of the job graph is attached in email.
> As the code image showed, I create a Table from DataStream.Then I create a
> StatementSet that contains three INSERT  statements  from same Table.
>
>
> --
> Best，
> Hjw
>
>
> At 2022-12-08 10:04:39, "yuxia"  wrote:
>
> Could you please post the image of the running job graph in Flink UI?
>
> Best regards,
> Yuxia
>
> --
> *发件人: *"hjw" 
> *收件人: *"User" 
> *发送时间: *星期四, 2022年 12 月 08日 上午 12:05:00
> *主题: *How to set  disableChaining like streaming multiple INSERT
>  statements   in a StatementSet ?
>
> Hi,
> I create a StatementSet that  contains  multiple  INSERT  statements.
> I found that  multiple  INSERT tasks will  be organized in a operator
> chain when StatementSet.execute() is invoked.
> How to set  disableChaining like streaming multiple INSERT  statements
>  in a StatementSet api ?
>
> env:
> Flink version:1.14.4
>
>
>
> --
> Best，
> Hjw
>
>

Re: How to set disableChaining like streaming multiple INSERT statements in a StatementSet ?

[yuxia]

Could you please post the image of the running job graph in Flink UI? 

Best regards, 
Yuxia 


发件人: "hjw"  
收件人: "User"  
发送时间: 星期四, 2022年 12 月 08日 上午 12:05:00 
主题: How to set disableChaining like streaming multiple INSERT statements in a 
StatementSet ? 

Hi, 
I create a StatementSet that contains multiple INSERT statements. 
I found that multiple INSERT tasks will be organized in a operator chain when 
StatementSet.execute() is invoked. 
How to set disableChaining like streaming multiple INSERT statements in a 
StatementSet api ? 

env: 
Flink version:1.14.4 








-- 
Best， 
Hjw