t
Yun Tang
From: godfrey he
Sent: Tuesday, May 10, 2022 17:33
To: dev
Subject: Re: Re: 【Could we support distribute by For FlinkSql】
Hi, Ipengdream. I will drive this work.
We will support this functionality via hints,
because "distribute by" is not in the sql stan
That's great. Thank you! Where can i get more information about
> > that?
> >
> >
> >
> > lpengdr...@163.com
> >
> > 发件人： Jark Wu
> > 发送时间： 2022-05-09 14:12
> > 收件人： dev
> > 抄送： 贺小令
> > 主题： Re: Re: 【Could we support di
Where can i get more information about
> that?
>
>
>
> lpengdr...@163.com
>
> 发件人： Jark Wu
> 发送时间： 2022-05-09 14:12
> 收件人： dev
> 抄送： 贺小令
> 主题： Re: Re: 【Could we support distribute by For FlinkSql】
> I got what you want, maybe something like DISTRIBUTED BY
Yeah! That's great. Thank you! Where can i get more information about that?
lpengdr...@163.com
发件人： Jark Wu
发送时间： 2022-05-09 14:12
收件人： dev
抄送： 贺小令
主题： Re: Re: 【Could we support distribute by For FlinkSql】
I got what you want, maybe something like DISTRIBUTED BY in Hive SQL
://docs.google.com/document/d/1D7AX-_wttMNY53TxLQxiDaRyDVCeEZYCE8AwYflDXZM/edit?usp=sharing
>
>
>
>
>
> lpengdr...@163.com
>
> 发件人： Jark Wu
> 发送时间： 2022-05-09 12:27
> 收件人： dev
> 主题： Re: 【Could we support distribute by For FlinkSql】
> Hi,
>
> If you are lo
blems ?
https://docs.google.com/document/d/1D7AX-_wttMNY53TxLQxiDaRyDVCeEZYCE8AwYflDXZM/edit?usp=sharing
lpengdr...@163.com
发件人： Jark Wu
发送时间： 2022-05-09 12:27
收件人： dev
主题： Re: 【Could we support distribute by For FlinkSql】
Hi,
If you are looking for the hash lookup join, there
zh ; dev
> *主题：* 【Could we support distribute by For FlinkSql】
> Hello：
> Now we cann't add a shuffle-operation in a sql-job.
> Sometimes , for example, I have a kafka-source(three partitions) with
> parallelism three. And then I have a lookup-join function, I want process
>
Sorry!
The destroied picture is the attachment ;
lpengdr...@163.com
发件人： lpengdr...@163.com
发送时间： 2022-05-09 11:16
收件人： user-zh; dev
主题： 【Could we support distribute by For FlinkSql】
Hello：
Now we cann't add a shuffle-operation in a sql-job.
Sometimes , for example, I have a kafka-s
Hello：
Now we cann't add a shuffle-operation in a sql-job.
Sometimes , for example, I have a kafka-source(three partitions) with
parallelism three. And then I have a lookup-join function, I want process the
data distribute by id so that the data can split into thre parallelism evenly
(The so
