Re:Re: sql 动态修改参数问题

[Michael Ran]

我没重现这个BUG，是1.12 的版本吗？



在 2021-03-04 23:12:11，"Jark Wu"  写道：
>看起来是个分段优化复用节点的bug，可以去 JIRA 开个 issue。
>
>Best,
>Jark
>
>On Thu, 4 Mar 2021 at 19:37, 酷酷的浑蛋  wrote:
>
>> StatementSet statementSet = tableEnvironment.createStatementSet();
>> String sql1 = "insert into test select a,b,c from test_a_12342 /*+
>> OPTIONS('table-name'='test_a_1')*/";
>> String sql2 = "insert into test select a,b,c from test_a_12342 /*+
>> OPTIONS('table-name'='test_a_2')*/";
>> statementSet.addInsertSql(sql1);
>> statementSet.addInsertSql(sql2);
>> statementSet.execute();
>>
>>
>> Sql代码如上，在最终insert后是将test_a_1表的数据插入了两遍，而test_a_2的数据并没有插入，请问这个是bug吗

Re: sql 动态修改参数问题

[Jark Wu]

看起来是个分段优化复用节点的bug，可以去 JIRA 开个 issue。

Best,
Jark

On Thu, 4 Mar 2021 at 19:37, 酷酷的浑蛋  wrote:

> StatementSet statementSet = tableEnvironment.createStatementSet();
> String sql1 = "insert into test select a,b,c from test_a_12342 /*+
> OPTIONS('table-name'='test_a_1')*/";
> String sql2 = "insert into test select a,b,c from test_a_12342 /*+
> OPTIONS('table-name'='test_a_2')*/";
> statementSet.addInsertSql(sql1);
> statementSet.addInsertSql(sql2);
> statementSet.execute();
>
>
> Sql代码如上，在最终insert后是将test_a_1表的数据插入了两遍，而test_a_2的数据并没有插入，请问这个是bug吗

sql 动态修改参数问题

[酷酷的浑蛋]

StatementSet statementSet = tableEnvironment.createStatementSet();
String sql1 = "insert into test select a,b,c from test_a_12342 /*+ 
OPTIONS('table-name'='test_a_1')*/";
String sql2 = "insert into test select a,b,c from test_a_12342 /*+ 
OPTIONS('table-name'='test_a_2')*/";
statementSet.addInsertSql(sql1);
statementSet.addInsertSql(sql2);
statementSet.execute();


Sql代码如上，在最终insert后是将test_a_1表的数据插入了两遍，而test_a_2的数据并没有插入，请问这个是bug吗