Jark Wu

icon indicating a website link http://wuchong.me

icon company @alibaba icon location Hangzhou China icon location Apache Flink PMC member & Committer. Work at Alibaba.

Results 73 comments of Jark Wu
trafficstars

问题：生产环境下connector可能会对mysql server的造成i/o压力? 是否支持mysql server的主从切换？

@gitdongjian , 目前还不支持自动切换，需要手动切换。比如原先的 hostname = A， 然后 A 挂了，B成为了新主，这时候 flink job 应该会挂。这时候需要 hostname 改成 B，然后将之前的作业从之前成功的 savepoint 恢复。

问题：生产环境下connector可能会对mysql server的造成i/o压力? 是否支持mysql server的主从切换？

@gitdongjian 有GTID 的话，就会用 GTID 来恢复。看你上面的异常信息是有 GTID的，可能是新主上面binlog被清理了，没有这个 GTID 了。可以在你的新主上执行下 `show global variables like '%gtid%'`看看 `3fa7d5bb-65f3-11eb-9413-b0262879b560:1-730774004` 在不在你的 `gtid_purged` 里面。

问题：生产环境下connector可能会对mysql server的造成i/o压力? 是否支持mysql server的主从切换？

@SEZ9 这个错误的意思是你的 server 没有开启 GTID。 GTID_MODE 需要设置为 ON

[FLINK-28751][Table SQL/Runtime] Optimize the performance of the json…

Do you have any benchmark between the two implementations?

[FLINK-28751][Table SQL/Runtime] Optimize the performance of the json…

@flinkbot run azure

[FLINK-28780][docs] fix incorrect description of function dayofmonth.

@snuyanzin is right. Would be better to follow the description template especially when the PR is not a simple hotfix.

[FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed

`HiveDialectQueryITCase.testCastTimeStampToDecimal:804` is failed, please take a look.

[FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed

The `HiveDialectQueryITCase.testCastTimeStampToDecimal` is still failed.

[FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed

@flinkbot run azure

[FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type

Could you add an IT case for this?