Version 1.11.2
On Sun, Dec 6, 2020 at 10:20 PM Yun Gao wrote:
> Hi Rex,
>
>I tried a similar example[1] but did not reproduce the issue, which
> version of Flink you are using now ?
>
> Best,
> Yun
>
>
>
>
> [1] The example code:
>
> StreamExecutionEnvironment bsEnv =
> StreamExecutionEnvi
Hi Rex,
I tried a similar example[1] but did not reproduce the issue, which version
of Flink you are using now ?
Best,
Yun
[1] The example code:
StreamExecutionEnvironment bsEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
bsEnv.setRestartStrategy(RestartStrategies.noRestart())
cc Brad
On Thu, Dec 3, 2020 at 10:17 PM Rex Fenley wrote:
> Yes, the same exact input operators go into both joins.
>
> The chunk of code for the joins from the specific part of the plan I
> showed is as follows. The orgUsersTable is later filtered into one table
> and aggregated and another tab
Yes, the same exact input operators go into both joins.
The chunk of code for the joins from the specific part of the plan I showed
is as follows. The orgUsersTable is later filtered into one table and
aggregated and another table and aggregated. The planner seems to duplicate
orgUsersTable into 2
Hi Rex,
Could you also attach one example for these sql / table ? And one possible
issue to confirm is that does the operators with the same names also have the
same inputs ?
Best,
Yun
--Original Mail --
Sender:Rex Fenley
Send Date:Fri Dec 4 02:55:41 2020
