Hi，
看起来应该是你之前改代码时引入的小bug，因为从代码路径和测试来看都不能复现这个问题。
另外，如果修改了源代码记得邮件里说明下，不然好南
祝好，
Leonard Xu
> 在 2020年4月23日，16:26，1101300123 写道：
>
> 我重新在源码里打了一些日志编译后，之前的问题不见了，试了好多次没有复现了，之前因为集成clickhouse
> 改过源码的delete代码，不知道是不是这个引起的
> 在2020年4月23日 16:23，Leonard Xu 写道：
> Hi,
> 我本地复现了下，用1.10.0发现的你的sql是ok的，结果也符合预期☺
我重新在源码里打了一些日志编译后，之前的问题不见了，试了好多次没有复现了，之前因为集成clickhouse 改过源码的delete代码，不知道是不是这个引起的
在2020年4月23日 16:23，Leonard Xu 写道：
Hi,
我本地复现了下，用1.10.0发现的你的sql是ok的，结果也符合预期☺️，如下[1]：
看到你建了JIRA，我们在issue里继续跟进吧
祝好，
Leonard Xu
[1]
mysql> select * from order_state_cnt;
++--+--+
| order_date | p
Hi,
我本地复现了下，用1.10.0发现的你的sql是ok的，结果也符合预期☺️，如下[1]：
看到你建了JIRA，我们在issue里继续跟进吧
祝好，
Leonard Xu
[1]
mysql> select * from order_state_cnt;
++--+--+
| order_date | product_code | cnt |
++--+--+
| 2020-04-01 | product1 |3 |
| 2020-04-01 | pro
我给你一些数据和代码吧!和我真实场景错误一样
订单主表：orders
13点两条记录；order_state是状态 0取消 1待支付
{"order_no":"order1","order_state":1,"pay_time":"","create_time":"2020-04-01
13:00:00","update_time":"2020-04-01 13:00:00"}
{"order_no":"order2","order_state":1,"pay_time":"","create_time":"2020-04-01
13:00:00","update_time":"20
赞详细的分析!
没能复现你说的问题，最后一步的分析应该有点小问题，我看下了jdbc mysql的实现
com/mysql/jdbc/PreparedStatement.java#executeBatchInternal() 1289行
是会判断batchedArgs数组的大小后会直接返回的，应该不会执行，你可以进一步调试确认下
```
if (this.batchedArgs == null || this.batchedArgs.size() == 0) {
return new long[0];
}
```
祝好，
Leonard
好的，我先换了看看，之后建jira
在2020年4月22日 22:38，Jingsong Li 写道：
Hi,
- JDBC是upsert
sink，所以你需要toUpsertStream，而不是toRetractStream，建议你用完整的DDL来插入mysql的表。
- 这个异常看起来是JDBC的bug，你可以建个JIRA来跟踪吗？
Best,
Jingsong Lee
On Wed, Apr 22, 2020 at 9:58 PM 1101300123 wrote:
我在SQL关联后把结果写入mysql出现 No value specified fo
Hi,
- JDBC是upsert
sink，所以你需要toUpsertStream，而不是toRetractStream，建议你用完整的DDL来插入mysql的表。
- 这个异常看起来是JDBC的bug，你可以建个JIRA来跟踪吗？
Best,
Jingsong Lee
On Wed, Apr 22, 2020 at 9:58 PM 1101300123 wrote:
>
>
> 我在SQL关联后把结果写入mysql出现 No value specified for parameter 1错误？
> 我的版本是1.10.0，代码如下
> JDBCUpsertT
我在SQL关联后把结果写入mysql出现 No value specified for parameter 1错误？
我的版本是1.10.0，代码如下
JDBCUpsertTableSink build = JDBCUpsertTableSink.builder()
.setTableSchema(results.getSchema())
.setOptions(JDBCOptions.builder()
.setDBUrl("MultiQueries=true&useUnicode=tr
